Package | Description |
---|---|
org.I0Itec.zkclient |
Modifier and Type | Method and Description |
---|---|
void |
ZkClient.close()
Close the client.
|
void |
ZkClient.connect(long maxMsToWaitUntilConnected,
org.apache.zookeeper.Watcher watcher)
Connect to ZooKeeper.
|
String |
ZkClient.create(String path,
Object data,
org.apache.zookeeper.CreateMode mode)
Create a node.
|
void |
ZkClient.createEphemeral(String path)
Create an ephemeral node.
|
void |
ZkClient.createEphemeral(String path,
List<org.apache.zookeeper.data.ACL> acl)
Create an ephemeral node and set its ACL.
|
void |
ZkClient.createEphemeral(String path,
Object data)
Create an ephemeral node.
|
void |
ZkClient.createEphemeral(String path,
Object data,
List<org.apache.zookeeper.data.ACL> acl)
Create an ephemeral node.
|
String |
ZkClient.createEphemeralSequential(String path,
Object data)
Create an ephemeral, sequential node.
|
String |
ZkClient.createEphemeralSequential(String path,
Object data,
List<org.apache.zookeeper.data.ACL> acl)
Create an ephemeral, sequential node with ACL.
|
void |
ZkClient.createPersistent(String path)
Create a persistent node.
|
void |
ZkClient.createPersistent(String path,
boolean createParents)
Create a persistent node and set its ACLs.
|
void |
ZkClient.createPersistent(String path,
boolean createParents,
List<org.apache.zookeeper.data.ACL> acl)
Create a persistent node and set its ACLs.
|
void |
ZkClient.createPersistent(String path,
Object data)
Create a persistent node.
|
String |
ZkClient.createPersistentSequential(String path,
Object data)
Create a persistent, sequental node.
|
String |
ZkClient.createPersistentSequential(String path,
Object data,
List<org.apache.zookeeper.data.ACL> acl)
Create a persistent, sequential node and set its ACL.
|
<T> T |
ZkClient.retryUntilConnected(Callable<T> callable) |
boolean |
ZkClient.waitForKeeperState(org.apache.zookeeper.Watcher.Event.KeeperState keeperState,
long time,
TimeUnit timeUnit) |
void |
ZkClient.waitUntilConnected() |
boolean |
ZkClient.waitUntilConnected(long time,
TimeUnit timeUnit) |
boolean |
ZkClient.waitUntilExists(String path,
TimeUnit timeUnit,
long time) |
Copyright © 2019. All rights reserved.