@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
ReplicationException
List<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.KeeperException
int getQueuesZNodeCversion() throws org.apache.zookeeper.KeeperException
org.apache.zookeeper.KeeperException
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.