add snapshot metric

vesoft-inc · Feb 10, 2022 · 2c7ecfa · 2c7ecfa
1 parent c532203
commit 2c7ecfa
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 0 deletions.
diff --git a/src/kvstore/raftex/Host.cpp b/src/kvstore/raftex/Host.cpp
@@ -339,6 +339,7 @@ nebula::cpp2::ErrorCode Host::startSendSnapshot() {
             << ", firstLogId in wal = " << part_->wal()->firstLogId()
             << ", lastLogId in wal = " << part_->wal()->lastLogId();
     sendingSnapshot_ = true;
+    stats::StatsManager::addValue(kNumSendSnapshot);
     part_->snapshot_->sendSnapshot(part_, addr_)
         .thenValue([self = shared_from_this()](auto&& status) {
           std::lock_guard<std::mutex> g(self->lock_);

diff --git a/src/kvstore/stats/KVStats.cpp b/src/kvstore/stats/KVStats.cpp
@@ -18,6 +18,7 @@ stats::CounterId kAppendLogLatencyUs;
 stats::CounterId kTransferLeaderLatencyUs;
 stats::CounterId kNumStartElect;
 stats::CounterId kNumGrantVotes;
+stats::CounterId kNumSendSnapshot;
 
 void initKVStats() {
   kCommitLogLatencyUs = stats::StatsManager::registerHisto(
@@ -34,6 +35,7 @@ void initKVStats() {
       "transfer_leader_latency_us", 1000, 0, 2000, "avg, p75, p95, p99, p999");
   kNumStartElect = stats::StatsManager::registerStats("num_start_elect", "rate, sum");
   kNumGrantVotes = stats::StatsManager::registerStats("num_grant_votes", "rate, sum");
+  kNumSendSnapshot = stats::StatsManager::registerStats("num_send_snapshot", "rate, sum");
 }
 
 }  // namespace nebula
diff --git a/src/kvstore/stats/KVStats.h b/src/kvstore/stats/KVStats.h
@@ -19,6 +19,7 @@ extern stats::CounterId kAppendLogLatencyUs;
 extern stats::CounterId kTransferLeaderLatencyUs;
 extern stats::CounterId kNumStartElect;
 extern stats::CounterId kNumGrantVotes;
+extern stats::CounterId kNumSendSnapshot;
 
 void initKVStats();