com.gigaspaces.internal.cluster.node

Interface IReplicationNodeAdmin

All Known Implementing Classes:

ReplicationNodeAdmin

public interface IReplicationNodeAdmin

Provide administration capabilities of an IReplicationNode

Since:

8.0

Author:

eitany

Method Summary

Modifier and Type	Method and Description
void	clearStaleReplicas(long expirationTime)
String	dumpState()
boolean	flushPendingReplication(long timeout, TimeUnit units) Attempts to flush all pending replication from the backlog The upper layer is in charge of not inserting new data to the replication node once flush is started.
IReplicationRouterAdmin	getRouterAdmin()
DynamicSourceGroupConfigHolder	getSourceGroupConfigHolder(String groupName)
ReplicationStatistics	getStatistics()
Object[]	getStatus()
void	monitorState()
void	setActive() Sets the administrated IReplicationNode as active mode (i.e containing space is not a backup)
void	setNodeStateListener(IReplicationNodeStateListener listener)
void	setPassive() Sets the administrated IReplicationNode as passive mode (i.e containing space is backup)

Method Detail

flushPendingReplication

boolean flushPendingReplication(long timeout,
                                TimeUnit units)

Attempts to flush all pending replication from the backlog The upper layer is in charge of not inserting new data to the replication node once flush is started.

Returns:

true if all was flushed successfully during the specified timeout, false otherwise.

monitorState

void monitorState()
           throws RedoLogCapacityExceededException,
                  ConsistencyLevelViolationException

Throws:

RedoLogCapacityExceededException

ConsistencyLevelViolationException

getStatistics

ReplicationStatistics getStatistics()

getStatus

Object[] getStatus()

setNodeStateListener

void setNodeStateListener(IReplicationNodeStateListener listener)

setActive

void setActive()

Sets the administrated IReplicationNode as active mode (i.e containing space is not a backup)

setPassive

void setPassive()

Sets the administrated IReplicationNode as passive mode (i.e containing space is backup)

dumpState

String dumpState()

clearStaleReplicas

void clearStaleReplicas(long expirationTime)

getRouterAdmin

IReplicationRouterAdmin getRouterAdmin()

Since:

8.0.5

getSourceGroupConfigHolder

DynamicSourceGroupConfigHolder getSourceGroupConfigHolder(String groupName)

Since:

8.0.5