public interface IZkConnection
Modifier and Type | Method and Description |
---|---|
void |
addAuthInfo(java.lang.String scheme,
byte[] auth) |
void |
close() |
void |
connect(org.apache.zookeeper.Watcher watcher) |
java.lang.String |
create(java.lang.String path,
byte[] data,
org.apache.zookeeper.CreateMode mode) |
java.lang.String |
create(java.lang.String path,
byte[] data,
java.util.List<org.apache.zookeeper.data.ACL> acl,
org.apache.zookeeper.CreateMode mode) |
void |
delete(java.lang.String path) |
void |
delete(java.lang.String path,
int version) |
boolean |
exists(java.lang.String path,
boolean watch) |
java.util.Map.Entry<java.util.List<org.apache.zookeeper.data.ACL>,org.apache.zookeeper.data.Stat> |
getAcl(java.lang.String path) |
java.util.List<java.lang.String> |
getChildren(java.lang.String path,
boolean watch) |
long |
getCreateTime(java.lang.String path) |
java.lang.String |
getServers() |
org.apache.zookeeper.ZooKeeper.States |
getZookeeperState() |
java.util.List<org.apache.zookeeper.OpResult> |
multi(java.lang.Iterable<org.apache.zookeeper.Op> ops) |
byte[] |
readData(java.lang.String path,
org.apache.zookeeper.data.Stat stat,
boolean watch) |
void |
setAcl(java.lang.String path,
java.util.List<org.apache.zookeeper.data.ACL> acl,
int version) |
void |
writeData(java.lang.String path,
byte[] data,
int expectedVersion) |
org.apache.zookeeper.data.Stat |
writeDataReturnStat(java.lang.String path,
byte[] data,
int expectedVersion) |
void connect(org.apache.zookeeper.Watcher watcher)
void close() throws java.lang.InterruptedException
java.lang.InterruptedException
java.lang.String create(java.lang.String path, byte[] data, org.apache.zookeeper.CreateMode mode) throws org.apache.zookeeper.KeeperException, java.lang.InterruptedException
org.apache.zookeeper.KeeperException
java.lang.InterruptedException
java.lang.String create(java.lang.String path, byte[] data, java.util.List<org.apache.zookeeper.data.ACL> acl, org.apache.zookeeper.CreateMode mode) throws org.apache.zookeeper.KeeperException, java.lang.InterruptedException
org.apache.zookeeper.KeeperException
java.lang.InterruptedException
void delete(java.lang.String path) throws java.lang.InterruptedException, org.apache.zookeeper.KeeperException
java.lang.InterruptedException
org.apache.zookeeper.KeeperException
void delete(java.lang.String path, int version) throws java.lang.InterruptedException, org.apache.zookeeper.KeeperException
java.lang.InterruptedException
org.apache.zookeeper.KeeperException
boolean exists(java.lang.String path, boolean watch) throws org.apache.zookeeper.KeeperException, java.lang.InterruptedException
org.apache.zookeeper.KeeperException
java.lang.InterruptedException
java.util.List<java.lang.String> getChildren(java.lang.String path, boolean watch) throws org.apache.zookeeper.KeeperException, java.lang.InterruptedException
org.apache.zookeeper.KeeperException
java.lang.InterruptedException
byte[] readData(java.lang.String path, org.apache.zookeeper.data.Stat stat, boolean watch) throws org.apache.zookeeper.KeeperException, java.lang.InterruptedException
org.apache.zookeeper.KeeperException
java.lang.InterruptedException
void writeData(java.lang.String path, byte[] data, int expectedVersion) throws org.apache.zookeeper.KeeperException, java.lang.InterruptedException
org.apache.zookeeper.KeeperException
java.lang.InterruptedException
org.apache.zookeeper.data.Stat writeDataReturnStat(java.lang.String path, byte[] data, int expectedVersion) throws org.apache.zookeeper.KeeperException, java.lang.InterruptedException
org.apache.zookeeper.KeeperException
java.lang.InterruptedException
org.apache.zookeeper.ZooKeeper.States getZookeeperState()
long getCreateTime(java.lang.String path) throws org.apache.zookeeper.KeeperException, java.lang.InterruptedException
org.apache.zookeeper.KeeperException
java.lang.InterruptedException
java.lang.String getServers()
java.util.List<org.apache.zookeeper.OpResult> multi(java.lang.Iterable<org.apache.zookeeper.Op> ops) throws org.apache.zookeeper.KeeperException, java.lang.InterruptedException
org.apache.zookeeper.KeeperException
java.lang.InterruptedException
void addAuthInfo(java.lang.String scheme, byte[] auth)
void setAcl(java.lang.String path, java.util.List<org.apache.zookeeper.data.ACL> acl, int version) throws org.apache.zookeeper.KeeperException, java.lang.InterruptedException
org.apache.zookeeper.KeeperException
java.lang.InterruptedException
java.util.Map.Entry<java.util.List<org.apache.zookeeper.data.ACL>,org.apache.zookeeper.data.Stat> getAcl(java.lang.String path) throws org.apache.zookeeper.KeeperException, java.lang.InterruptedException
org.apache.zookeeper.KeeperException
java.lang.InterruptedException