diff --git a/cmd/bucket-lifecycle.go b/cmd/bucket-lifecycle.go index a1cd73db6..a6b738c0f 100644 --- a/cmd/bucket-lifecycle.go +++ b/cmd/bucket-lifecycle.go @@ -277,6 +277,10 @@ func (es *expiryState) getWorkerCh(h uint64) chan<- expiryOp { } func (es *expiryState) ResizeWorkers(n int) { + if n == 0 { + n = 100 + } + // Lock to avoid multiple resizes to happen at the same time. es.mu.Lock() defer es.mu.Unlock() @@ -538,6 +542,10 @@ func (t *transitionState) UpdateWorkers(n int) { } func (t *transitionState) updateWorkers(n int) { + if n == 0 { + n = 100 + } + for t.numWorkers < n { go t.worker(t.objAPI) t.numWorkers++ diff --git a/cmd/config-current.go b/cmd/config-current.go index 5d1d136d1..e5daa847c 100644 --- a/cmd/config-current.go +++ b/cmd/config-current.go @@ -240,6 +240,11 @@ func initHelp() { Description: "manage Browser HTTP specific features, such as Security headers, etc.", Optional: true, }, + config.HelpKV{ + Key: config.ILMSubSys, + Description: "manage ILM settings for expiration and transition workers", + Optional: true, + }, } if globalIsErasure { @@ -288,6 +293,7 @@ func initHelp() { config.DriveSubSys: drive.HelpDrive, config.CacheSubSys: cache.Help, config.BrowserSubSys: browser.Help, + config.ILMSubSys: ilm.Help, } config.RegisterHelpSubSys(helpMap) diff --git a/internal/config/ilm/help.go b/internal/config/ilm/help.go index d0037d8dc..9cbf30b15 100644 --- a/internal/config/ilm/help.go +++ b/internal/config/ilm/help.go @@ -33,9 +33,9 @@ var ( return config.DefaultHelpPostfix(DefaultKVS, key) } - // HelpILM holds configuration keys and their default values for the ILM + // Help holds configuration keys and their default values for the ILM // subsystem - HelpILM = config.HelpKVS{ + Help = config.HelpKVS{ config.HelpKV{ Key: transitionWorkers, Type: "number",