@InterfaceAudience.Private public interface ReplicationPeerStorage
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.
|
void addPeer(String peerId, ReplicationPeerConfig peerConfig, boolean enabled) throws ReplicationException
ReplicationException
- if there are errors accessing the storage service.void removePeer(String peerId) throws ReplicationException
ReplicationException
- if there are errors accessing the storage service.void setPeerState(String peerId, boolean enabled) throws ReplicationException
true
to ENABLED
, otherwise to DISABLED
.ReplicationException
- if there are errors accessing the storage service.void updatePeerConfig(String peerId, ReplicationPeerConfig peerConfig) throws ReplicationException
ReplicationException
- if there are errors accessing the storage service.List<String> listPeerIds() throws ReplicationException
ReplicationException
- if there are errors accessing the storage service.boolean isPeerEnabled(String peerId) throws ReplicationException
ReplicationException
- if there are errors accessing the storage service.ReplicationPeerConfig getPeerConfig(String peerId) throws ReplicationException
ReplicationException
- if there are errors accessing the storage service.Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.