public class ZkConnection extends java.lang.Object implements IZkConnection
Constructor and Description |
---|
ZkConnection(java.lang.String zkServers) |
ZkConnection(java.lang.String zkServers,
int sessionTimeOut) |
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 |
getZookeeper() |
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) |
void |
writeData(java.lang.String path,
byte[] data,
int version) |
org.apache.zookeeper.data.Stat |
writeDataReturnStat(java.lang.String path,
byte[] data,
int version) |
public ZkConnection(java.lang.String zkServers)
public ZkConnection(java.lang.String zkServers, int sessionTimeOut)
public void connect(org.apache.zookeeper.Watcher watcher)
connect
in interface IZkConnection
public void close() throws java.lang.InterruptedException
close
in interface IZkConnection
java.lang.InterruptedException
public java.lang.String create(java.lang.String path, byte[] data, org.apache.zookeeper.CreateMode mode) throws org.apache.zookeeper.KeeperException, java.lang.InterruptedException
create
in interface IZkConnection
org.apache.zookeeper.KeeperException
java.lang.InterruptedException
public 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
create
in interface IZkConnection
org.apache.zookeeper.KeeperException
java.lang.InterruptedException
public void delete(java.lang.String path) throws java.lang.InterruptedException, org.apache.zookeeper.KeeperException
delete
in interface IZkConnection
java.lang.InterruptedException
org.apache.zookeeper.KeeperException
public void delete(java.lang.String path, int version) throws java.lang.InterruptedException, org.apache.zookeeper.KeeperException
delete
in interface IZkConnection
java.lang.InterruptedException
org.apache.zookeeper.KeeperException
public boolean exists(java.lang.String path, boolean watch) throws org.apache.zookeeper.KeeperException, java.lang.InterruptedException
exists
in interface IZkConnection
org.apache.zookeeper.KeeperException
java.lang.InterruptedException
public java.util.List<java.lang.String> getChildren(java.lang.String path, boolean watch) throws org.apache.zookeeper.KeeperException, java.lang.InterruptedException
getChildren
in interface IZkConnection
org.apache.zookeeper.KeeperException
java.lang.InterruptedException
public byte[] readData(java.lang.String path, org.apache.zookeeper.data.Stat stat, boolean watch) throws org.apache.zookeeper.KeeperException, java.lang.InterruptedException
readData
in interface IZkConnection
org.apache.zookeeper.KeeperException
java.lang.InterruptedException
public void writeData(java.lang.String path, byte[] data) throws org.apache.zookeeper.KeeperException, java.lang.InterruptedException
org.apache.zookeeper.KeeperException
java.lang.InterruptedException
public void writeData(java.lang.String path, byte[] data, int version) throws org.apache.zookeeper.KeeperException, java.lang.InterruptedException
writeData
in interface IZkConnection
org.apache.zookeeper.KeeperException
java.lang.InterruptedException
public org.apache.zookeeper.data.Stat writeDataReturnStat(java.lang.String path, byte[] data, int version) throws org.apache.zookeeper.KeeperException, java.lang.InterruptedException
writeDataReturnStat
in interface IZkConnection
org.apache.zookeeper.KeeperException
java.lang.InterruptedException
public org.apache.zookeeper.ZooKeeper.States getZookeeperState()
getZookeeperState
in interface IZkConnection
public org.apache.zookeeper.ZooKeeper getZookeeper()
public long getCreateTime(java.lang.String path) throws org.apache.zookeeper.KeeperException, java.lang.InterruptedException
getCreateTime
in interface IZkConnection
org.apache.zookeeper.KeeperException
java.lang.InterruptedException
public java.lang.String getServers()
getServers
in interface IZkConnection
public java.util.List<org.apache.zookeeper.OpResult> multi(java.lang.Iterable<org.apache.zookeeper.Op> ops) throws org.apache.zookeeper.KeeperException, java.lang.InterruptedException
multi
in interface IZkConnection
org.apache.zookeeper.KeeperException
java.lang.InterruptedException
public void addAuthInfo(java.lang.String scheme, byte[] auth)
addAuthInfo
in interface IZkConnection
public 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
setAcl
in interface IZkConnection
org.apache.zookeeper.KeeperException
java.lang.InterruptedException
public 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
getAcl
in interface IZkConnection
org.apache.zookeeper.KeeperException
java.lang.InterruptedException