Class EnsembleTracker

java.lang.Object
org.apache.curator.framework.imps.EnsembleTracker
All Implemented Interfaces:
Closeable, AutoCloseable, CuratorWatcher

public class EnsembleTracker extends Object implements Closeable, CuratorWatcher
  • Method Details

    • start

      public void start() throws Exception
      Throws:
      Exception
    • close

      public void close()
      Specified by:
      close in interface AutoCloseable
      Specified by:
      close in interface Closeable
    • process

      public void process(org.apache.zookeeper.WatchedEvent event) throws Exception
      Description copied from interface: CuratorWatcher
      Same as Watcher.process(WatchedEvent). If an exception is thrown, Curator will log it
      Specified by:
      process in interface CuratorWatcher
      Parameters:
      event - the event
      Throws:
      Exception - any exceptions to log
    • getCurrentConfig

      public org.apache.zookeeper.server.quorum.flexible.QuorumVerifier getCurrentConfig()
      Return the current quorum config
      Returns:
      config
    • hasOutstanding

      public boolean hasOutstanding()
    • configToConnectionString

      public static String configToConnectionString(org.apache.zookeeper.server.quorum.flexible.QuorumVerifier data) throws Exception
      Throws:
      Exception