Interface DistribStateManager
-
- All Superinterfaces:
AutoCloseable
,Closeable
,org.apache.solr.common.SolrCloseable
- All Known Implementing Classes:
ZkDistribStateManager
public interface DistribStateManager extends org.apache.solr.common.SolrCloseable
This interface represents a distributed state repository.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Default Methods Modifier and Type Method Description String
createData(String path, byte[] data, org.apache.zookeeper.CreateMode mode)
Create data (leaf) node at specified path.default VersionedData
getData(String path)
VersionedData
getData(String path, org.apache.zookeeper.Watcher watcher)
Map<String,Object>
getJson(String path)
default org.apache.solr.common.cloud.DocCollection.PrsSupplier
getPrsSupplier(String collName)
default org.apache.solr.common.cloud.PerReplicaStates
getReplicaStates(String path)
boolean
hasData(String path)
List<String>
listData(String path)
List<String>
listData(String path, org.apache.zookeeper.Watcher watcher)
default List<String>
listTree(String root)
List a subtree including the root path, using breadth-first traversal.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)
default void
removeRecursively(String root, boolean ignoreMissing, boolean includeRoot)
Remove data recursively.void
setData(String path, byte[] data, int version)
-
-
-
Method Detail
-
hasData
boolean hasData(String path) throws IOException, org.apache.zookeeper.KeeperException, InterruptedException
- Throws:
IOException
org.apache.zookeeper.KeeperException
InterruptedException
-
listData
List<String> listData(String path) throws NoSuchElementException, IOException, org.apache.zookeeper.KeeperException, InterruptedException
- Throws:
NoSuchElementException
IOException
org.apache.zookeeper.KeeperException
InterruptedException
-
listData
List<String> listData(String path, org.apache.zookeeper.Watcher watcher) throws NoSuchElementException, IOException, org.apache.zookeeper.KeeperException, InterruptedException
- Throws:
NoSuchElementException
IOException
org.apache.zookeeper.KeeperException
InterruptedException
-
getData
VersionedData getData(String path, org.apache.zookeeper.Watcher watcher) throws NoSuchElementException, IOException, org.apache.zookeeper.KeeperException, InterruptedException
- Throws:
NoSuchElementException
IOException
org.apache.zookeeper.KeeperException
InterruptedException
-
getData
default VersionedData getData(String path) throws NoSuchElementException, IOException, org.apache.zookeeper.KeeperException, InterruptedException
- Throws:
NoSuchElementException
IOException
org.apache.zookeeper.KeeperException
InterruptedException
-
getJson
Map<String,Object> getJson(String path) throws InterruptedException, IOException, org.apache.zookeeper.KeeperException
- Throws:
InterruptedException
IOException
org.apache.zookeeper.KeeperException
-
makePath
void makePath(String path) throws AlreadyExistsException, IOException, org.apache.zookeeper.KeeperException, InterruptedException
- Throws:
AlreadyExistsException
IOException
org.apache.zookeeper.KeeperException
InterruptedException
-
makePath
void makePath(String path, byte[] data, org.apache.zookeeper.CreateMode createMode, boolean failOnExists) throws AlreadyExistsException, IOException, org.apache.zookeeper.KeeperException, InterruptedException
- Throws:
AlreadyExistsException
IOException
org.apache.zookeeper.KeeperException
InterruptedException
-
createData
String createData(String path, byte[] data, org.apache.zookeeper.CreateMode mode) throws AlreadyExistsException, IOException, org.apache.zookeeper.KeeperException, InterruptedException
Create data (leaf) node at specified path.- Parameters:
path
- base path name of the node.data
- data to be stored.mode
- creation mode.- Returns:
- actual path of the node - in case of sequential nodes this will differ from the base path because of the appended sequence number.
- Throws:
AlreadyExistsException
IOException
org.apache.zookeeper.KeeperException
InterruptedException
-
removeData
void removeData(String path, int version) throws NoSuchElementException, IOException, NotEmptyException, org.apache.zookeeper.KeeperException, InterruptedException, BadVersionException
- Throws:
NoSuchElementException
IOException
NotEmptyException
org.apache.zookeeper.KeeperException
InterruptedException
BadVersionException
-
setData
void setData(String path, byte[] data, int version) throws BadVersionException, NoSuchElementException, IOException, org.apache.zookeeper.KeeperException, InterruptedException
- Throws:
BadVersionException
NoSuchElementException
IOException
org.apache.zookeeper.KeeperException
InterruptedException
-
multi
List<org.apache.zookeeper.OpResult> multi(Iterable<org.apache.zookeeper.Op> ops) throws BadVersionException, NoSuchElementException, AlreadyExistsException, IOException, org.apache.zookeeper.KeeperException, InterruptedException
- Throws:
BadVersionException
NoSuchElementException
AlreadyExistsException
IOException
org.apache.zookeeper.KeeperException
InterruptedException
-
listTree
default List<String> listTree(String root) throws NoSuchElementException, IOException, org.apache.zookeeper.KeeperException, InterruptedException
List a subtree including the root path, using breadth-first traversal.- Parameters:
root
- root path- Returns:
- list of full paths, with the root path being the first element
- Throws:
NoSuchElementException
IOException
org.apache.zookeeper.KeeperException
InterruptedException
-
getReplicaStates
default org.apache.solr.common.cloud.PerReplicaStates getReplicaStates(String path) throws org.apache.zookeeper.KeeperException, InterruptedException
- Throws:
org.apache.zookeeper.KeeperException
InterruptedException
-
getPrsSupplier
default org.apache.solr.common.cloud.DocCollection.PrsSupplier getPrsSupplier(String collName)
-
removeRecursively
default void removeRecursively(String root, boolean ignoreMissing, boolean includeRoot) throws NoSuchElementException, IOException, NotEmptyException, org.apache.zookeeper.KeeperException, InterruptedException, BadVersionException
Remove data recursively.- Parameters:
root
- root pathignoreMissing
- ignore errors if root or any children path is missingincludeRoot
- when true delete also the root path- Throws:
NoSuchElementException
IOException
NotEmptyException
org.apache.zookeeper.KeeperException
InterruptedException
BadVersionException
-
-