Package org.openspaces.admin.internal.pu.scale_horizontal.steps

Interface IStepOperation

All Known Implementing Classes:

CopyChunksStep, CreateNewTopologyStep, DeleteChunksStep, DrainStep, InformTopologyChangeStep, KillInstancesStep, QuiesceStep, RevertPuMetaDataStep, RevertTopologyStep, SetNewTopologyStep, TriggerInstancesInitiationStep, UnquiesceOnRollbackStep, UnquiesceStep

public interface IStepOperation

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static enum	IStepOperation.StepType

Field Summary

Fields

Modifier and Type	Field	Description
static final org.slf4j.Logger	logger

Method Summary

Modifier and Type	Method	Description
default boolean	checkIfStepIsCompleted(DefaultProcessingUnit pu, AttributeStore attributeStore, String stepName, GigaSpace gigaSpace, InternalAdminDriver driver)
default HashMap<Integer,String>	createInstanceIdsMap(DefaultProcessingUnit pu, int startIndex, int endIndex)
default void	executePerInstance(DefaultProcessingUnit pu, AttributeStore attributeStore, GigaSpace gigaSpace, int partitionId)
void	executeStepOperation(DefaultProcessingUnit pu, AttributeStore attributeStore, GigaSpace gigaSpace, InternalAdminDriver driver, long timeout)
default void	executeTaskRequest(GigaSpace gigaSpace, AttributeStore attributeStore, SystemTask<SpaceResponseInfo> task, Step step, String puName, int partitionId)
default List<Integer>	generateList(int num)
IStepOperation.StepType	getStepType()

Field Details

logger

static final org.slf4j.Logger logger

Method Details

executeStepOperation

void executeStepOperation(DefaultProcessingUnit pu,
 AttributeStore attributeStore,
 GigaSpace gigaSpace,
 InternalAdminDriver driver,
 long timeout)

checkIfStepIsCompleted

default boolean checkIfStepIsCompleted(DefaultProcessingUnit pu,
 AttributeStore attributeStore,
 String stepName,
 GigaSpace gigaSpace,
 InternalAdminDriver driver)

generateList

default List<Integer> generateList(int num)

executePerInstance

default void executePerInstance(DefaultProcessingUnit pu,
 AttributeStore attributeStore,
 GigaSpace gigaSpace,
 int partitionId)
                         throws Exception

Throws:

Exception

executeTaskRequest

default void executeTaskRequest(GigaSpace gigaSpace,
 AttributeStore attributeStore,
 SystemTask<SpaceResponseInfo> task,
 Step step,
 String puName,
 int partitionId)

createInstanceIdsMap

default HashMap<Integer,String> createInstanceIdsMap(DefaultProcessingUnit pu,
 int startIndex,
 int endIndex)

getStepType

IStepOperation.StepType getStepType()