ClusterCockpit/cc-metric-collector
1
0
Fork 0
mirror of https://github.com/ClusterCockpit/cc-metric-collector.git synced 2025-04-05 21:25:55 +02:00
Code Issues Packages Projects Releases Wiki Activity

change to ccMessage

Browse Source
This commit is contained in:
exterr2f 2025-02-19 08:28:19 +01:00
parent a389a5476b
commit 6845098fec
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
collectors/numastatsMetric.go
View File

@ -11,7 +11,7 @@ import (
"time" "time"
cclog "github.com/ClusterCockpit/cc-metric-collector/pkg/ccLogger" cclog "github.com/ClusterCockpit/cc-metric-collector/pkg/ccLogger"
lp "github.com/ClusterCockpit/cc-energy-manager/pkg/cc-message" lp "github.com/ClusterCockpit/cc-lib/ccMessage"
) )
type NUMAStatsCollectorConfig struct { type NUMAStatsCollectorConfig struct {
@ -100,6 +100,7 @@ func (m *NUMAStatsCollector) Init(config json.RawMessage) error {
}) })
} }
// Initialized
cclog.ComponentDebug(m.name, "initialized", len(m.topology), "NUMA domains") cclog.ComponentDebug(m.name, "initialized", len(m.topology), "NUMA domains")
m.init = true m.init = true
return nil return nil
@ -114,7 +115,8 @@ func (m *NUMAStatsCollector) Read(interval time.Duration, output chan lp.CCMessa
timeDiff := now.Sub(m.lastTimestamp).Seconds() timeDiff := now.Sub(m.lastTimestamp).Seconds()
m.lastTimestamp = now m.lastTimestamp = now
for i := range m.topology { for i := range m.topology {i
// Loop for all NUMA domains
t := &m.topology[i] t := &m.topology[i]
file, err := os.Open(t.file) file, err := os.Open(t.file)