Class TestDisablePeerModification.MockPeerStorage
java.lang.Object
org.apache.hadoop.hbase.replication.FSReplicationPeerStorage
org.apache.hadoop.hbase.master.replication.TestDisablePeerModification.MockPeerStorage
- All Implemented Interfaces:
org.apache.hadoop.hbase.replication.ReplicationPeerStorage
- Enclosing class:
- TestDisablePeerModification
public static final class TestDisablePeerModification.MockPeerStorage
extends org.apache.hadoop.hbase.replication.FSReplicationPeerStorage
-
Field Summary
Fields inherited from class org.apache.hadoop.hbase.replication.FSReplicationPeerStorage
PEERS_DIR, PEERS_DIR_DEFAULT
-
Constructor Summary
ConstructorDescriptionMockPeerStorage
(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.conf.Configuration conf) -
Method Summary
Methods inherited from class org.apache.hadoop.hbase.replication.FSReplicationPeerStorage
getPeerConfig, getPeerNewSyncReplicationState, getPeerSyncReplicationState, isPeerEnabled, listPeerIds, removePeer, setPeerNewSyncReplicationState, setPeerState, transitPeerSyncReplicationState, updatePeerConfig
-
Constructor Details
-
MockPeerStorage
public MockPeerStorage(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.conf.Configuration conf) throws IOException - Throws:
IOException
-
-
Method Details
-
addPeer
public void addPeer(String peerId, org.apache.hadoop.hbase.replication.ReplicationPeerConfig peerConfig, boolean enabled, org.apache.hadoop.hbase.replication.SyncReplicationState syncReplicationState) throws org.apache.hadoop.hbase.replication.ReplicationException - Specified by:
addPeer
in interfaceorg.apache.hadoop.hbase.replication.ReplicationPeerStorage
- Overrides:
addPeer
in classorg.apache.hadoop.hbase.replication.FSReplicationPeerStorage
- Throws:
org.apache.hadoop.hbase.replication.ReplicationException
-