Package org.apache.storm.zookeeper
Class ClientZookeeper
java.lang.Object
org.apache.storm.zookeeper.ClientZookeeper
-
Constructor Summary
Constructors -
Method Summary
Modifier 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
-
ClientZookeeper
public ClientZookeeper()
-
-
Method Details
-
setInstance
Provide 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
-
resetInstance
public 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
-
existsNode
public static boolean existsNode(org.apache.storm.shade.org.apache.curator.framework.CuratorFramework zk, String path, boolean watch) -
deleteNode
public static void deleteNode(org.apache.storm.shade.org.apache.curator.framework.CuratorFramework zk, String path) -
parentPath
-
exists
public static boolean exists(org.apache.storm.shade.org.apache.curator.framework.CuratorFramework zk, String path, boolean watch) -
setData
public 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) -
getVersion
public static Integer getVersion(org.apache.storm.shade.org.apache.curator.framework.CuratorFramework zk, String path, boolean watch) throws Exception - Throws:
Exception
-
getChildren
-
getData
public static byte[] getData(org.apache.storm.shade.org.apache.curator.framework.CuratorFramework zk, String path, boolean watch) -
getDataWithVersion
public 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 usepath- the path to get it fromwatch- should a watch be enabled- Returns:
- null if no data is found, else the data with the version.
-
addListener
public static void addListener(org.apache.storm.shade.org.apache.curator.framework.CuratorFramework zk, org.apache.storm.shade.org.apache.curator.framework.state.ConnectionStateListener listener) -
syncPath
public static void syncPath(org.apache.storm.shade.org.apache.curator.framework.CuratorFramework zk, String path) -
mkdirsImpl
-
mkClientImpl
-