public class SnapshotDistribStateManager extends Object implements DistribStateManager
DistribStateManager
Constructor and Description |
---|
SnapshotDistribStateManager(DistribStateManager other,
AutoScalingConfig config)
Populate this instance from another
DistribStateManager instance. |
SnapshotDistribStateManager(Map<String,Object> snapshot)
Populate this instance from a previously generated snapshot.
|
Modifier and Type | Method and Description |
---|---|
void |
close() |
String |
createData(String path,
byte[] data,
org.apache.zookeeper.CreateMode mode) |
AutoScalingConfig |
getAutoScalingConfig(org.apache.zookeeper.Watcher watcher) |
VersionedData |
getData(String path,
org.apache.zookeeper.Watcher watcher) |
Map<String,Object> |
getSnapshot()
Create a snapshot of all content in this instance.
|
boolean |
hasData(String path) |
List<String> |
listData(String path) |
List<String> |
listData(String path,
org.apache.zookeeper.Watcher watcher) |
List<String> |
listTree(String path) |
void |
makePath(String path) |
void |
makePath(String path,
byte[] data,
org.apache.zookeeper.CreateMode createMode,
boolean failOnExists) |
List<org.apache.zookeeper.OpResult> |
multi(Iterable<org.apache.zookeeper.Op> ops) |
void |
removeData(String path,
int version) |
void |
setData(String path,
byte[] data,
int version) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getAutoScalingConfig, getData, removeRecursively
isClosed
public SnapshotDistribStateManager(DistribStateManager other, AutoScalingConfig config) throws Exception
DistribStateManager
instance.other
- another instanceconfig
- optional AutoScalingConfig
, which will overwrite any existing config.Exception
public Map<String,Object> getSnapshot()
public boolean hasData(String path) throws IOException, org.apache.zookeeper.KeeperException, InterruptedException
hasData
in interface DistribStateManager
IOException
org.apache.zookeeper.KeeperException
InterruptedException
public List<String> listData(String path) throws NoSuchElementException, IOException, org.apache.zookeeper.KeeperException, InterruptedException
listData
in interface DistribStateManager
NoSuchElementException
IOException
org.apache.zookeeper.KeeperException
InterruptedException
public List<String> listTree(String path)
listTree
in interface DistribStateManager
public List<String> listData(String path, org.apache.zookeeper.Watcher watcher) throws NoSuchElementException, IOException, org.apache.zookeeper.KeeperException, InterruptedException
listData
in interface DistribStateManager
NoSuchElementException
IOException
org.apache.zookeeper.KeeperException
InterruptedException
public VersionedData getData(String path, org.apache.zookeeper.Watcher watcher) throws NoSuchElementException, IOException, org.apache.zookeeper.KeeperException, InterruptedException
getData
in interface DistribStateManager
NoSuchElementException
IOException
org.apache.zookeeper.KeeperException
InterruptedException
public void makePath(String path) throws AlreadyExistsException, IOException, org.apache.zookeeper.KeeperException, InterruptedException
makePath
in interface DistribStateManager
AlreadyExistsException
IOException
org.apache.zookeeper.KeeperException
InterruptedException
public void makePath(String path, byte[] data, org.apache.zookeeper.CreateMode createMode, boolean failOnExists) throws AlreadyExistsException, IOException, org.apache.zookeeper.KeeperException, InterruptedException
makePath
in interface DistribStateManager
AlreadyExistsException
IOException
org.apache.zookeeper.KeeperException
InterruptedException
public String createData(String path, byte[] data, org.apache.zookeeper.CreateMode mode) throws AlreadyExistsException, IOException, org.apache.zookeeper.KeeperException, InterruptedException
createData
in interface DistribStateManager
AlreadyExistsException
IOException
org.apache.zookeeper.KeeperException
InterruptedException
public void removeData(String path, int version) throws NoSuchElementException, IOException, NotEmptyException, org.apache.zookeeper.KeeperException, InterruptedException, BadVersionException
removeData
in interface DistribStateManager
NoSuchElementException
IOException
NotEmptyException
org.apache.zookeeper.KeeperException
InterruptedException
BadVersionException
public void setData(String path, byte[] data, int version) throws BadVersionException, NoSuchElementException, IOException, org.apache.zookeeper.KeeperException, InterruptedException
setData
in interface DistribStateManager
BadVersionException
NoSuchElementException
IOException
org.apache.zookeeper.KeeperException
InterruptedException
public List<org.apache.zookeeper.OpResult> multi(Iterable<org.apache.zookeeper.Op> ops) throws BadVersionException, NoSuchElementException, AlreadyExistsException, IOException, org.apache.zookeeper.KeeperException, InterruptedException
multi
in interface DistribStateManager
BadVersionException
NoSuchElementException
AlreadyExistsException
IOException
org.apache.zookeeper.KeeperException
InterruptedException
public AutoScalingConfig getAutoScalingConfig(org.apache.zookeeper.Watcher watcher) throws InterruptedException, IOException
getAutoScalingConfig
in interface DistribStateManager
InterruptedException
IOException
public void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
IOException
Copyright © 2000-2019 Apache Software Foundation. All Rights Reserved.