merge: #15416

15416: [Backport stable/8.3] fix(raft): update role metrics when closing or transitioning to inactive r=github-actions[bot] a=backport-action # Description Backport of #15413 to `stable/8.3`. relates to original author: `@deepthidevaki` Co-authored-by: Deepthi Devaki Akkoorath <[email protected]>
camunda · Nov 29, 2023 · e7bbcf2 · e7bbcf2
2 parents d25c1ae + b6c6c11
commit e7bbcf2
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 0 deletions.
diff --git a/atomix/cluster/src/main/java/io/atomix/raft/impl/RaftContext.java b/atomix/cluster/src/main/java/io/atomix/raft/impl/RaftContext.java
@@ -853,6 +853,7 @@ public void checkThread() {
   private RaftRole createRole(final Role role) {
     switch (role) {
       case INACTIVE:
+        raftRoleMetrics.becomingInactive();
         return new InactiveRole(this);
       case PASSIVE:
         return new PassiveRole(this);
@@ -915,6 +916,7 @@ public void transition(final Type type) {
 
   @Override
   public void close() {
+    raftRoleMetrics.becomingInactive();
     started = false;
     // Unregister protocol listeners.
     unregisterHandlers(protocol);

diff --git a/atomix/cluster/src/main/java/io/atomix/raft/metrics/RaftRoleMetrics.java b/atomix/cluster/src/main/java/io/atomix/raft/metrics/RaftRoleMetrics.java
@@ -67,6 +67,10 @@ public RaftRoleMetrics(final String partitionName) {
     electionLatency = ELECTION_LATENCY.labels(partitionGroupName, partition);
   }
 
+  public void becomingInactive() {
+    role.set(0);
+  }
+
   public void becomingFollower() {
     role.set(1);
   }