Package org.apache.storm.zookeeper
Class Zookeeper
java.lang.Object
org.apache.storm.zookeeper.Zookeeper
- 
Constructor SummaryConstructors
- 
Method SummaryModifier and TypeMethodDescriptionstatic org.apache.storm.shade.org.apache.zookeeper.server.NIOServerCnxnFactorymkInprocessZookeeper(String localdir, Integer port) static voidResets the singleton instance to the default.static voidProvide an instance of this class for delegates to use.static voidshutdownInprocessZookeeper(org.apache.storm.shade.org.apache.zookeeper.server.NIOServerCnxnFactory handle) static NimbusInfotoNimbusInfo(org.apache.storm.shade.org.apache.curator.framework.recipes.leader.Participant participant) static ILeaderElectorzkLeaderElector(Map<String, Object> conf, org.apache.storm.shade.org.apache.curator.framework.CuratorFramework zkClient, BlobStore blobStore, TopoCache tc, IStormClusterState clusterState, List<org.apache.storm.shade.org.apache.zookeeper.data.ACL> acls, StormMetricsRegistry metricsRegistry, Object submitLock) Get master leader elector.protected ILeaderElectorzkLeaderElectorImpl(Map<String, Object> conf, org.apache.storm.shade.org.apache.curator.framework.CuratorFramework zk, BlobStore blobStore, TopoCache tc, IStormClusterState clusterState, List<org.apache.storm.shade.org.apache.zookeeper.data.ACL> acls, StormMetricsRegistry metricsRegistry, Object submitLock) 
- 
Constructor Details- 
Zookeeperpublic Zookeeper()
 
- 
- 
Method Details- 
setInstanceProvide an instance of this class for delegates to use. To mock out delegated methods, provide an instance of a subclass that overrides the implementation of the delegated method.- Parameters:
- u- a Zookeeper instance
 
- 
resetInstancepublic static void resetInstance()Resets the singleton instance to the default. This is helpful to reset the class to its original functionality when mocking is no longer desired.
- 
mkInprocessZookeeperpublic static org.apache.storm.shade.org.apache.zookeeper.server.NIOServerCnxnFactory mkInprocessZookeeper(String localdir, Integer port) throws Exception - Throws:
- Exception
 
- 
shutdownInprocessZookeeperpublic static void shutdownInprocessZookeeper(org.apache.storm.shade.org.apache.zookeeper.server.NIOServerCnxnFactory handle) 
- 
toNimbusInfopublic static NimbusInfo toNimbusInfo(org.apache.storm.shade.org.apache.curator.framework.recipes.leader.Participant participant) 
- 
zkLeaderElectorpublic static ILeaderElector zkLeaderElector(Map<String, Object> conf, org.apache.storm.shade.org.apache.curator.framework.CuratorFramework zkClient, BlobStore blobStore, TopoCache tc, IStormClusterState clusterState, List<org.apache.storm.shade.org.apache.zookeeper.data.ACL> acls, StormMetricsRegistry metricsRegistry, Object submitLock) Get master leader elector.- Parameters:
- conf- Config.
- zkClient- ZkClient, the client must have a default Config.STORM_ZOOKEEPER_ROOT as root path.
- blobStore-- BlobStore
- tc-- TopoCache
- clusterState-- IStormClusterState
- acls- ACLs
- Returns:
- Instance of ILeaderElector
 
- 
zkLeaderElectorImplprotected ILeaderElector zkLeaderElectorImpl(Map<String, Object> conf, org.apache.storm.shade.org.apache.curator.framework.CuratorFramework zk, BlobStore blobStore, TopoCache tc, IStormClusterState clusterState, List<org.apache.storm.shade.org.apache.zookeeper.data.ACL> acls, StormMetricsRegistry metricsRegistry, Object submitLock) 
 
-