org.apache.hadoop.hbase.replication

Interface ReplicationPeerStorage

All Known Implementing Classes:

ZKReplicationPeerStorage

@InterfaceAudience.Private
public interface ReplicationPeerStorage

Perform read/write to the replication peer storage.

Method Summary

Modifier and Type	Method and Description
void	addPeer(String peerId, ReplicationPeerConfig peerConfig, boolean enabled) Add a replication peer.
ReplicationPeerConfig	getPeerConfig(String peerId) Get the peer config of a replication peer.
boolean	isPeerEnabled(String peerId) Test whether a replication peer is enabled.
List<String>	listPeerIds() Return the peer ids of all replication peers.
void	removePeer(String peerId) Remove a replication peer.
void	setPeerState(String peerId, boolean enabled) Set the state of peer, true to ENABLED, otherwise to DISABLED.
void	updatePeerConfig(String peerId, ReplicationPeerConfig peerConfig) Update the config a replication peer.

Method Detail

addPeer

void addPeer(String peerId,
             ReplicationPeerConfig peerConfig,
             boolean enabled)
      throws ReplicationException

Add a replication peer.

Throws:

ReplicationException - if there are errors accessing the storage service.

removePeer

void removePeer(String peerId)
         throws ReplicationException

Remove a replication peer.

Throws:

ReplicationException - if there are errors accessing the storage service.

setPeerState

void setPeerState(String peerId,
                  boolean enabled)
           throws ReplicationException

Set the state of peer, true to ENABLED, otherwise to DISABLED.

Throws:

ReplicationException - if there are errors accessing the storage service.

updatePeerConfig

void updatePeerConfig(String peerId,
                      ReplicationPeerConfig peerConfig)
               throws ReplicationException

Update the config a replication peer.

Throws:

ReplicationException - if there are errors accessing the storage service.

listPeerIds

List<String> listPeerIds()
                  throws ReplicationException

Return the peer ids of all replication peers.

Throws:

ReplicationException - if there are errors accessing the storage service.

isPeerEnabled

boolean isPeerEnabled(String peerId)
               throws ReplicationException

Test whether a replication peer is enabled.

Throws:

ReplicationException - if there are errors accessing the storage service.

getPeerConfig

ReplicationPeerConfig getPeerConfig(String peerId)
                             throws ReplicationException

Get the peer config of a replication peer.

Throws:

ReplicationException - if there are errors accessing the storage service.