update

alibaba · Jan 15, 2025 · 0a6d8c8 · 0a6d8c8
1 parent 4db3f54
commit 0a6d8c8
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/core/prometheus/schedulers/ScrapeScheduler.cpp b/core/prometheus/schedulers/ScrapeScheduler.cpp
@@ -50,7 +50,7 @@ ScrapeScheduler::ScrapeScheduler(std::shared_ptr<ScrapeConfig> scrapeConfigPtr,
       mTargetInfo(targetInfo),
       mQueueKey(queueKey),
       mInputIndex(inputIndex),
-      mScrapeResponseSizeBytes(0) {
+      mScrapeResponseSizeBytes(-1) {
     mInterval = mScrapeConfigPtr->mScrapeIntervalSeconds;
 }
 

diff --git a/core/prometheus/schedulers/ScrapeScheduler.h b/core/prometheus/schedulers/ScrapeScheduler.h
@@ -56,7 +56,7 @@ class ScrapeScheduler : public BaseScheduler {
     std::string GetId() const;
 
     void SetComponent(std::shared_ptr<Timer> timer, EventPool* eventPool);
-    uint64_t GetLastScrapeSize() const { return mScrapeResponseSizeBytes; }
+    int64_t GetLastScrapeSize() const { return mScrapeResponseSizeBytes; }
 
     uint64_t GetReBalanceMs() const { return mTargetInfo.mRebalanceMs; }
     void ScheduleNext() override;
@@ -78,7 +78,7 @@ class ScrapeScheduler : public BaseScheduler {
     size_t mInputIndex;
 
     // auto metrics
-    std::atomic_uint64_t mScrapeResponseSizeBytes;
+    std::atomic_int mScrapeResponseSizeBytes;
 
     // self monitor
     std::shared_ptr<PromSelfMonitorUnsafe> mSelfMonitor;