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