@InterfaceAudience.Private public class VisibilityReplicationEndpoint extends java.lang.Object implements ReplicationEndpoint
ReplicationEndpoint.Context, ReplicationEndpoint.ReplicateContext
Constructor and Description |
---|
VisibilityReplicationEndpoint(ReplicationEndpoint endpoint,
VisibilityLabelService visibilityLabelsService) |
Modifier and Type | Method and Description |
---|---|
boolean |
canReplicateToSameCluster()
Whether or not, the replication endpoint can replicate to it's source cluster with the same
UUID
|
java.util.UUID |
getPeerUUID()
Returns a UUID of the provided peer id.
|
WALEntryFilter |
getWALEntryfilter()
Returns a WALEntryFilter to use for filtering out WALEntries from the log.
|
void |
init(ReplicationEndpoint.Context context)
Initialize the replication endpoint with the given context.
|
boolean |
isRunning() |
boolean |
replicate(ReplicationEndpoint.ReplicateContext replicateContext)
Replicate the given set of entries (in the context) to the other cluster.
|
<any> |
start() |
State |
startAndWait() |
State |
state() |
<any> |
stop() |
State |
stopAndWait() |
public VisibilityReplicationEndpoint(ReplicationEndpoint endpoint, VisibilityLabelService visibilityLabelsService)
public void init(ReplicationEndpoint.Context context) throws java.io.IOException
ReplicationEndpoint
init
in interface ReplicationEndpoint
context
- replication contextjava.io.IOException
public boolean replicate(ReplicationEndpoint.ReplicateContext replicateContext)
ReplicationEndpoint
replicate
in interface ReplicationEndpoint
replicateContext
- a context where WAL entries and other
parameters can be obtained.public java.util.UUID getPeerUUID()
ReplicationEndpoint
getPeerUUID
in interface ReplicationEndpoint
public boolean canReplicateToSameCluster()
ReplicationEndpoint
canReplicateToSameCluster
in interface ReplicationEndpoint
public WALEntryFilter getWALEntryfilter()
ReplicationEndpoint
getWALEntryfilter
in interface ReplicationEndpoint
WALEntryFilter
or null.public boolean isRunning()
public <any> start()
public State startAndWait()
public State state()
public <any> stop()
public State stopAndWait()