show peers in raft state (#4014)

Co-authored-by: Doodle <[email protected]>
vesoft-inc · Mar 16, 2022 · 37cc70b · 37cc70b
1 parent 3161f01
commit 37cc70b
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 0 deletions.
diff --git a/src/interface/raftex.thrift b/src/interface/raftex.thrift
@@ -133,6 +133,7 @@ struct GetStateResponse {
     6: LogID            last_log_id;
     7: TermID           last_log_term;
     8: Status           status;
+    9: list<binary>     peers;
 }
 
 service RaftexService {

diff --git a/src/kvstore/raftex/RaftPart.cpp b/src/kvstore/raftex/RaftPart.cpp
@@ -1067,6 +1067,15 @@ void RaftPart::getState(cpp2::GetStateResponse& resp) {
   resp.last_log_id_ref() = lastLogId_;
   resp.last_log_term_ref() = lastLogTerm_;
   resp.status_ref() = status_;
+  std::vector<std::string> peers;
+  for (auto& h : hosts_) {
+    std::string str = h->address().toString();
+    if (h->isLearner()) {
+      str += "_learner";
+    }
+    peers.emplace_back(str);
+  }
+  resp.peers_ref() = peers;
 }
 
 bool RaftPart::processElectionResponses(const RaftPart::ElectionResponses& results,