Adding method to expose current leader uuid in RaftConsensus

iRitwik · Sep 17, 2019 · ae8899b · ae8899b
1 parent 332a5d2
commit ae8899b
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 0 deletions.
diff --git a/src/kudu/consensus/raft_consensus.cc b/src/kudu/consensus/raft_consensus.cc
@@ -2388,6 +2388,11 @@ int64_t RaftConsensus::CurrentTerm() const {
   return CurrentTermUnlocked();
 }
 
+string RaftConsensus::GetLeaderUuid() const {
+  LockGuard l(lock_);
+  return GetLeaderUuidUnlocked();
+}
+
 void RaftConsensus::SetStateUnlocked(State new_state) {
   switch (new_state) {
     case kInitialized:

diff --git a/src/kudu/consensus/raft_consensus.h b/src/kudu/consensus/raft_consensus.h
@@ -333,6 +333,9 @@ class RaftConsensus : public std::enable_shared_from_this<RaftConsensus>,
   // Returns the current term.
   int64_t CurrentTerm() const;
 
+  // Returns uuid of the current leader
+  std::string GetLeaderUuid() const;
+
   // Returns the uuid of this peer.
   // Thread-safe.
   const std::string& peer_uuid() const;