From e0ab399a9cf22be63e61b8df14eb058379ad10e8 Mon Sep 17 00:00:00 2001
From: mountain <mountain@action2quare.com>
Date: Tue, 13 Feb 2024 15:05:59 +0900
Subject: [PATCH] =?UTF-8?q?metric=20=EB=93=B1=EB=A1=9D=20=EB=A1=9C?=
 =?UTF-8?q?=EC=A7=81=20=EC=88=98=EC=A0=95?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 metric/prometheus.go | 10 ++++------
 1 file changed, 4 insertions(+), 6 deletions(-)

diff --git a/metric/prometheus.go b/metric/prometheus.go
index 1be333e..9663db3 100644
--- a/metric/prometheus.go
+++ b/metric/prometheus.go
@@ -119,10 +119,6 @@ func (pe *prometheusExporter) loop(ctx context.Context) {
 		case nm := <-pe.registerChan:
 			var nextmetrics map[string]*prometheusMetricDesc
 			if collector != nil {
-				if collector.metrics[nm.key] != nil {
-					break
-				}
-
 				nextmetrics = collector.metrics
 				prometheus.Unregister(collector)
 				nextmetrics[nm.key] = nm
@@ -132,12 +128,14 @@ func (pe *prometheusExporter) loop(ctx context.Context) {
 				}
 			}
 
-			collector = &prometheusCollector{
+			nextcollector := &prometheusCollector{
 				metrics: nextmetrics,
 			}
 
-			if err := prometheus.Register(collector); err != nil {
+			if err := prometheus.Register(nextcollector); err != nil {
 				logger.Error("prometheus register err :", *nm, err)
+			} else {
+				collector = nextcollector
 			}
 		}
 	}