mirror of
https://github.com/ClusterCockpit/cc-metric-collector.git
synced 2025-04-08 22:45:55 +02:00
Compare commits
2 Commits
Author | SHA1 | Date | |
---|---|---|---|
|
c1395ec2ed | ||
|
16faa70867 |
@ -33,8 +33,10 @@ In contrast to the configuration files for sinks and receivers, the collectors c
|
|||||||
* [`topprocs`](./topprocsMetric.md)
|
* [`topprocs`](./topprocsMetric.md)
|
||||||
* [`nfs3stat`](./nfs3Metric.md)
|
* [`nfs3stat`](./nfs3Metric.md)
|
||||||
* [`nfs4stat`](./nfs4Metric.md)
|
* [`nfs4stat`](./nfs4Metric.md)
|
||||||
|
* [`nfsiostat`](./nfsiostatMetric.md)
|
||||||
* [`cpufreq`](./cpufreqMetric.md)
|
* [`cpufreq`](./cpufreqMetric.md)
|
||||||
* [`cpufreq_cpuinfo`](./cpufreqCpuinfoMetric.md)
|
* [`cpufreq_cpuinfo`](./cpufreqCpuinfoMetric.md)
|
||||||
|
* [`schedstat`](./schedstatMetric.md)
|
||||||
* [`numastats`](./numastatsMetric.md)
|
* [`numastats`](./numastatsMetric.md)
|
||||||
* [`gpfs`](./gpfsMetric.md)
|
* [`gpfs`](./gpfsMetric.md)
|
||||||
* [`beegfs_meta`](./beegfsmetaMetric.md)
|
* [`beegfs_meta`](./beegfsmetaMetric.md)
|
||||||
|
@ -91,17 +91,18 @@ func (r *NatsReceiver) _NatsReceive(m *nats.Msg) {
|
|||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
y, _ := lp.NewMessage(
|
y, err := lp.NewMessage(
|
||||||
string(measurement),
|
string(measurement),
|
||||||
tags,
|
tags,
|
||||||
nil,
|
nil,
|
||||||
fields,
|
fields,
|
||||||
t,
|
t,
|
||||||
)
|
)
|
||||||
|
if err == nil {
|
||||||
m, err := r.mp.ProcessMessage(y)
|
m, err := r.mp.ProcessMessage(y)
|
||||||
if err == nil && m != nil {
|
if err == nil && m != nil && r.sink != nil {
|
||||||
r.sink <- m
|
r.sink <- m
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
Loading…
x
Reference in New Issue
Block a user