Skip to content

Commit 1e5579a

Browse files
authored
fix(operator): Select non-zero delete worker count for all sizes (#16492)
1 parent 5b33e65 commit 1e5579a

File tree

1 file changed

+8
-6
lines changed

1 file changed

+8
-6
lines changed

‎operator/internal/manifests/config.go

Lines changed: 8 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -367,11 +367,13 @@ func remoteWriteConfig(s *lokiv1.RemoteWriteSpec, rs *RulerSecret) *config.Remot
367367
return c
368368
}
369369

370-
var deleteWorkerCountMap = map[lokiv1.LokiStackSizeType]uint{
371-
lokiv1.SizeOneXDemo: 10,
372-
lokiv1.SizeOneXExtraSmall: 10,
373-
lokiv1.SizeOneXSmall: 150,
374-
lokiv1.SizeOneXMedium: 150,
370+
func deleteWorkerCount(size lokiv1.LokiStackSizeType) uint {
371+
switch size {
372+
case lokiv1.SizeOneXSmall, lokiv1.SizeOneXMedium:
373+
return 150
374+
default:
375+
return 10
376+
}
375377
}
376378

377379
func retentionConfig(ls *lokiv1.LokiStackSpec) config.RetentionOptions {
@@ -394,7 +396,7 @@ func retentionConfig(ls *lokiv1.LokiStackSpec) config.RetentionOptions {
394396

395397
return config.RetentionOptions{
396398
Enabled: true,
397-
DeleteWorkerCount: deleteWorkerCountMap[ls.Size],
399+
DeleteWorkerCount: deleteWorkerCount(ls.Size),
398400
}
399401
}
400402

0 commit comments

Comments
 (0)