Rename LeadershipManagerZkImpl to LeadershipManagerImpl (#694)

Netflix · Jul 19, 2024 · dd5a89e · dd5a89e
1 parent c0d0370
commit dd5a89e
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/...erver/master/LeadershipManagerZkImpl.java → .../server/master/LeadershipManagerImpl.java b/...erver/master/LeadershipManagerZkImpl.java → .../server/master/LeadershipManagerImpl.java
@@ -34,9 +34,9 @@
 import rx.functions.Func0;
 
 
-public class LeadershipManagerZkImpl implements ILeadershipManager {
+public class LeadershipManagerImpl implements ILeadershipManager {
 
-    private static final Logger logger = LoggerFactory.getLogger(LeadershipManagerZkImpl.class);
+    private static final Logger logger = LoggerFactory.getLogger(LeadershipManagerImpl.class);
     private final Gauge isLeaderGauge;
     private final Gauge isLeaderReadyGauge;
     private final AtomicBoolean firstTimeLeaderMode = new AtomicBoolean(false);
@@ -46,7 +46,7 @@ public class LeadershipManagerZkImpl implements ILeadershipManager {
     private volatile boolean isReady = false;
     private volatile Instant becameLeaderAt;
 
-    public LeadershipManagerZkImpl(final MasterConfiguration config,
+    public LeadershipManagerImpl(final MasterConfiguration config,
                                    final ServiceLifecycle serviceLifecycle) {
         this.config = config;
         this.serviceLifecycle = serviceLifecycle;

diff --git a/...plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/MasterMain.java b/...plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/MasterMain.java
@@ -119,7 +119,7 @@ public MasterMain(
         try {
             ConfigurationProvider.initialize(configFactory);
             this.config = ConfigurationProvider.getConfig();
-            leadershipManager = new LeadershipManagerZkImpl(config, mantisServices);
+            leadershipManager = new LeadershipManagerImpl(config, mantisServices);
 
             Thread t = new Thread(this::shutdown);
             t.setDaemon(true);