Package org.apache.hadoop.hbase.replication

Interface ReplicationPeerStorage

All Known Implementing Classes:

FSReplicationPeerStorage, ZKReplicationPeerStorage

@Private
public interface ReplicationPeerStorage

Perform read/write to the replication peer storage.

Method Summary

Modifier and Type	Method	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 Details

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.