@InterfaceAudience.Private public class PeerProcedureHandlerImpl extends Object implements PeerProcedureHandler
Modifier and Type | Field and Description |
---|---|
private static org.slf4j.Logger |
LOG |
private PeerActionListener |
peerActionListener |
private KeyLocker<String> |
peersLock |
private ReplicationSourceManager |
replicationSourceManager |
Constructor and Description |
---|
PeerProcedureHandlerImpl(ReplicationSourceManager replicationSourceManager,
PeerActionListener peerActionListener) |
Modifier and Type | Method and Description |
---|---|
void |
addPeer(String peerId) |
void |
claimReplicationQueue(ReplicationQueueId queueId) |
void |
disablePeer(String peerId) |
void |
enablePeer(String peerId) |
private void |
refreshPeerState(String peerId) |
void |
removePeer(String peerId) |
void |
transitSyncReplicationPeerState(String peerId,
int stage,
HRegionServer rs) |
void |
updatePeerConfig(String peerId) |
private static final org.slf4j.Logger LOG
private final ReplicationSourceManager replicationSourceManager
private final PeerActionListener peerActionListener
public PeerProcedureHandlerImpl(ReplicationSourceManager replicationSourceManager, PeerActionListener peerActionListener)
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
public void transitSyncReplicationPeerState(String peerId, int stage, HRegionServer rs) throws ReplicationException, IOException
transitSyncReplicationPeerState
in interface PeerProcedureHandler
ReplicationException
IOException
public void claimReplicationQueue(ReplicationQueueId queueId) throws ReplicationException, IOException
claimReplicationQueue
in interface PeerProcedureHandler
ReplicationException
IOException
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.