From 59b0a975f7c28ea6e022e73d08e7a897af3322db Mon Sep 17 00:00:00 2001 From: mountain Date: Fri, 24 Nov 2023 16:28:25 +0900 Subject: [PATCH] =?UTF-8?q?=EA=B3=B5=ED=86=B5=20=EB=A9=94=ED=8A=B8?= =?UTF-8?q?=EB=A6=AD=20=EC=B6=94=EA=B0=80?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- metric/metric.go | 11 +++++++++++ 1 file changed, 11 insertions(+) diff --git a/metric/metric.go b/metric/metric.go index 29ed231..8f70b15 100644 --- a/metric/metric.go +++ b/metric/metric.go @@ -106,6 +106,7 @@ func (mc *metricCollection) metricWriter() { } var NewMetric func(MetricType, string, string, map[string]string) MetricWriter +var ConcurrentUser = MetricWriterNil func init() { NewMetric = func(MetricType, string, string, map[string]string) MetricWriter { @@ -130,6 +131,7 @@ func init() { logger.Println("metrics are going to be generated for houston") go mc.metricWriter() NewMetric = newMetricImpl + ConcurrentUser = NewMetric(MetricGuage, "concurrent_user", "concurrent user count", nil) } else { logger.Println("metrics are NOT going to be generated. parent is not houston :", filename, string(fn)) } @@ -145,6 +147,15 @@ func newMetricImpl(mt MetricType, name string, help string, constLabels map[stri hash := md5.New() hash.Write([]byte(name)) + if constLabels == nil { + constLabels = make(map[string]string) + } + + hn, _ := os.Hostname() + sn := path.Base(os.Args[0]) + constLabels["hostname"] = hn + constLabels["service"] = sn + key := hex.EncodeToString(hash.Sum(nil))[:metric_key_size] temp, _ := json.Marshal(MetricDescription{ Key: key,