public class ReplicationManager
extends java.lang.Object
Constructor and Description |
---|
ReplicationManager(Configuration conf,
ZKWatcher zkw,
Abortable abortable) |
Modifier and Type | Method and Description |
---|---|
void |
addReplicationPeer(java.lang.String peerId,
ReplicationPeerConfig peerConfig,
boolean enabled) |
void |
disableReplicationPeer(java.lang.String peerId) |
void |
enableReplicationPeer(java.lang.String peerId) |
ReplicationPeerConfig |
getPeerConfig(java.lang.String peerId) |
java.util.List<ReplicationPeerDescription> |
listReplicationPeers(java.util.regex.Pattern pattern) |
void |
removeReplicationPeer(java.lang.String peerId) |
void |
updatePeerConfig(java.lang.String peerId,
ReplicationPeerConfig peerConfig) |
public ReplicationManager(Configuration conf, ZKWatcher zkw, Abortable abortable) throws java.io.IOException
java.io.IOException
public void addReplicationPeer(java.lang.String peerId, ReplicationPeerConfig peerConfig, boolean enabled) throws ReplicationException, java.io.IOException
ReplicationException
java.io.IOException
public void removeReplicationPeer(java.lang.String peerId) throws ReplicationException
ReplicationException
public void enableReplicationPeer(java.lang.String peerId) throws ReplicationException
ReplicationException
public void disableReplicationPeer(java.lang.String peerId) throws ReplicationException
ReplicationException
public ReplicationPeerConfig getPeerConfig(java.lang.String peerId) throws ReplicationException, ReplicationPeerNotFoundException
ReplicationException
ReplicationPeerNotFoundException
public void updatePeerConfig(java.lang.String peerId, ReplicationPeerConfig peerConfig) throws ReplicationException, java.io.IOException
ReplicationException
java.io.IOException
public java.util.List<ReplicationPeerDescription> listReplicationPeers(java.util.regex.Pattern pattern) throws ReplicationException
ReplicationException