Package com.gigaspaces.internal.cluster.node.impl.groups.sync

Class ConstantReplicationThrottleController

java.lang.Object

com.gigaspaces.internal.cluster.node.impl.groups.sync.ConstantReplicationThrottleController

All Implemented Interfaces:

IReplicationThrottleController, IReplicationThrottleControllerBuilder

public class ConstantReplicationThrottleController
extends Object
implements IReplicationThrottleController, IReplicationThrottleControllerBuilder

Constructor Summary

Constructors

Constructor	Description
ConstantReplicationThrottleController(int threshold, long throttleDelay)

Method Summary

Modifier and Type	Method	Description
IReplicationThrottleController	createController(String groupName, String sourceMemberName, String targetMemberName)
void	suggestThroughPut(int throughPut)
boolean	throttle(long backlogSize, int contextSize, boolean channelActive)

Methods inherited from class java.lang.Object

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

Constructor Details

ConstantReplicationThrottleController

public ConstantReplicationThrottleController(int threshold,
 long throttleDelay)

Method Details

throttle

public boolean throttle(long backlogSize,
 int contextSize,
 boolean channelActive)

Specified by:

throttle in interface IReplicationThrottleController

createController

public IReplicationThrottleController createController(String groupName,
 String sourceMemberName,
 String targetMemberName)

Specified by:

createController in interface IReplicationThrottleControllerBuilder

suggestThroughPut

public void suggestThroughPut(int throughPut)

Specified by:

suggestThroughPut in interface IReplicationThrottleController