metric 등록 로직 수정
This commit is contained in:
@ -119,10 +119,6 @@ func (pe *prometheusExporter) loop(ctx context.Context) {
|
|||||||
case nm := <-pe.registerChan:
|
case nm := <-pe.registerChan:
|
||||||
var nextmetrics map[string]*prometheusMetricDesc
|
var nextmetrics map[string]*prometheusMetricDesc
|
||||||
if collector != nil {
|
if collector != nil {
|
||||||
if collector.metrics[nm.key] != nil {
|
|
||||||
break
|
|
||||||
}
|
|
||||||
|
|
||||||
nextmetrics = collector.metrics
|
nextmetrics = collector.metrics
|
||||||
prometheus.Unregister(collector)
|
prometheus.Unregister(collector)
|
||||||
nextmetrics[nm.key] = nm
|
nextmetrics[nm.key] = nm
|
||||||
@ -132,12 +128,14 @@ func (pe *prometheusExporter) loop(ctx context.Context) {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
collector = &prometheusCollector{
|
nextcollector := &prometheusCollector{
|
||||||
metrics: nextmetrics,
|
metrics: nextmetrics,
|
||||||
}
|
}
|
||||||
|
|
||||||
if err := prometheus.Register(collector); err != nil {
|
if err := prometheus.Register(nextcollector); err != nil {
|
||||||
logger.Error("prometheus register err :", *nm, err)
|
logger.Error("prometheus register err :", *nm, err)
|
||||||
|
} else {
|
||||||
|
collector = nextcollector
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user