org.apache.hadoop.hbase.replication

Class TestReplicationEndpoint.ReplicationEndpointForTest

java.lang.Object

org.apache.hbase.thirdparty.com.google.common.util.concurrent.AbstractService

org.apache.hadoop.hbase.replication.BaseReplicationEndpoint

org.apache.hadoop.hbase.replication.TestReplicationEndpoint.ReplicationEndpointForTest

All Implemented Interfaces:

org.apache.hadoop.hbase.replication.ReplicationEndpoint, org.apache.hadoop.hbase.replication.ReplicationPeerConfigListener, org.apache.hbase.thirdparty.com.google.common.util.concurrent.Service

Direct Known Subclasses:

TestReplicationEndpoint.ReplicationEndpointReturningFalse, TestReplicationEndpoint.ReplicationEndpointWithWALEntryFilter, TestReplicationEndpoint.SleepingReplicationEndpointForTest

Enclosing class:

TestReplicationEndpoint

public static class TestReplicationEndpoint.ReplicationEndpointForTest
extends org.apache.hadoop.hbase.replication.BaseReplicationEndpoint

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.hadoop.hbase.replication.ReplicationEndpoint

org.apache.hadoop.hbase.replication.ReplicationEndpoint.Context, org.apache.hadoop.hbase.replication.ReplicationEndpoint.ReplicateContext

Nested classes/interfaces inherited from interface org.apache.hbase.thirdparty.com.google.common.util.concurrent.Service

org.apache.hbase.thirdparty.com.google.common.util.concurrent.Service.Listener, org.apache.hbase.thirdparty.com.google.common.util.concurrent.Service.State

Field Summary

Fields

Modifier and Type	Field and Description
(package private) static AtomicInteger	contructedCount
(package private) static List<org.apache.hadoop.hbase.wal.WAL.Entry>	lastEntries
(package private) static AtomicInteger	replicateCount
(package private) static AtomicInteger	startedCount
(package private) static AtomicInteger	stoppedCount
(package private) static UUID	uuid

Fields inherited from class org.apache.hadoop.hbase.replication.BaseReplicationEndpoint

ctx, REPLICATION_WALENTRYFILTER_CONFIG_KEY

Constructor Summary

Constructors

Constructor and Description
ReplicationEndpointForTest()

Method Summary

Modifier and Type	Method and Description
boolean	canReplicateToSameCluster()
protected void	doStart()
protected void	doStop()
UUID	getPeerUUID()
boolean	replicate(org.apache.hadoop.hbase.replication.ReplicationEndpoint.ReplicateContext replicateContext)
void	start()
void	stop()

Methods inherited from class org.apache.hadoop.hbase.replication.BaseReplicationEndpoint

getNamespaceTableCfWALEntryFilter, getScopeWALEntryFilter, getWALEntryfilter, init, isStarting, peerConfigUpdated

Methods inherited from class org.apache.hbase.thirdparty.com.google.common.util.concurrent.AbstractService

addListener, awaitRunning, awaitRunning, awaitRunning, awaitTerminated, awaitTerminated, awaitTerminated, doCancelStart, failureCause, isRunning, notifyFailed, notifyStarted, notifyStopped, startAsync, state, stopAsync, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.hadoop.hbase.replication.ReplicationEndpoint

awaitRunning, awaitRunning, awaitTerminated, awaitTerminated, failureCause, isRunning

Field Detail

uuid

static UUID uuid

contructedCount

static AtomicInteger contructedCount

startedCount

static AtomicInteger startedCount

stoppedCount

static AtomicInteger stoppedCount

replicateCount

static AtomicInteger replicateCount

lastEntries

static volatile List<org.apache.hadoop.hbase.wal.WAL.Entry> lastEntries

Constructor Detail

ReplicationEndpointForTest

public ReplicationEndpointForTest()

Method Detail

getPeerUUID

public UUID getPeerUUID()

replicate

public boolean replicate(org.apache.hadoop.hbase.replication.ReplicationEndpoint.ReplicateContext replicateContext)

start

public void start()

stop

public void stop()

doStart

protected void doStart()

Specified by:

doStart in class org.apache.hbase.thirdparty.com.google.common.util.concurrent.AbstractService

doStop

protected void doStop()

Specified by:

doStop in class org.apache.hbase.thirdparty.com.google.common.util.concurrent.AbstractService

canReplicateToSameCluster

public boolean canReplicateToSameCluster()

Specified by:

canReplicateToSameCluster in interface org.apache.hadoop.hbase.replication.ReplicationEndpoint

Overrides:

canReplicateToSameCluster in class org.apache.hadoop.hbase.replication.BaseReplicationEndpoint