Package | Description |
---|---|
com.gigaspaces.attribute_store | |
com.gigaspaces.client |
Deprecated: use
org.openspaces.core instead. |
com.gigaspaces.internal.server.space | |
com.gigaspaces.internal.server.space.repartitioning | |
org.openspaces.admin.internal.pu.scale_horizontal | |
org.openspaces.admin.internal.pu.scale_horizontal.steps | |
org.openspaces.core.config |
Support classes for Spring namespace based configuration of OpenSpaces core.
|
org.openspaces.core.space |
This package is responsible for simplifying the creation of IJSpace implementation.
|
Modifier and Type | Class and Description |
---|---|
class |
PropertiesFileAttributeStore
Note that this is a technology preview feature may be changed in the future.
|
class |
TransientAttributeStore |
Modifier and Type | Method and Description |
---|---|
void |
SpaceProxyFactory.setAttributeStore(AttributeStore attributeStore) |
Modifier and Type | Method and Description |
---|---|
AttributeStore |
SpaceImpl.getAttributeStore() |
Modifier and Type | Method and Description |
---|---|
static ClusterTopology |
ZookeeperTopologyHandler.getClusterTopology(AttributeStore attributeStore,
String puName,
int generation) |
Constructor and Description |
---|
ZookeeperLastPrimaryHandler(SpaceImpl spaceImpl,
AttributeStore attributeStore,
org.slf4j.Logger logger) |
ZookeeperTopologyHandler(String puName,
AttributeStore attributeStore) |
Modifier and Type | Method and Description |
---|---|
static boolean |
ZKScaleOutUtils.checkIfScaleIsCanceled(AttributeStore attributeStore,
String puName) |
static ClusterTopologyState |
ZKScaleOutUtils.getOldTopologyState(AttributeStore attributeStore,
String puName) |
static List<Integer> |
ZKScaleOutUtils.getParticipantPartitions(AttributeStore attributeStore,
String puName) |
static QuiesceToken |
ZKScaleOutUtils.getQuiesceToken(AttributeStore attributeStore,
String puName) |
static String |
ZKScaleOutUtils.getScaleOutLastStep(AttributeStore attributeStore,
String puName) |
static String |
ZKScaleOutUtils.getScaleOutMetaData(AttributeStore attributeStore,
String puName,
String key) |
static ScaleRequestInfo |
ZKScaleOutUtils.getScaleRequestInfoIfExist(AttributeStore attributeStore,
String requestId,
List<String> pusName) |
static Status |
ZKScaleOutUtils.getScaleStatusOnCompletion(AttributeStore attributeStore,
String puName) |
static String |
ZKScaleOutUtils.getStepDetails(AttributeStore attributeStore,
String puName,
String step,
String key) |
static boolean |
ZKScaleOutUtils.isScaleInProgress(AttributeStore attributeStore,
String puName) |
static void |
ZKScaleOutUtils.setOldTopologyState(AttributeStore attributeStore,
String puName,
ClusterTopologyState topologyState) |
static void |
ZKScaleOutUtils.setQuiesceToken(AttributeStore attributeStore,
String puName,
Object value) |
static void |
ZKScaleOutUtils.setScaleOutLastStep(AttributeStore attributeStore,
String puName,
String step) |
static void |
ZKScaleOutUtils.setScaleOutMetaData(AttributeStore attributeStore,
String puName,
String key,
String value) |
static boolean |
ZKScaleOutUtils.setStepIfPossible(AttributeStore attributeStore,
String puName,
String step,
String key,
String value) |
Modifier and Type | Method and Description |
---|---|
static ClusterTopology |
ScaleManager.getClusterTopology(AttributeStore attributeStore,
String puName,
int generation) |
static ClusterTopologyState |
ScaleManager.getClusterTopologyState(AttributeStore attributeStore,
String puName) |
static InternalQuiesceDetails |
ScaleManager.getQuiesceDetails(AttributeStore attributeStore,
String puName) |
static void |
ScaleManager.setClusterTopology(AttributeStore attributeStore,
String puName,
ClusterTopology topology) |
static void |
ScaleManager.setClusterTopologyState(AttributeStore attributeStore,
String puName,
ClusterTopologyState topologyState) |
static void |
ScaleManager.updateGenerationAfterScaleOut(DefaultProcessingUnit pu,
ClusterTopology currentMap,
ClusterTopology newMap,
AttributeStore attributeStore) |
Modifier and Type | Method and Description |
---|---|
default boolean |
IStepOperation.checkIfStepIsCompleted(DefaultProcessingUnit pu,
AttributeStore attributeStore,
String stepName,
GigaSpace gigaSpace,
InternalAdminDriver driver) |
void |
CopyChunksStep.executePerInstance(DefaultProcessingUnit pu,
AttributeStore attributeStore,
GigaSpace gigaSpace,
int partitionId) |
void |
DeleteChunksStep.executePerInstance(DefaultProcessingUnit pu,
AttributeStore attributeStore,
GigaSpace gigaSpace,
int partitionId) |
void |
DrainStep.executePerInstance(DefaultProcessingUnit pu,
AttributeStore attributeStore,
GigaSpace gigaSpace,
int partitionId) |
default void |
IStepOperation.executePerInstance(DefaultProcessingUnit pu,
AttributeStore attributeStore,
GigaSpace gigaSpace,
int partitionId) |
void |
CopyChunksStep.executeStepOperation(DefaultProcessingUnit pu,
AttributeStore attributeStore,
GigaSpace gigaSpace,
InternalAdminDriver driver,
long timeout) |
void |
CreateNewTopologyStep.executeStepOperation(DefaultProcessingUnit pu,
AttributeStore attributeStore,
GigaSpace gigaSpace,
InternalAdminDriver driver,
long timeout) |
void |
DeleteChunksStep.executeStepOperation(DefaultProcessingUnit pu,
AttributeStore attributeStore,
GigaSpace gigaSpace,
InternalAdminDriver driver,
long timeout) |
void |
DrainStep.executeStepOperation(DefaultProcessingUnit pu,
AttributeStore attributeStore,
GigaSpace gigaSpace,
InternalAdminDriver driver,
long timeout) |
void |
IStepOperation.executeStepOperation(DefaultProcessingUnit pu,
AttributeStore attributeStore,
GigaSpace gigaSpace,
InternalAdminDriver driver,
long timeout) |
void |
KillInstancesStep.executeStepOperation(DefaultProcessingUnit pu,
AttributeStore attributeStore,
GigaSpace gigaSpace,
InternalAdminDriver driver,
long timeout) |
void |
RevertPuMetaDataStep.executeStepOperation(DefaultProcessingUnit pu,
AttributeStore attributeStore,
GigaSpace gigaSpace,
InternalAdminDriver driver,
long timeout) |
void |
SetNewTopologyStep.executeStepOperation(DefaultProcessingUnit pu,
AttributeStore attributeStore,
GigaSpace gigaSpace,
InternalAdminDriver driver,
long timeout) |
void |
UnquiesceOnRollbackStep.executeStepOperation(DefaultProcessingUnit pu,
AttributeStore attributeStore,
GigaSpace gigaSpace,
InternalAdminDriver driver,
long timeout) |
void |
UnquiesceStep.executeStepOperation(DefaultProcessingUnit pu,
AttributeStore attributeStore,
GigaSpace gigaSpace,
InternalAdminDriver driver,
long timeout) |
void |
InformTopologyChangeStep.executeStepOperation(DefaultProcessingUnit pu,
AttributeStore attributeStore,
GigaSpace gigaSpace,
InternalAdminDriver driver,
long timeout) |
void |
QuiesceStep.executeStepOperation(DefaultProcessingUnit pu,
AttributeStore attributeStore,
GigaSpace gigaSpace,
InternalAdminDriver driver,
long timeout) |
void |
RevertTopologyStep.executeStepOperation(DefaultProcessingUnit pu,
AttributeStore attributeStore,
GigaSpace gigaSpace,
InternalAdminDriver driver,
long timeout) |
void |
TriggerInstancesInitiationStep.executeStepOperation(DefaultProcessingUnit pu,
AttributeStore attributeStore,
GigaSpace gigaSpace,
InternalAdminDriver driver,
long timeout) |
default void |
IStepOperation.executeTaskRequest(GigaSpace gigaSpace,
AttributeStore attributeStore,
SystemTask<SpaceResponseInfo> task,
Step step,
String puName,
int partitionId) |
void |
TriggerInstancesInitiationStep.waitForAllInstancesToBeAvailable(DefaultProcessingUnit pu,
AttributeStore attributeStore) |
Modifier and Type | Method and Description |
---|---|
AttributeStore |
AttributeStoreFactoryBean.getStoreHandler() |
Modifier and Type | Method and Description |
---|---|
void |
AttributeStoreFactoryBean.setStoreHandler(AttributeStore storeHandler) |
Modifier and Type | Method and Description |
---|---|
void |
EmbeddedSpaceFactoryBean.attributeStore(AttributeStore attributeStore) |
UrlSpaceConfigurer |
UrlSpaceConfigurer.attributeStore(AttributeStore attributeStore)
Sets an attribute store
|
EmbeddedSpaceConfigurer |
EmbeddedSpaceConfigurer.attributeStore(AttributeStore attributeStore)
Sets an attribute store
|
void |
UrlSpaceFactoryBean.attributeStore(AttributeStore attributeStore) |
void |
InternalSpaceFactory.setAttributeStore(AttributeStore attributeStore) |
Copyright © GigaSpaces.