From 0eff5b36d7e668610372da1404e35bb120cc05ad Mon Sep 17 00:00:00 2001 From: liqiang Date: Thu, 28 Nov 2024 08:13:45 +0000 Subject: [PATCH] update --- core/prometheus/schedulers/TargetSubscriberScheduler.cpp | 8 +++----- 1 file changed, 3 insertions(+), 5 deletions(-) diff --git a/core/prometheus/schedulers/TargetSubscriberScheduler.cpp b/core/prometheus/schedulers/TargetSubscriberScheduler.cpp index 90802ff9c8..178c952dba 100644 --- a/core/prometheus/schedulers/TargetSubscriberScheduler.cpp +++ b/core/prometheus/schedulers/TargetSubscriberScheduler.cpp @@ -58,10 +58,9 @@ bool TargetSubscriberScheduler::operator<(const TargetSubscriberScheduler& other } void TargetSubscriberScheduler::OnSubscription(HttpResponse& response, uint64_t timestampMilliSec) { - mSelfMonitor->AddCounter(METRIC_PLUGIN_PROM_SUBSCRIBE_TOTAL, - PromSelfMonitorUnsafe::StatusToString(response.GetStatusCode())); + mSelfMonitor->AddCounter(METRIC_PLUGIN_PROM_SUBSCRIBE_TOTAL, response.GetStatusCode()); mSelfMonitor->AddCounter(METRIC_PLUGIN_PROM_SUBSCRIBE_TIME_MS, - PromSelfMonitorUnsafe::StatusToString(response.GetStatusCode()), + response.GetStatusCode(), GetCurrentTimeInMilliSeconds() - timestampMilliSec); if (response.GetStatusCode() == 304) { // not modified @@ -337,8 +336,7 @@ void TargetSubscriberScheduler::InitSelfMonitor(const MetricLabels& defaultLabel mSelfMonitor = std::make_shared(); mSelfMonitor->InitMetricManager(sSubscriberMetricKeys, mDefaultLabels); - WriteMetrics::GetInstance()->PrepareMetricsRecordRef( - mMetricsRecordRef, MetricCategory::METRIC_CATEGORY_PLUGIN_SOURCE, std::move(mDefaultLabels)); + WriteMetrics::GetInstance()->PrepareMetricsRecordRef(mMetricsRecordRef, MetricCategory::METRIC_CATEGORY_PLUGIN_SOURCE, std::move(mDefaultLabels)); mPromSubscriberTargets = mMetricsRecordRef.CreateIntGauge(METRIC_PLUGIN_PROM_SUBSCRIBE_TARGETS); mTotalDelayMs = mMetricsRecordRef.CreateCounter(METRIC_PLUGIN_TOTAL_DELAY_MS); }