ClusterCockpit/cc-backend
1
0
Fork 0
mirror of https://github.com/ClusterCockpit/cc-backend synced 2026-03-20 23:07:29 +01:00
Code Issues Packages Releases Activity

fix: Blocking ReceiveNats call

Browse Source 
Entire-Checkpoint: 38a235c86ceb
This commit is contained in:
Jan Eitzinger
2026-03-18 06:47:45 +01:00
parent bf1a8a174e
commit 8b132ed7f8
1 changed files with 5 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
pkg/metricstore/metricstore.go
View File

@@ -184,10 +184,11 @@ func Init(rawConfig json.RawMessage, metrics map[string]MetricConfig, wg *sync.W
shutdownFuncMu.Unlock()
if Keys.Subscriptions != nil {
err = ReceiveNats(ms, Keys.NumWorkers, ctx)
if err != nil {
cclog.Fatal(err)
}
wg.Go(func() {
if err := ReceiveNats(ms, Keys.NumWorkers, ctx); err != nil {
cclog.Fatal(err)
}
})
}
}