@InterfaceAudience.Private public class PeerProcedureHandlerImpl extends Object implements PeerProcedureHandler
Modifier and Type | Field and Description |
---|---|
private KeyLocker<String> |
peersLock |
private ReplicationSourceManager |
replicationSourceManager |
Constructor and Description |
---|
PeerProcedureHandlerImpl(ReplicationSourceManager replicationSourceManager) |
Modifier and Type | Method and Description |
---|---|
void |
addPeer(String peerId) |
void |
disablePeer(String peerId) |
void |
enablePeer(String peerId) |
private void |
refreshPeerState(String peerId) |
void |
removePeer(String peerId) |
void |
updatePeerConfig(String peerId) |
private final ReplicationSourceManager replicationSourceManager
public PeerProcedureHandlerImpl(ReplicationSourceManager replicationSourceManager)
public void addPeer(String peerId) throws IOException
addPeer
in interface PeerProcedureHandler
IOException
public void removePeer(String peerId) throws IOException
removePeer
in interface PeerProcedureHandler
IOException
private void refreshPeerState(String peerId) throws ReplicationException, IOException
ReplicationException
IOException
public void enablePeer(String peerId) throws ReplicationException, IOException
enablePeer
in interface PeerProcedureHandler
ReplicationException
IOException
public void disablePeer(String peerId) throws ReplicationException, IOException
disablePeer
in interface PeerProcedureHandler
ReplicationException
IOException
public void updatePeerConfig(String peerId) throws ReplicationException, IOException
updatePeerConfig
in interface PeerProcedureHandler
ReplicationException
IOException
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.