ClusterCockpit/cc-backend
1
0
Fork 0
mirror of https://github.com/ClusterCockpit/cc-backend synced 2026-02-28 13:27:30 +01:00
Code Issues Packages Releases Activity

Modernize code

Browse Source
This commit is contained in:
Jan Eitzinger
2026-02-19 09:01:54 +01:00
parent 415467967d
commit 8b7cb587c5
1 changed files with 4 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
pkg/metricstore/checkpoint.go
View File

@@ -98,9 +98,7 @@ func Checkpointing(wg *sync.WaitGroup, ctx context.Context) {
if Keys.Checkpoints.FileFormat == "json" { if Keys.Checkpoints.FileFormat == "json" {
ms := GetMemoryStore() ms := GetMemoryStore()
wg.Add(1) wg.Go(func() {
go func() {
defer wg.Done()
d, err := time.ParseDuration(Keys.Checkpoints.Interval) d, err := time.ParseDuration(Keys.Checkpoints.Interval)
if err != nil { if err != nil {
cclog.Fatalf("[METRICSTORE]> invalid checkpoint interval '%s': %s", Keys.Checkpoints.Interval, err.Error()) cclog.Fatalf("[METRICSTORE]> invalid checkpoint interval '%s': %s", Keys.Checkpoints.Interval, err.Error())
@@ -136,12 +134,9 @@ func Checkpointing(wg *sync.WaitGroup, ctx context.Context) {
} }
} }
} }
}() })
} else { } else {
wg.Add(1) wg.Go(func() {
go func() {
defer wg.Done()
select { select {
case <-ctx.Done(): case <-ctx.Done():
return return
@@ -160,7 +155,7 @@ func Checkpointing(wg *sync.WaitGroup, ctx context.Context) {
GetAvroStore().ToCheckpoint(Keys.Checkpoints.RootDir, false) GetAvroStore().ToCheckpoint(Keys.Checkpoints.RootDir, false)
} }
} }
}() })
} }
} }