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