org.openspaces.admin.internal.pu.scale_horizontal

Class ScaleMonitorThread

java.lang.Object

org.openspaces.admin.internal.pu.scale_horizontal.ScaleMonitorThread

All Implemented Interfaces:

Runnable

public class ScaleMonitorThread
extends Object
implements Runnable

Constructor Summary

Constructors

Constructor and Description
ScaleMonitorThread(DefaultAdmin admin, long scaleInterval)

Method Summary

Modifier and Type	Method and Description
boolean	executeScaleIteration()
Map<Step,IStepOperation>	initStepsOperations()
boolean	revertOperation(InternalAdminDriver driver, org.openspaces.zookeeper.attribute_store.ZooKeeperAttributeStore attributeStore, DefaultProcessingUnit pu, Step step, Status status)
void	run()
boolean	scaleOperation(InternalAdminDriver driver, org.openspaces.zookeeper.attribute_store.ZooKeeperAttributeStore attributeStore, DefaultProcessingUnit pu, Step step, Status status)

Methods inherited from class java.lang.Object

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

Constructor Detail

ScaleMonitorThread

public ScaleMonitorThread(DefaultAdmin admin,
                          long scaleInterval)

Method Detail

run

public void run()

Specified by:

run in interface Runnable

executeScaleIteration

public boolean executeScaleIteration()

scaleOperation

public boolean scaleOperation(InternalAdminDriver driver,
                              org.openspaces.zookeeper.attribute_store.ZooKeeperAttributeStore attributeStore,
                              DefaultProcessingUnit pu,
                              Step step,
                              Status status)
                       throws IOException,
                              InterruptedException,
                              TimeoutException

Throws:

IOException

InterruptedException

TimeoutException

revertOperation

public boolean revertOperation(InternalAdminDriver driver,
                               org.openspaces.zookeeper.attribute_store.ZooKeeperAttributeStore attributeStore,
                               DefaultProcessingUnit pu,
                               Step step,
                               Status status)
                        throws IOException

Throws:

IOException

initStepsOperations

public Map<Step,IStepOperation> initStepsOperations()