@InterfaceAudience.Private public interface ReplicationQueuesClient
Modifier and Type | Method and Description |
---|---|
java.util.List<java.lang.String> |
getAllPeersFromHFileRefsQueue()
Get list of all peers from hfile reference queue.
|
java.util.List<java.lang.String> |
getAllQueues(java.lang.String serverName)
Get a list of all queues for the specified region server.
|
int |
getHFileRefsNodeChangeVersion()
Get the change version number of replication hfile references node.
|
java.util.List<java.lang.String> |
getListOfReplicators()
Get a list of all region servers that have outstanding replication queues.
|
java.util.List<java.lang.String> |
getLogsInQueue(java.lang.String serverName,
java.lang.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.
|
java.util.List<java.lang.String> |
getReplicableHFiles(java.lang.String peerId)
Get a list of all hfile references in the given peer.
|
void |
init()
Initialize the replication queue client interface.
|
void init() throws ReplicationException
ReplicationException
java.util.List<java.lang.String> getListOfReplicators() throws KeeperException
KeeperException
- zookeeper exceptionjava.util.List<java.lang.String> getLogsInQueue(java.lang.String serverName, java.lang.String queueId) throws KeeperException
serverName
- the server name of the region server that owns the queuequeueId
- a String that identifies the queueKeeperException
- zookeeper exceptionjava.util.List<java.lang.String> getAllQueues(java.lang.String serverName) throws KeeperException
serverName
- the server name of the region server that owns the set of queuesKeeperException
int getQueuesZNodeCversion() throws KeeperException
KeeperException
int getHFileRefsNodeChangeVersion() throws KeeperException
KeeperException
java.util.List<java.lang.String> getAllPeersFromHFileRefsQueue() throws KeeperException
KeeperException
- zookeeper exceptionjava.util.List<java.lang.String> getReplicableHFiles(java.lang.String peerId) throws KeeperException
peerId
- a String that identifies the peerKeeperException
- zookeeper exception