ClusterCockpit/cc-metric-collector
1
0
Fork 0
mirror of https://github.com/ClusterCockpit/cc-metric-collector.git synced 2025-09-23 08:44:31 +02:00
Code Issues Packages Projects Releases Wiki Activity

Merge 1fcb302620 into 8837ff4474

Browse Source
This commit is contained in:
Thomas Gruber
2024-12-02 02:00:31 +00:00
committed by GitHub
parent 8837ff4474 1fcb302620
commit 7e75dbf2ff
6 changed files with 706 additions and 203 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
internal/metricRouter/metricRouter.go
View File

@@ -9,8 +9,8 @@ import (
cclog "github.com/ClusterCockpit/cc-metric-collector/pkg/ccLogger"
agg "github.com/ClusterCockpit/cc-metric-collector/internal/metricAggregator"
lp "github.com/ClusterCockpit/cc-metric-collector/pkg/ccMetric"
agg "github.com/ClusterCockpit/cc-metric-collector/internal/metricAggregator"
mct "github.com/ClusterCockpit/cc-metric-collector/pkg/multiChanTicker"
units "github.com/ClusterCockpit/cc-units"
)
@@ -281,7 +281,9 @@ func (r *metricRouter) Start() {
// Foward message received from collector channel
coll_forward := func(p lp.CCMetric) {
// receive from metric collector
p.AddTag(r.config.HostnameTagName, r.hostname)
if !p.HasTag(r.config.HostnameTagName) {
p.AddTag(r.config.HostnameTagName, r.hostname)
}
if r.config.IntervalStamp {
p.SetTime(r.timestamp)
}
@@ -310,7 +312,9 @@ func (r *metricRouter) Start() {
cache_forward := func(p lp.CCMetric) {
// receive from metric collector
if !r.dropMetric(p) {
p.AddTag(r.config.HostnameTagName, r.hostname)
if !p.HasTag(r.config.HostnameTagName) {
p.AddTag(r.config.HostnameTagName, r.hostname)
}
forward(p)
}
}