fix: wire up ILM sub-system properly for help (#19836)

This commit is contained in:
Harshavardhana 2024-05-30 01:14:58 -07:00 committed by GitHub
parent 38d059b0ae
commit aad50579ba
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
3 changed files with 16 additions and 2 deletions

View File

@ -277,6 +277,10 @@ func (es *expiryState) getWorkerCh(h uint64) chan<- expiryOp {
} }
func (es *expiryState) ResizeWorkers(n int) { func (es *expiryState) ResizeWorkers(n int) {
if n == 0 {
n = 100
}
// Lock to avoid multiple resizes to happen at the same time. // Lock to avoid multiple resizes to happen at the same time.
es.mu.Lock() es.mu.Lock()
defer es.mu.Unlock() defer es.mu.Unlock()
@ -538,6 +542,10 @@ func (t *transitionState) UpdateWorkers(n int) {
} }
func (t *transitionState) updateWorkers(n int) { func (t *transitionState) updateWorkers(n int) {
if n == 0 {
n = 100
}
for t.numWorkers < n { for t.numWorkers < n {
go t.worker(t.objAPI) go t.worker(t.objAPI)
t.numWorkers++ t.numWorkers++

View File

@ -240,6 +240,11 @@ func initHelp() {
Description: "manage Browser HTTP specific features, such as Security headers, etc.", Description: "manage Browser HTTP specific features, such as Security headers, etc.",
Optional: true, Optional: true,
}, },
config.HelpKV{
Key: config.ILMSubSys,
Description: "manage ILM settings for expiration and transition workers",
Optional: true,
},
} }
if globalIsErasure { if globalIsErasure {
@ -288,6 +293,7 @@ func initHelp() {
config.DriveSubSys: drive.HelpDrive, config.DriveSubSys: drive.HelpDrive,
config.CacheSubSys: cache.Help, config.CacheSubSys: cache.Help,
config.BrowserSubSys: browser.Help, config.BrowserSubSys: browser.Help,
config.ILMSubSys: ilm.Help,
} }
config.RegisterHelpSubSys(helpMap) config.RegisterHelpSubSys(helpMap)

View File

@ -33,9 +33,9 @@ var (
return config.DefaultHelpPostfix(DefaultKVS, key) 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 // subsystem
HelpILM = config.HelpKVS{ Help = config.HelpKVS{
config.HelpKV{ config.HelpKV{
Key: transitionWorkers, Key: transitionWorkers,
Type: "number", Type: "number",