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 and Description
static class	IStepOperation.StepType

Field Summary

Fields

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

Method Summary

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

logger

static final org.slf4j.Logger logger

Method Detail

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