com.gigaspaces.internal.cluster.node.impl

Class ReplicationNodeAdmin

java.lang.Object

com.gigaspaces.internal.cluster.node.impl.ReplicationNodeAdmin

All Implemented Interfaces:

IReplicationNodeAdmin

public class ReplicationNodeAdmin
extends Object
implements IReplicationNodeAdmin

Administrator of a ReplicationNode

Since:

8.0

Author:

eitany

Constructor Summary

Constructors

Constructor and Description
ReplicationNodeAdmin(ReplicationNode replicationNode)

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.
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)

Methods inherited from class java.lang.Object

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

Constructor Detail

ReplicationNodeAdmin

public ReplicationNodeAdmin(ReplicationNode replicationNode)

Method Detail

flushPendingReplication

public boolean flushPendingReplication(long timeout,
                                       TimeUnit units)

Description copied from interface: IReplicationNodeAdmin

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.

Specified by:

flushPendingReplication in interface IReplicationNodeAdmin

Returns:

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

getStatistics

public ReplicationStatistics getStatistics()

Specified by:

getStatistics in interface IReplicationNodeAdmin

flushRedoLogToStorage

public int flushRedoLogToStorage()

Specified by:

flushRedoLogToStorage in interface IReplicationNodeAdmin

Returns:

number of flushed packets

getStatus

public Object[] getStatus()

Specified by:

getStatus in interface IReplicationNodeAdmin

monitorState

public void monitorState(OperationWeightInfo info)
                  throws RedoLogCapacityExceededException,
                         ConsistencyLevelViolationException

Specified by:

monitorState in interface IReplicationNodeAdmin

Throws:

RedoLogCapacityExceededException

ConsistencyLevelViolationException

setActive

public void setActive()

Description copied from interface: IReplicationNodeAdmin

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

Specified by:

setActive in interface IReplicationNodeAdmin

setPassive

public void setPassive(boolean closeProxy)

Description copied from interface: IReplicationNodeAdmin

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

Specified by:

setPassive in interface IReplicationNodeAdmin

Parameters:

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

setNodeStateListener

public void setNodeStateListener(IReplicationNodeStateListener listener)

Specified by:

setNodeStateListener in interface IReplicationNodeAdmin

dumpState

public String dumpState()

Specified by:

dumpState in interface IReplicationNodeAdmin

clearStaleReplicas

public void clearStaleReplicas(long expirationTime)

Specified by:

clearStaleReplicas in interface IReplicationNodeAdmin

getRouterAdmin

public IReplicationRouterAdmin getRouterAdmin()

Specified by:

getRouterAdmin in interface IReplicationNodeAdmin

getSourceGroupConfigHolder

public DynamicSourceGroupConfigHolder getSourceGroupConfigHolder(String groupName)

Specified by:

getSourceGroupConfigHolder in interface IReplicationNodeAdmin