org.openspaces.admin.internal.pu.scale_horizontal

Class ScaleManager

java.lang.Object

org.openspaces.admin.internal.pu.scale_horizontal.ScaleManager

public class ScaleManager
extends Object

Constructor Summary

Constructors

Constructor and Description
ScaleManager(InternalAdmin admin)

Method Summary

Modifier and Type	Method and Description
static String	convertToInstanceId(String idFromName)
static ClusterTopology	getClusterTopology(AttributeStore attributeStore, String puName, int generation)
static ClusterTopologyState	getClusterTopologyState(AttributeStore attributeStore, String puName)
ClusterTopology	getLatestChunksMap(String puName)
static InternalQuiesceDetails	getQuiesceDetails(AttributeStore attributeStore, String puName)
boolean	isRESTScaleRequest(String puName)
boolean	isScaling(String puName)
static boolean	killPartitionInstances(DefaultProcessingUnit pu, ClusterTopology newMap)
boolean	postScaleRequest(String puName)
void	scaleIn(DefaultProcessingUnit pu, int factor, InternalAdminDriver driver)
void	scaleOutUnSafe(DefaultProcessingUnit pu, int factor, String memory, String cpu, InternalAdminDriver driver)
static void	setClusterTopology(AttributeStore attributeStore, String puName, ClusterTopology topology)
static void	setClusterTopologyState(AttributeStore attributeStore, String puName, ClusterTopologyState topologyState)
void	setRollbackDetailsOnZK(DefaultProcessingUnit pu)
void	setScaleOutDetailsOnZK(DefaultProcessingUnit pu, int factor, String memory, String cpu, String requestId)
static void	updateGenerationAfterScaleOut(DefaultProcessingUnit pu, ClusterTopology currentMap, ClusterTopology newMap, AttributeStore attributeStore)

Methods inherited from class java.lang.Object

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

Constructor Detail

ScaleManager

public ScaleManager(InternalAdmin admin)

Method Detail

getClusterTopologyState

public static ClusterTopologyState getClusterTopologyState(AttributeStore attributeStore,
                                                           String puName)
                                                    throws IOException

Throws:

IOException

getClusterTopology

public static ClusterTopology getClusterTopology(AttributeStore attributeStore,
                                                 String puName,
                                                 int generation)
                                          throws IOException

Throws:

IOException

setScaleOutDetailsOnZK

public void setScaleOutDetailsOnZK(DefaultProcessingUnit pu,
                                   int factor,
                                   String memory,
                                   String cpu,
                                   String requestId)
                            throws IOException

Throws:

IOException

setRollbackDetailsOnZK

public void setRollbackDetailsOnZK(DefaultProcessingUnit pu)
                            throws IOException

Throws:

IOException

scaleIn

public void scaleIn(DefaultProcessingUnit pu,
                    int factor,
                    InternalAdminDriver driver)
             throws IOException,
                    TransactionException,
                    ExecutionException,
                    InterruptedException

Throws:

IOException

TransactionException

ExecutionException

InterruptedException

scaleOutUnSafe

public void scaleOutUnSafe(DefaultProcessingUnit pu,
                           int factor,
                           String memory,
                           String cpu,
                           InternalAdminDriver driver)
                    throws ExecutionException,
                           InterruptedException,
                           IOException,
                           TransactionException

Throws:

ExecutionException

InterruptedException

IOException

TransactionException

updateGenerationAfterScaleOut

public static void updateGenerationAfterScaleOut(DefaultProcessingUnit pu,
                                                 ClusterTopology currentMap,
                                                 ClusterTopology newMap,
                                                 AttributeStore attributeStore)
                                          throws IOException

Throws:

IOException

setClusterTopologyState

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

setClusterTopology

public static void setClusterTopology(AttributeStore attributeStore,
                                      String puName,
                                      ClusterTopology topology)

killPartitionInstances

public static boolean killPartitionInstances(DefaultProcessingUnit pu,
                                             ClusterTopology newMap)

convertToInstanceId

public static String convertToInstanceId(String idFromName)

getQuiesceDetails

public static InternalQuiesceDetails getQuiesceDetails(AttributeStore attributeStore,
                                                       String puName)
                                                throws IOException

Throws:

IOException

getLatestChunksMap

public ClusterTopology getLatestChunksMap(String puName)
                                   throws IOException

Throws:

IOException

isScaling

public boolean isScaling(String puName)
                  throws IOException

Throws:

IOException

isRESTScaleRequest

public boolean isRESTScaleRequest(String puName)
                           throws Exception

Throws:

Exception

postScaleRequest

public boolean postScaleRequest(String puName)
                         throws Exception

Throws:

Exception