Package com.gigaspaces.internal.server.space.repartitioning

Class ZookeeperScaleOutHandler

java.lang.Object

com.gigaspaces.internal.server.space.repartitioning.ZookeeperScaleOutHandler

public class ZookeeperScaleOutHandler
extends Object

Constructor Summary

Constructors

Constructor	Description
ZookeeperScaleOutHandler()

Method Summary

Modifier and Type	Method	Description
static boolean	checkIfScaleIsCanceled(AttributeStore attributeStore, String puName)
static ClusterTopologyState	getOldTopologyState(AttributeStore attributeStore, String puName)
static List<Integer>	getParticipantPartitions(AttributeStore attributeStore, String puName)
static QuiesceToken	getQuiesceToken(AttributeStore attributeStore, String puName)
static String	getScaleOutLastStep(AttributeStore attributeStore, String puName)
static String	getScaleOutMetaData(AttributeStore attributeStore, String puName, String key)
static String	getScaleOutPath(String puName)
static ScaleRequestInfo	getScaleRequestInfoIfExist(AttributeStore attributeStore, String requestId, List<String> pusName)
static Status	getScaleStatusOnCompletion(AttributeStore attributeStore, String puName)
static String	getScaleStepsPath(String puName, String step)
static String	getStepDetails(AttributeStore attributeStore, String puName, String step, String key)
static boolean	isScaleInProgress(AttributeStore attributeStore, String puName)
static void	setOldTopologyState(AttributeStore attributeStore, String puName, ClusterTopologyState topologyState)
static void	setQuiesceToken(AttributeStore attributeStore, String puName, Object value)
static void	setScaleOutLastStep(AttributeStore attributeStore, String puName, String step)
static void	setScaleOutMetaData(AttributeStore attributeStore, String puName, String key, String value)
static boolean	setStepIfPossible(AttributeStore attributeStore, String puName, String step, String key, String value)

Methods inherited from class java.lang.Object

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

Constructor Details

ZookeeperScaleOutHandler

public ZookeeperScaleOutHandler()

Method Details

getScaleOutPath

public static String getScaleOutPath(String puName)

getScaleStepsPath

public static String getScaleStepsPath(String puName,
 String step)

getStepDetails

public static String getStepDetails(AttributeStore attributeStore,
 String puName,
 String step,
 String key)
                             throws IOException

Throws:

IOException

setScaleOutMetaData

public static void setScaleOutMetaData(AttributeStore attributeStore,
 String puName,
 String key,
 String value)
                                throws IOException

Throws:

IOException

getScaleOutMetaData

public static String getScaleOutMetaData(AttributeStore attributeStore,
 String puName,
 String key)
                                  throws IOException

Throws:

IOException

setScaleOutLastStep

public static void setScaleOutLastStep(AttributeStore attributeStore,
 String puName,
 String step)
                                throws IOException

Throws:

IOException

setQuiesceToken

public static void setQuiesceToken(AttributeStore attributeStore,
 String puName,
 Object value)
                            throws IOException

Throws:

IOException

getQuiesceToken

public static QuiesceToken getQuiesceToken(AttributeStore attributeStore,
 String puName)
                                    throws IOException

Throws:

IOException

getScaleOutLastStep

public static String getScaleOutLastStep(AttributeStore attributeStore,
 String puName)
                                  throws IOException

Throws:

IOException

getParticipantPartitions

public static List<Integer> getParticipantPartitions(AttributeStore attributeStore,
 String puName)
                                              throws IOException

Throws:

IOException

setStepIfPossible

public static boolean setStepIfPossible(AttributeStore attributeStore,
 String puName,
 String step,
 String key,
 String value)

isScaleInProgress

public static boolean isScaleInProgress(AttributeStore attributeStore,
 String puName)

getScaleStatusOnCompletion

public static Status getScaleStatusOnCompletion(AttributeStore attributeStore,
 String puName)

checkIfScaleIsCanceled

public static boolean checkIfScaleIsCanceled(AttributeStore attributeStore,
 String puName)

setOldTopologyState

public static void setOldTopologyState(AttributeStore attributeStore,
 String puName,
 ClusterTopologyState topologyState)

getOldTopologyState

public static ClusterTopologyState getOldTopologyState(AttributeStore attributeStore,
 String puName)

getScaleRequestInfoIfExist

public static ScaleRequestInfo getScaleRequestInfoIfExist(AttributeStore attributeStore,
 String requestId,
 List<String> pusName)
                                                   throws IOException

Throws:

IOException