Package org.apache.storm.zookeeper
Class ClientZookeeper
java.lang.Object
org.apache.storm.zookeeper.ClientZookeeper
- 
Constructor SummaryConstructors
- 
Method SummaryModifier and TypeMethodDescriptionstatic voidaddListener(org.apache.storm.shade.org.apache.curator.framework.CuratorFramework zk, org.apache.storm.shade.org.apache.curator.framework.state.ConnectionStateListener listener) static StringcreateNode(org.apache.storm.shade.org.apache.curator.framework.CuratorFramework zk, String path, byte[] data, List<org.apache.storm.shade.org.apache.zookeeper.data.ACL> acls) static StringcreateNode(org.apache.storm.shade.org.apache.curator.framework.CuratorFramework zk, String path, byte[] data, org.apache.storm.shade.org.apache.zookeeper.CreateMode mode, List<org.apache.storm.shade.org.apache.zookeeper.data.ACL> acls) static voiddeleteNode(org.apache.storm.shade.org.apache.curator.framework.CuratorFramework zk, String path) static voiddeleteNodeBlobstore(org.apache.storm.shade.org.apache.curator.framework.CuratorFramework zk, String parentPath, String hostPortInfo) static booleanexists(org.apache.storm.shade.org.apache.curator.framework.CuratorFramework zk, String path, boolean watch) static booleanexistsNode(org.apache.storm.shade.org.apache.curator.framework.CuratorFramework zk, String path, boolean watch) getChildren(org.apache.storm.shade.org.apache.curator.framework.CuratorFramework zk, String path, boolean watch) static byte[]getData(org.apache.storm.shade.org.apache.curator.framework.CuratorFramework zk, String path, boolean watch) static VersionedData<byte[]>getDataWithVersion(org.apache.storm.shade.org.apache.curator.framework.CuratorFramework zk, String path, boolean watch) Get the data along with a version.static IntegergetVersion(org.apache.storm.shade.org.apache.curator.framework.CuratorFramework zk, String path, boolean watch) static org.apache.storm.shade.org.apache.curator.framework.CuratorFrameworkmkClient(Map<String, Object> conf, List<String> servers, Object port, String root, WatcherCallBack watcher, Map<String, Object> authConf, DaemonType type) org.apache.storm.shade.org.apache.curator.framework.CuratorFrameworkmkClientImpl(Map<String, Object> conf, List<String> servers, Object port, String root, WatcherCallBack watcher, Map<String, Object> authConf, DaemonType type) static voidmkdirs(org.apache.storm.shade.org.apache.curator.framework.CuratorFramework zk, String path, List<org.apache.storm.shade.org.apache.zookeeper.data.ACL> acls) voidmkdirsImpl(org.apache.storm.shade.org.apache.curator.framework.CuratorFramework zk, String path, List<org.apache.storm.shade.org.apache.zookeeper.data.ACL> acls) static StringnormalizePath(String path) static StringparentPath(String path) static voidResets the singleton instance to the default.static org.apache.storm.shade.org.apache.zookeeper.data.StatsetData(org.apache.storm.shade.org.apache.curator.framework.CuratorFramework zk, String path, byte[] data) static voidProvide an instance of this class for delegates to use.static voidtokenizePath(String path) static StringtoksToPath(List<String> toks) 
- 
Constructor Details- 
ClientZookeeperpublic ClientZookeeper()
 
- 
- 
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 ClientZookeeper 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.
- 
mkdirs
- 
mkClient
- 
deleteNodeBlobstore
- 
createNode
- 
createNode
- 
tokenizePath
- 
toksToPath
- 
normalizePath
- 
existsNodepublic static boolean existsNode(org.apache.storm.shade.org.apache.curator.framework.CuratorFramework zk, String path, boolean watch) 
- 
deleteNodepublic static void deleteNode(org.apache.storm.shade.org.apache.curator.framework.CuratorFramework zk, String path) 
- 
parentPath
- 
existspublic static boolean exists(org.apache.storm.shade.org.apache.curator.framework.CuratorFramework zk, String path, boolean watch) 
- 
setDatapublic static org.apache.storm.shade.org.apache.zookeeper.data.Stat setData(org.apache.storm.shade.org.apache.curator.framework.CuratorFramework zk, String path, byte[] data) 
- 
getVersionpublic static Integer getVersion(org.apache.storm.shade.org.apache.curator.framework.CuratorFramework zk, String path, boolean watch) throws Exception - Throws:
- Exception
 
- 
getChildren
- 
getDatapublic static byte[] getData(org.apache.storm.shade.org.apache.curator.framework.CuratorFramework zk, String path, boolean watch) 
- 
getDataWithVersionpublic static VersionedData<byte[]> getDataWithVersion(org.apache.storm.shade.org.apache.curator.framework.CuratorFramework zk, String path, boolean watch) Get the data along with a version.- Parameters:
- zk- the zk instance to use
- path- the path to get it from
- watch- should a watch be enabled
- Returns:
- null if no data is found, else the data with the version.
 
- 
addListenerpublic static void addListener(org.apache.storm.shade.org.apache.curator.framework.CuratorFramework zk, org.apache.storm.shade.org.apache.curator.framework.state.ConnectionStateListener listener) 
- 
syncPathpublic static void syncPath(org.apache.storm.shade.org.apache.curator.framework.CuratorFramework zk, String path) 
- 
mkdirsImpl
- 
mkClientImpl
 
-