Package 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	Description
ScaleMonitorThread(DefaultAdmin admin, long scaleInterval)

Method Summary

Modifier and Type	Method	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 Details

ScaleMonitorThread

public ScaleMonitorThread(DefaultAdmin admin,
 long scaleInterval)

Method Details

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 Exception

Throws:

Exception

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