Package 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	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.
int	flushRedoLogToStorage()
IReplicationRouterAdmin	getRouterAdmin()
DynamicSourceGroupConfigHolder	getSourceGroupConfigHolder(String groupName)
ReplicationStatistics	getStatistics()
Object[]	getStatus()
void	monitorState(OperationWeightInfo info)
void	setActive()	Sets the administrated IReplicationNode as active mode (i.e containing space is not a backup)
void	setNodeStateListener(IReplicationNodeStateListener listener)
void	setPassive(boolean closeProxy)	Sets the administrated IReplicationNode as passive mode (i.e containing space is backup)

Method Details

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(OperationWeightInfo info)
           throws RedoLogCapacityExceededException,
ConsistencyLevelViolationException

Throws:

RedoLogCapacityExceededException

ConsistencyLevelViolationException

getStatistics

ReplicationStatistics getStatistics()

flushRedoLogToStorage

int flushRedoLogToStorage()

Returns:

number of flushed packets

Since:

16.2

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(boolean closeProxy)

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

Parameters:

closeProxy - - whether to close the stub proxy when it has no more references.

dumpState

String dumpState()

clearStaleReplicas

void clearStaleReplicas(long expirationTime)

getRouterAdmin

IReplicationRouterAdmin getRouterAdmin()

Since:

8.0.5

getSourceGroupConfigHolder

DynamicSourceGroupConfigHolder getSourceGroupConfigHolder(String groupName)

Since:

8.0.5