public class InMemoryConnection extends java.lang.Object implements IZkConnection
Modifier and Type | Class and Description |
---|---|
static class |
InMemoryConnection.DataAndVersion |
Constructor and Description |
---|
InMemoryConnection() |
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) |
public void close() throws java.lang.InterruptedException
close
in interface IZkConnection
java.lang.InterruptedException
public void connect(org.apache.zookeeper.Watcher watcher)
connect
in interface IZkConnection
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 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 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 org.apache.zookeeper.ZooKeeper.States getZookeeperState()
getZookeeperState
in interface IZkConnection
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, int expectedVersion) 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 expectedVersion) throws org.apache.zookeeper.KeeperException, java.lang.InterruptedException
writeDataReturnStat
in interface IZkConnection
org.apache.zookeeper.KeeperException
java.lang.InterruptedException
public long getCreateTime(java.lang.String path)
getCreateTime
in interface IZkConnection
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