@InterfaceAudience.Private public interface ReplicationQueuesClient
| Modifier and Type | Method and Description |
|---|---|
List<String> |
getAllQueues(String serverName)
Get a list of all queues for the specified region server.
|
List<String> |
getListOfReplicators()
Get a list of all region servers that have outstanding replication queues.
|
List<String> |
getLogsInQueue(String serverName,
String queueId)
Get a list of all WALs in the given queue on the given region server.
|
int |
getQueuesZNodeCversion()
Get the cversion of replication rs node.
|
void |
init()
Initialize the replication queue client interface.
|
void init()
throws ReplicationException
ReplicationExceptionList<String> getListOfReplicators() throws org.apache.zookeeper.KeeperException
org.apache.zookeeper.KeeperException - zookeeper exceptionList<String> getLogsInQueue(String serverName, String queueId) throws org.apache.zookeeper.KeeperException
serverName - the server name of the region server that owns the queuequeueId - a String that identifies the queueorg.apache.zookeeper.KeeperException - zookeeper exceptionList<String> getAllQueues(String serverName) throws org.apache.zookeeper.KeeperException
serverName - the server name of the region server that owns the set of queuesorg.apache.zookeeper.KeeperExceptionint getQueuesZNodeCversion()
throws org.apache.zookeeper.KeeperException
org.apache.zookeeper.KeeperExceptionCopyright © 2007–2016 The Apache Software Foundation. All rights reserved.