Skip to content

Commit

Permalink
remove maxStoreIndexSize option from create-version-store-index command
Browse files Browse the repository at this point in the history
  • Loading branch information
DanEngelbrecht committed Apr 24, 2023
1 parent de1d2f1 commit b987456
Showing 1 changed file with 3 additions and 7 deletions.
10 changes: 3 additions & 7 deletions commands/cmd_createversionstoreindex.go
Original file line number Diff line number Diff line change
Expand Up @@ -16,8 +16,7 @@ func createVersionStoreIndex(
s3EndpointResolverURI string,
sourceFilePath string,
versionLocalStoreIndexPath string,
storeIndexCachePath string,
maxStoreIndexSize int64) ([]longtailutils.StoreStat, []longtailutils.TimeStat, error) {
storeIndexCachePath string) ([]longtailutils.StoreStat, []longtailutils.TimeStat, error) {
const fname = "createVersionStoreIndex"
log := logrus.WithFields(logrus.Fields{
"fname": fname,
Expand All @@ -27,7 +26,6 @@ func createVersionStoreIndex(
"sourceFilePath": sourceFilePath,
"versionLocalStoreIndexPath": versionLocalStoreIndexPath,
"storeIndexCachePath": storeIndexCachePath,
"maxStoreIndexSize": maxStoreIndexSize,
})
log.Info(fname)

Expand All @@ -39,7 +37,7 @@ func createVersionStoreIndex(
jobs := longtaillib.CreateBikeshedJobAPI(uint32(numWorkerCount), 0)
defer jobs.Dispose()

indexStore, err := remotestore.CreateBlockStoreForURI(blobStoreURI, storeIndexCachePath, maxStoreIndexSize, nil, jobs, numWorkerCount, 8388608, 1024, remotestore.ReadOnly, false, longtailutils.WithS3EndpointResolverURI(s3EndpointResolverURI))
indexStore, err := remotestore.CreateBlockStoreForURI(blobStoreURI, storeIndexCachePath, -1, nil, jobs, numWorkerCount, 8388608, 1024, remotestore.ReadOnly, false, longtailutils.WithS3EndpointResolverURI(s3EndpointResolverURI))
if err != nil {
return storeStats, timeStats, errors.Wrap(err, fname)
}
Expand Down Expand Up @@ -96,7 +94,6 @@ type CreateVersionStoreIndexCmd struct {
SourceUriOption
VersionLocalStoreIndexPathOption
StoreIndexCachePathOption
MaxStoreIndexSizeOption
}

func (r *CreateVersionStoreIndexCmd) Run(ctx *Context) error {
Expand All @@ -106,8 +103,7 @@ func (r *CreateVersionStoreIndexCmd) Run(ctx *Context) error {
r.S3EndpointResolverURL,
r.SourcePath,
r.VersionLocalStoreIndexPath,
r.StoreIndexCachePath,
r.MaxStoreIndexSize)
r.StoreIndexCachePath)
ctx.StoreStats = append(ctx.StoreStats, storeStats...)
ctx.TimeStats = append(ctx.TimeStats, timeStats...)
return err
Expand Down

0 comments on commit b987456

Please sign in to comment.