| Modifier and Type | Method and Description | 
|---|---|
ProcessingUnit | 
Application.deployProcessingUnit(ProcessingUnitDeploymentTopology puDeployment)
Deploys the specified processing unit adding it to this application 
 | 
ProcessingUnit | 
Application.deployProcessingUnit(ProcessingUnitDeploymentTopology puDeployment,
                    long timeout,
                    TimeUnit timeUnit)
Deploys the specified processing unit adding it to this application 
 | 
| Modifier and Type | Method and Description | 
|---|---|
default boolean | 
ElasticServiceManagers.hasElasticManager(ProcessingUnit pu)
Deprecated.  
  | 
| Modifier and Type | Method and Description | 
|---|---|
ProcessingUnit | 
GatewayProcessingUnit.getProcessingUnit()
Returns the hosting  
ProcessingUnit. | 
| Modifier and Type | Method and Description | 
|---|---|
ProcessingUnit | 
GridServiceManagers.deploy(ElasticSpaceDeployment deployment)
Deprecated. 
 
Since 12.1 - Elastic deployments support will be replaced with a different solution in upcoming releases, contact support for additional information. 
 | 
ProcessingUnit | 
GridServiceManager.deploy(ElasticSpaceDeployment deployment)
Deprecated. 
 
Since 12.1 - Elastic deployments support will be replaced with a different solution in upcoming releases, contact support for additional information. 
 | 
ProcessingUnit | 
GridServiceManagers.deploy(ElasticSpaceDeployment deployment,
      long timeout,
      TimeUnit timeUnit)
Deprecated. 
 
Since 12.1 - Elastic deployments support will be replaced with a different solution in upcoming releases, contact support for additional information. 
 | 
ProcessingUnit | 
GridServiceManager.deploy(ElasticSpaceDeployment deployment,
      long timeout,
      TimeUnit timeUnit)
Deprecated. 
 
Since 12.1 - Elastic deployments support will be replaced with a different solution in upcoming releases, contact support for additional information. 
 | 
ProcessingUnit | 
GridServiceManagers.deploy(ElasticStatefulProcessingUnitDeployment deployment)
Deprecated. 
 
Since 12.1 - Elastic deployments support will be replaced with a different solution in upcoming releases, contact support for additional information. 
 | 
ProcessingUnit | 
GridServiceManager.deploy(ElasticStatefulProcessingUnitDeployment deployment)
Deprecated. 
 
Since 12.1 - Elastic deployments support will be replaced with a different solution in upcoming releases, contact support for additional information. 
 | 
ProcessingUnit | 
GridServiceManagers.deploy(ElasticStatefulProcessingUnitDeployment deployment,
      long timeout,
      TimeUnit timeUnit)
Deprecated. 
 
Since 12.1 - Elastic deployments support will be replaced with a different solution in upcoming releases, contact support for additional information. 
 | 
ProcessingUnit | 
GridServiceManager.deploy(ElasticStatefulProcessingUnitDeployment deployment,
      long timeout,
      TimeUnit timeUnit)
Deprecated. 
 
Since 12.1 - Elastic deployments support will be replaced with a different solution in upcoming releases, contact support for additional information. 
 | 
ProcessingUnit | 
GridServiceManagers.deploy(ElasticStatelessProcessingUnitDeployment deployment)
Deprecated. 
 
Since 12.1 - Elastic deployments support will be replaced with a different solution in upcoming releases, contact support for additional information. 
 | 
ProcessingUnit | 
GridServiceManager.deploy(ElasticStatelessProcessingUnitDeployment deployment)
Deprecated. 
 
Since 12.1 - Elastic deployments support will be replaced with a different solution in upcoming releases, contact support for additional information. 
 | 
ProcessingUnit | 
GridServiceManagers.deploy(ElasticStatelessProcessingUnitDeployment deployment,
      long timeout,
      TimeUnit timeUnit)
Deprecated. 
 
Since 12.1 - Elastic deployments support will be replaced with a different solution in upcoming releases, contact support for additional information. 
 | 
ProcessingUnit | 
GridServiceManager.deploy(ElasticStatelessProcessingUnitDeployment deployment,
      long timeout,
      TimeUnit timeUnit)
Deprecated. 
 
Since 12.1 - Elastic deployments support will be replaced with a different solution in upcoming releases, contact support for additional information. 
 | 
ProcessingUnit | 
GridServiceManagers.deploy(MemcachedDeployment deployment)
Deploys a memcached based on the space deployment information on a random grid service
 manager (it will act as the primary GSM for the deployed processing unit). 
 | 
ProcessingUnit | 
GridServiceManager.deploy(MemcachedDeployment deployment)
Deploys a memcached based on the space deployment information on the given grid service
 manager (it will act as the primary GSM for the deployed processing unit). 
 | 
ProcessingUnit | 
GridServiceManagers.deploy(MemcachedDeployment deployment,
      long timeout,
      TimeUnit timeUnit)
Deploys a memcached based on the space deployment information on a random grid service
 manager (it will act as the primary GSM for the deployed processing unit). 
 | 
ProcessingUnit | 
GridServiceManager.deploy(MemcachedDeployment deployment,
      long timeout,
      TimeUnit timeUnit)
Deploys a memcached based on the space deployment information on the given grid service
 manager (it will act as the primary GSM for the deployed processing unit). 
 | 
ProcessingUnit | 
GridServiceManager.deploy(ProcessingUnitConfigHolder puConfigHolder)
Deploys a new processing unit based on the specified configuration 
 | 
ProcessingUnit | 
GridServiceManager.deploy(ProcessingUnitConfigHolder puConfigHolder,
      long timeout,
      TimeUnit timeUnit)
Deploys a new processing unit based on the specified configuration 
 | 
ProcessingUnit | 
GridServiceManagers.deploy(ProcessingUnitDeployment deployment)
Deploys a processing unit based on the processing unit deployment information on a random
 grid service manager (it will act as the primary GSM for the deployed processing unit). 
 | 
ProcessingUnit | 
GridServiceManager.deploy(ProcessingUnitDeployment deployment)
Deploys a processing unit based on the processing unit deployment information on the given
 grid service manager (it will act as the primary GSM for the deployed processing unit). 
 | 
ProcessingUnit | 
GridServiceManagers.deploy(ProcessingUnitDeployment deployment,
      long timeout,
      TimeUnit timeUnit)
Deploys a processing unit based on the processing unit deployment information on a random
 grid service manager (it will act as the primary GSM for the deployed processing unit). 
 | 
ProcessingUnit | 
GridServiceManager.deploy(ProcessingUnitDeployment deployment,
      long timeout,
      TimeUnit timeUnit)
Deploys a processing unit based on the processing unit deployment information on the given
 grid service manager (it will act as the primary GSM for the deployed processing unit). 
 | 
ProcessingUnit | 
GridServiceManagers.deploy(SpaceDeployment deployment)
Deploys a space based on the space deployment information on a random grid service manager
 (it will act as the primary GSM for the deployed processing unit). 
 | 
ProcessingUnit | 
GridServiceManager.deploy(SpaceDeployment deployment)
Deploys a space based on the space deployment information on the given grid service manager
 (it will act as the primary GSM for the deployed processing unit). 
 | 
ProcessingUnit | 
GridServiceManagers.deploy(SpaceDeployment deployment,
      long timeout,
      TimeUnit timeUnit)
Deploys a space based on the space deployment information on a random grid service manager
 (it will act as the primary GSM for the deployed processing unit). 
 | 
ProcessingUnit | 
GridServiceManager.deploy(SpaceDeployment deployment,
      long timeout,
      TimeUnit timeUnit)
Deploys a space based on the space deployment information on the given grid service manager
 (it will act as the primary GSM for the deployed processing unit). 
 | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
ProcessingUnitInstanceMemberAliveIndicatorAlertBean.processingUnitRemoved(ProcessingUnit processingUnit)  | 
void | 
ProvisionFailureAlertBean.processingUnitRemoved(ProcessingUnit processingUnit)  | 
| Modifier and Type | Method and Description | 
|---|---|
static String | 
AlertBeanUtils.getProcessingUnitDescription(ProcessingUnit processingUnit)  | 
| Modifier and Type | Method and Description | 
|---|---|
ProcessingUnit | 
DefaultApplication.deployProcessingUnit(ProcessingUnitDeploymentTopology puDeployment)  | 
ProcessingUnit | 
DefaultApplication.deployProcessingUnit(ProcessingUnitDeploymentTopology puDeployment,
                    long timeout,
                    TimeUnit timeUnit)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
DefaultApplications.addApplication(Application application,
              ProcessingUnit processingUnit)  | 
void | 
InternalApplications.addApplication(Application application,
              ProcessingUnit processingUnit)  | 
void | 
DefaultApplications.removeProcessingUnit(ProcessingUnit processingUnit)  | 
void | 
InternalApplications.removeProcessingUnit(ProcessingUnit processingUnit)  | 
| Modifier and Type | Method and Description | 
|---|---|
ProcessingUnit | 
InternalAdminDriver.deploy(ProcessingUnitConfigHolder puConfigHolder)  | 
ProcessingUnit | 
InternalAdminDriver.deploy(ProcessingUnitConfigHolder puConfigHolder,
      String applicationName,
      long timeout,
      TimeUnit timeUnit)  | 
ProcessingUnit | 
InternalAdminDriver.deploy(ProcessingUnitConfig puConfig,
      String applicationName,
      long timeout,
      TimeUnit timeUnit)  | 
| Modifier and Type | Method and Description | 
|---|---|
protected void | 
ServiceGridAdminDriver.afterDeploy(ProcessingUnit pu,
           ProcessingUnitConfig puConfig,
           long deadline)  | 
protected void | 
InternalAdminDriver.afterDeploy(ProcessingUnit pu,
           ProcessingUnitConfig puConfig,
           long deadline)  | 
void | 
KubernetesAdminDriver.scaleIn(ProcessingUnit pu,
       int factor)  | 
void | 
ServiceGridAdminDriver.scaleIn(ProcessingUnit pu,
       int factor)  | 
void | 
ElasticGridAdminDriver.scaleIn(ProcessingUnit pu,
       int factor)  | 
abstract void | 
InternalAdminDriver.scaleIn(ProcessingUnit pu,
       int factor)  | 
void | 
KubernetesAdminDriver.scaleOut(ProcessingUnit pu,
        int factor,
        Integer memory,
        Integer cpu)  | 
void | 
ServiceGridAdminDriver.scaleOut(ProcessingUnit pu,
        int factor,
        Integer memory,
        Integer cpu)  | 
void | 
ElasticGridAdminDriver.scaleOut(ProcessingUnit pu,
        int factor,
        Integer memory,
        Integer cpu)  | 
abstract void | 
InternalAdminDriver.scaleOut(ProcessingUnit pu,
        int factor,
        Integer memory,
        Integer cpu)  | 
void | 
KubernetesAdminDriver.scaleUpDown(ProcessingUnit pu,
           List<Integer> partitionsIds,
           String memory,
           String cpu,
           PuScaleVStatusChangedEventListener listener)  | 
void | 
ServiceGridAdminDriver.scaleUpDown(ProcessingUnit pu,
           List<Integer> partitionsIds,
           String memory,
           String cpu,
           PuScaleVStatusChangedEventListener listener)  | 
void | 
ElasticGridAdminDriver.scaleUpDown(ProcessingUnit pu,
           List<Integer> partitionIds,
           String memory,
           String cpu,
           PuScaleVStatusChangedEventListener listener)  | 
abstract void | 
InternalAdminDriver.scaleUpDown(ProcessingUnit pu,
           List<Integer> partitionsIds,
           String memory,
           String cpu,
           PuScaleVStatusChangedEventListener listener)  | 
CompletableFuture<?> | 
InternalAdminDriver.undeployAsync(ProcessingUnit pu)  | 
| Modifier and Type | Method and Description | 
|---|---|
ProcessingUnit | 
DefaultGatewayProcessingUnit.getProcessingUnit()  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
GrafanaDashboardsHandler.processingUnitAdded(ProcessingUnit processingUnit)  | 
| Modifier and Type | Method and Description | 
|---|---|
ProcessingUnit | 
InternalGridServiceManagers.deploy(Application application,
      ProcessingUnitDeploymentTopology puDeployment,
      long timeout,
      TimeUnit timeUnit)  | 
ProcessingUnit | 
DefaultGridServiceManager.deploy(Application application,
      ProcessingUnitDeploymentTopology deploymentTopology,
      long timeout,
      TimeUnit timeUnit)  | 
ProcessingUnit | 
InternalGridServiceManager.deploy(Application application,
      ProcessingUnitDeploymentTopology deploymentTopology,
      long timeout,
      TimeUnit timeUnit)  | 
ProcessingUnit | 
DefaultGridServiceManagers.deploy(Application application,
      ProcessingUnitDeploymentTopology puDeploymentTopology,
      long timeout,
      TimeUnit timeUnit)  | 
ProcessingUnit | 
DefaultGridServiceManager.deploy(ElasticSpaceDeployment deployment)  | 
ProcessingUnit | 
DefaultGridServiceManagers.deploy(ElasticSpaceDeployment deployment)  | 
ProcessingUnit | 
DefaultGridServiceManager.deploy(ElasticSpaceDeployment deployment,
      long timeout,
      TimeUnit timeUnit)  | 
ProcessingUnit | 
DefaultGridServiceManagers.deploy(ElasticSpaceDeployment deployment,
      long timeout,
      TimeUnit timeUnit)  | 
ProcessingUnit | 
DefaultGridServiceManager.deploy(ElasticStatefulProcessingUnitDeployment deployment)  | 
ProcessingUnit | 
DefaultGridServiceManagers.deploy(ElasticStatefulProcessingUnitDeployment deployment)  | 
ProcessingUnit | 
DefaultGridServiceManager.deploy(ElasticStatefulProcessingUnitDeployment deployment,
      long timeout,
      TimeUnit timeUnit)  | 
ProcessingUnit | 
DefaultGridServiceManagers.deploy(ElasticStatefulProcessingUnitDeployment deployment,
      long timeout,
      TimeUnit timeUnit)  | 
ProcessingUnit | 
DefaultGridServiceManager.deploy(ElasticStatelessProcessingUnitDeployment deployment)  | 
ProcessingUnit | 
DefaultGridServiceManagers.deploy(ElasticStatelessProcessingUnitDeployment deployment)  | 
ProcessingUnit | 
DefaultGridServiceManager.deploy(ElasticStatelessProcessingUnitDeployment deployment,
      long timeout,
      TimeUnit timeUnit)  | 
ProcessingUnit | 
DefaultGridServiceManagers.deploy(ElasticStatelessProcessingUnitDeployment deployment,
      long timeout,
      TimeUnit timeUnit)  | 
ProcessingUnit | 
DefaultGridServiceManager.deploy(MemcachedDeployment deployment)  | 
ProcessingUnit | 
DefaultGridServiceManagers.deploy(MemcachedDeployment deployment)  | 
ProcessingUnit | 
DefaultGridServiceManager.deploy(MemcachedDeployment deployment,
      long timeout,
      TimeUnit timeUnit)  | 
ProcessingUnit | 
DefaultGridServiceManagers.deploy(MemcachedDeployment deployment,
      long timeout,
      TimeUnit timeUnit)  | 
ProcessingUnit | 
DefaultGridServiceManager.deploy(ProcessingUnitConfigHolder puConfigHolder)  | 
ProcessingUnit | 
DefaultGridServiceManager.deploy(ProcessingUnitConfigHolder puConfigHolder,
      long timeout,
      TimeUnit timeUnit)  | 
ProcessingUnit | 
DefaultGridServiceManager.deploy(ProcessingUnitDeployment deployment)  | 
ProcessingUnit | 
DefaultGridServiceManagers.deploy(ProcessingUnitDeployment deployment)  | 
ProcessingUnit | 
DefaultGridServiceManager.deploy(ProcessingUnitDeployment deployment,
      long timeout,
      TimeUnit timeUnit)  | 
ProcessingUnit | 
DefaultGridServiceManagers.deploy(ProcessingUnitDeployment deployment,
      long timeout,
      TimeUnit timeUnit)  | 
ProcessingUnit | 
DefaultGridServiceManager.deploy(SpaceDeployment deployment)  | 
ProcessingUnit | 
DefaultGridServiceManagers.deploy(SpaceDeployment deployment)  | 
ProcessingUnit | 
DefaultGridServiceManager.deploy(SpaceDeployment deployment,
      long timeout,
      TimeUnit timeUnit)  | 
ProcessingUnit | 
DefaultGridServiceManagers.deploy(SpaceDeployment deployment,
      long timeout,
      TimeUnit timeUnit)  | 
| Modifier and Type | Method and Description | 
|---|---|
boolean | 
DefaultGridServiceManager.decrementPlannedInstances(ProcessingUnit processingUnit)  | 
boolean | 
InternalGridServiceManager.decrementPlannedInstances(ProcessingUnit processingUnit)
Decrements a planned instance if the number of planned instances is less then the actual
 instances to maintain. 
 | 
ScaleStrategyConfig | 
DefaultGridServiceManager.getProcessingUnitScaleStrategyConfig(ProcessingUnit pu)  | 
ScaleStrategyConfig | 
InternalGridServiceManager.getProcessingUnitScaleStrategyConfig(ProcessingUnit pu)  | 
void | 
DefaultGridServiceManager.incrementInstance(ProcessingUnit processingUnit)  | 
void | 
InternalGridServiceManager.incrementInstance(ProcessingUnit processingUnit)  | 
boolean | 
DefaultGridServiceManager.isManagedByElasticServiceManager(ProcessingUnit pu)  | 
boolean | 
InternalGridServiceManager.isManagedByElasticServiceManager(ProcessingUnit pu)  | 
boolean | 
DefaultGridServiceManager.isManagedByElasticServiceManagerAndScaleNotInProgress(ProcessingUnit pu)  | 
boolean | 
InternalGridServiceManager.isManagedByElasticServiceManagerAndScaleNotInProgress(ProcessingUnit pu)  | 
void | 
DefaultGridServiceManager.setProcessingUnitElasticProperties(ProcessingUnit pu,
                                  Map<String,String> properties)  | 
void | 
InternalGridServiceManager.setProcessingUnitElasticProperties(ProcessingUnit pu,
                                  Map<String,String> properties)  | 
void | 
DefaultGridServiceManager.setProcessingUnitScaleStrategyConfig(ProcessingUnit pu,
                                    ScaleStrategyConfig scaleStrategyConfig)  | 
void | 
InternalGridServiceManager.setProcessingUnitScaleStrategyConfig(ProcessingUnit pu,
                                    ScaleStrategyConfig scaleStratefyConfig)  | 
void | 
DefaultGridServiceManager.updateProcessingUnitElasticPropertiesOnGsm(ProcessingUnit pu,
                                          Map<String,String> elasticProperties)  | 
void | 
InternalGridServiceManager.updateProcessingUnitElasticPropertiesOnGsm(ProcessingUnit pu,
                                          Map<String,String> elasticProperties)
Used as a call back by the esm to update the store of records of elastic properties on the
 actual gsm 
 | 
| Modifier and Type | Method and Description | 
|---|---|
ProcessingUnit[] | 
DefaultMachine.getProcessingUnits()  | 
| Modifier and Type | Interface and Description | 
|---|---|
interface  | 
InternalProcessingUnit  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
DefaultProcessingUnit  | 
| Modifier and Type | Method and Description | 
|---|---|
ProcessingUnit | 
DefaultProcessingUnitPartition.getProcessingUnit()  | 
ProcessingUnit | 
DefaultProcessingUnitInstance.getProcessingUnit()  | 
ProcessingUnit | 
DefaultProcessingUnits.getProcessingUnit(String name)  | 
ProcessingUnit[] | 
DefaultProcessingUnits.getProcessingUnits()  | 
ProcessingUnit | 
DefaultProcessingUnits.removeEmbeddedSpace(InternalSpace space)  | 
ProcessingUnit | 
InternalProcessingUnits.removeEmbeddedSpace(InternalSpace space)
Removes the reference to the specified space from the hosting processing unit. 
 | 
ProcessingUnit | 
DefaultProcessingUnits.waitFor(String processingUnitName)  | 
ProcessingUnit | 
DefaultProcessingUnits.waitFor(String processingUnitName,
       long timeout,
       TimeUnit timeUnit)  | 
| Modifier and Type | Method and Description | 
|---|---|
Map<String,ProcessingUnit> | 
DefaultProcessingUnits.getNames()  | 
Iterator<ProcessingUnit> | 
DefaultProcessingUnits.iterator()  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
DefaultProcessingUnits.addProcessingUnit(ProcessingUnit processingUnit)  | 
void | 
InternalProcessingUnits.addProcessingUnit(ProcessingUnit processingUnit)  | 
Integer | 
DefaultProcessingUnits.getPlannedNumberOfInstancesOfElasticPU(ProcessingUnit pu)  | 
Integer | 
InternalProcessingUnits.getPlannedNumberOfInstancesOfElasticPU(ProcessingUnit pu)  | 
void | 
DefaultAdminProcessingUnitInstances.processRemovedOnProcessingUnitRemoval(ProcessingUnit processingUnit)  | 
void | 
InternalProcessingUnitInstance.setProcessingUnit(ProcessingUnit processingUnit)  | 
void | 
DefaultProcessingUnitInstance.setProcessingUnit(ProcessingUnit processingUnit)  | 
| Constructor and Description | 
|---|
DefaultProcessingUnitPartition(ProcessingUnit processingUnit,
                              int patitionId)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
DefaultProcessingUnitAddedEventManager.processingUnitAdded(ProcessingUnit processingUnit)  | 
void | 
ClosureProcessingUnitAddedEventListener.processingUnitAdded(ProcessingUnit processingUnit)  | 
void | 
DefaultProcessingUnitRemovedEventManager.processingUnitRemoved(ProcessingUnit processingUnit)  | 
void | 
ClosureProcessingUnitRemovedEventListener.processingUnitRemoved(ProcessingUnit processingUnit)  | 
| Constructor and Description | 
|---|
DefaultBackupGridServiceManagerChangedEventManager(InternalAdmin admin,
                                                  ProcessingUnit processingUnit)  | 
DefaultProcessingUnitStatusChangedEventManager(InternalAdmin admin,
                                              ProcessingUnit processingUnit)  | 
| Modifier and Type | Method and Description | 
|---|---|
QuiesceDetails | 
ZookeeperQuiesceManager.getQuiesceDetails(ProcessingUnit processingUnit)  | 
QuiesceDetails | 
GsmQuiesceManager.getQuiesceDetails(ProcessingUnit processingUnit)  | 
QuiesceDetails | 
QuiesceManager.getQuiesceDetails(ProcessingUnit processingUnit)  | 
InternalQuiesceDetails | 
ZookeeperQuiesceManager.quiesce(ProcessingUnit processingUnit,
       QuiesceRequest request)  | 
InternalQuiesceDetails | 
GsmQuiesceManager.quiesce(ProcessingUnit processingUnit,
       QuiesceRequest request)  | 
InternalQuiesceDetails | 
QuiesceManager.quiesce(ProcessingUnit processingUnit,
       QuiesceRequest request)  | 
void | 
ZookeeperQuiesceManager.unquiesce(ProcessingUnit processingUnit,
         QuiesceRequest request)  | 
void | 
GsmQuiesceManager.unquiesce(ProcessingUnit processingUnit,
         QuiesceRequest request)  | 
void | 
QuiesceManager.unquiesce(ProcessingUnit processingUnit,
         QuiesceRequest request)  | 
| Modifier and Type | Method and Description | 
|---|---|
ProcessingUnit[] | 
Machine.getProcessingUnits()  | 
| Modifier and Type | Method and Description | 
|---|---|
ProcessingUnit | 
ProcessingUnitPartition.getProcessingUnit()
Returns the processing unit this partition is part of. 
 | 
ProcessingUnit | 
ProcessingUnitInstance.getProcessingUnit()
Returns the processing unit this processing unit instance belongs to. 
 | 
ProcessingUnit | 
ProcessingUnits.getProcessingUnit(String name)
Returns the  
ProcessingUnit for the given processing unit
 name. | 
ProcessingUnit[] | 
ProcessingUnits.getProcessingUnits()
Returns the  
ProcessingUnits currently deployed. | 
ProcessingUnit | 
ProcessingUnits.waitFor(String processingUnitName)
Waits indefinitely till the processing unit is identified as deployed. 
 | 
ProcessingUnit | 
ProcessingUnits.waitFor(String processingUnitName,
       long timeout,
       TimeUnit timeUnit)
Waits for the specified timeout (in time interval) till the processing unit is identified as
 deployed. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
Map<String,ProcessingUnit> | 
ProcessingUnits.getNames()
Returns a map of  
ProcessingUnit keyed by their respective
 names. | 
| Constructor and Description | 
|---|
ElasticStatelessReachedMaximumNumberOfInstancesEvent(ProcessingUnit pu,
                                                    int existingNumberOfInstances,
                                                    int requestedNumberOfInstances,
                                                    int maximumNumberOfInstances)
Deprecated.  
  | 
| Modifier and Type | Method and Description | 
|---|---|
ProcessingUnit | 
ProcessingUnitInstanceProvisionStatusChangedEvent.getProcessingUnit()  | 
ProcessingUnit | 
ManagingGridServiceManagerChangedEvent.getProcessingUnit()
Returns the processing unit the managing GSM was changed for. 
 | 
ProcessingUnit | 
ProcessingUnitSpaceCorrelatedEvent.getProcessingUnit()
Returns the Processing Unit the space was correlated with. 
 | 
ProcessingUnit | 
ProcessingUnitStatusChangedEvent.getProcessingUnit()
Returns the Processing Unit that the deployment status changed for. 
 | 
ProcessingUnit | 
BackupGridServiceManagerChangedEvent.getProcessingUnit()
Returns the Processing Unit that the backup GSM event occurred on. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
ProcessingUnitAddedEventListener.processingUnitAdded(ProcessingUnit processingUnit)
A callback indicating that a Processing Unit was added (deployed/discovered). 
 | 
void | 
ProcessingUnitRemovedEventListener.processingUnitRemoved(ProcessingUnit processingUnit)
A callback indicating that a Processing Unit was removed (undeployed). 
 | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
TestEventSampler.processingUnitAdded(ProcessingUnit processingUnit)  | 
void | 
TestEventSampler.processingUnitRemoved(ProcessingUnit processingUnit)  | 
| Modifier and Type | Method and Description | 
|---|---|
static String | 
GatewayUtils.extractGatewayNameIfExists(ProcessingUnit processingUnit)  | 
static ProcessingUnitInstance | 
GatewayUtils.extractInstanceIfPuOfGateway(String gatewayName,
                            ProcessingUnit processingUnit)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
ESMImpl.processingUnitAdded(ProcessingUnit pu)  | 
void | 
ESMImpl.processingUnitRemoved(ProcessingUnit pu)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
ProcessingUnitAware.setProcessingUnit(ProcessingUnit pu)  | 
| Constructor and Description | 
|---|
LogPerProcessingUnit(org.apache.commons.logging.Log logger,
                    ProcessingUnit pu)  | 
ScaleBeanServer(ProcessingUnit pu,
               ProcessingUnitSchemaConfig schemaConfig,
               RebalancingSlaEnforcement rebalancingSlaEnforcement,
               ContainersSlaEnforcement containersSlaEnforcement,
               MachinesSlaEnforcement machinesSlaEnforcement,
               AutoScalingSlaEnforcement autoScalingSlaEnforcement,
               NonBlockingElasticMachineProvisioningAdapterFactory nonBlockingAdapterFactory,
               ElasticMachineIsolationConfig isolationConfig,
               org.jini.rio.monitor.event.EventsStore eventStore,
               MachinesStateBackup machinesStateBackup)  | 
| Modifier and Type | Method and Description | 
|---|---|
AutoScalingSlaEnforcementEndpoint | 
AutoScalingSlaEnforcement.createEndpoint(ProcessingUnit pu)  | 
void | 
AutoScalingSlaEnforcement.destroyEndpoint(ProcessingUnit pu)  | 
static Object | 
AutoScalingSlaUtils.getStatisticsValue(ProcessingUnit pu,
                  Map<ProcessingUnitStatisticsId,Object> statistics,
                  ProcessingUnitStatisticsId ruleStatisticsId)
Validates that the specified statisticsId defined in the rule 
 | 
| Constructor and Description | 
|---|
DefaultAutoScalingSlaEnforcementEndpoint(ProcessingUnit pu)  | 
| Modifier and Type | Method and Description | 
|---|---|
static ProcessingUnit | 
ContainersSlaUtils.findProcessingUnitWithSameName(Set<ProcessingUnit> processingUnits,
                              ProcessingUnit pu)  | 
static ProcessingUnit | 
ContainersSlaUtils.findProcessingUnitWithSameZone(Set<ProcessingUnit> processingUnits,
                              ProcessingUnit pu)  | 
| Modifier and Type | Method and Description | 
|---|---|
ContainersSlaEnforcementEndpoint | 
ContainersSlaEnforcement.createEndpoint(ProcessingUnit pu)  | 
void | 
ContainersSlaEnforcement.destroyEndpoint(ProcessingUnit pu)  | 
static ProcessingUnit | 
ContainersSlaUtils.findProcessingUnitWithSameName(Set<ProcessingUnit> processingUnits,
                              ProcessingUnit pu)  | 
static ProcessingUnit | 
ContainersSlaUtils.findProcessingUnitWithSameZone(Set<ProcessingUnit> processingUnits,
                              ProcessingUnit pu)  | 
static String | 
ContainersSlaUtils.getContainerZone(ProcessingUnit pu)  | 
static String | 
ContainersSlaUtils.gscToStringWithPuInstance(GridServiceContainer container,
                         ProcessingUnit pu)  | 
| Modifier and Type | Method and Description | 
|---|---|
static ProcessingUnit | 
ContainersSlaUtils.findProcessingUnitWithSameName(Set<ProcessingUnit> processingUnits,
                              ProcessingUnit pu)  | 
static ProcessingUnit | 
ContainersSlaUtils.findProcessingUnitWithSameZone(Set<ProcessingUnit> processingUnits,
                              ProcessingUnit pu)  | 
| Constructor and Description | 
|---|
ContainerNotDiscoveredException(ProcessingUnit pu,
                               GridServiceContainer container)  | 
ContainersSlaEnforcementInProgressException(ProcessingUnit pu,
                                           String message)  | 
ContainersSlaEnforcementInProgressException(ProcessingUnit pu,
                                           String message,
                                           Exception reason)  | 
ContainersSlaEnforcementPendingProcessingUnitDeallocationException(ProcessingUnit pu,
                                                                  Collection<GridServiceContainer> containers)  | 
FailedToStartNewGridServiceContainersException(Machine machine,
                                              ProcessingUnit pu,
                                              Exception reason)  | 
| Modifier and Type | Method and Description | 
|---|---|
Map<GridServiceAgent,Map<ProcessingUnit,CapacityRequirements>> | 
MachinesSlaEnforcementState.groupCapacityPerProcessingUnitPerAgent(MachinesSlaEnforcementState.StateKey key)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
MachinesSlaEnforcementEndpoint.afterUndeployedProcessingUnit(ProcessingUnit pu)
Erases all Allocated (state) that is related to the specified processing unit. 
 | 
void | 
MachinesSlaEnforcementState.afterUndeployProcessingUnit(ProcessingUnit pu)
Removes all state related to the specified processing unit Call this method only if you are
 not going to call any other state method on this pu 
 | 
void | 
MachinesSlaEnforcementEndpoint.beforeUndeployedProcessingUnit(ProcessingUnit pu)
Marks that the processing unit is being undeployed. 
 | 
void | 
MachinesSlaEnforcementState.beforeUndeployProcessingUnit(ProcessingUnit pu)  | 
void | 
MachinesSlaEnforcementEndpoint.cleanupCloud(ProcessingUnit pu,
            NonBlockingElasticMachineProvisioning machineProvisioning)
Erases all Allocated (state) that is related to the specified processing unit. 
 | 
MachinesSlaEnforcementEndpoint | 
MachinesSlaEnforcement.createEndpoint(ProcessingUnit pu)  | 
void | 
MachinesSlaEnforcement.destroyEndpoint(ProcessingUnit pu)  | 
void | 
MachinesSlaEnforcementState.failedRecoveredStateOnEsmStart(ProcessingUnit otherPu)  | 
void | 
MachinesSlaEnforcement.failedRecoveredStateOnEsmStart(ProcessingUnit pu)  | 
CapacityRequirementsPerAgent | 
MachinesSlaEnforcementState.getAllocatedCapacity(ProcessingUnit otherPu)  | 
FutureCleanupCloudResources | 
MachinesSlaEnforcementState.getCleanupFuture(ProcessingUnit pu)  | 
Set<ZonesConfig> | 
MachinesSlaEnforcementState.getGridServiceAgentsZones(ProcessingUnit pu)  | 
static int | 
MachinesSlaUtils.getNumberOfChildContainersForProcessingUnit(GridServiceAgent agent,
                                           ProcessingUnit pu)  | 
MachinesSlaEnforcementState.RecoveryState | 
MachinesSlaEnforcementState.getRecoveredStateOnEsmStart(ProcessingUnit pu)  | 
MachinesSlaEnforcementState.RecoveryState | 
MachinesSlaEnforcementEndpoint.getRecoveredStateOnEsmStart(ProcessingUnit processingUnit)  | 
Map<MachinesSlaEnforcementState.StateKey,org.openspaces.grid.gsm.machines.MachinesSlaEnforcementState.StateValue> | 
MachinesSlaEnforcementState.getStateForProcessingUnit(ProcessingUnit pu)  | 
Set<ZonesConfig> | 
MachinesSlaEnforcementState.getUndeployedGridServiceAgentsZones(ProcessingUnit pu)  | 
boolean | 
MachinesSlaEnforcementState.isAgentSharedWithOtherProcessingUnits(ProcessingUnit pu,
                                     String agentUid)  | 
boolean | 
MachinesSlaEnforcementState.isHoldingStateForProcessingUnit(ProcessingUnit pu)  | 
void | 
MachinesSlaEnforcementState.recoveredStateOnEsmStart(ProcessingUnit otherPu)  | 
void | 
MachinesSlaEnforcementEndpoint.recoveredStateOnEsmStart(ProcessingUnit processingUnit)
Mark that the specified processing unit has recovered state. 
 | 
void | 
MachinesSlaEnforcementState.setCleanupFuture(ProcessingUnit pu,
                FutureCleanupCloudResources future)  | 
void | 
MachinesSlaEnforcementState.validateUndeployNotInProgress(ProcessingUnit pu)  | 
| Constructor and Description | 
|---|
StateKey(ProcessingUnit pu,
        ZonesConfig gridServiceAgentZones)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
MachinesStateBackupToSpace.recoverAndStartBackup(ProcessingUnit pu)  | 
void | 
MachinesStateBackupStub.recoverAndStartBackup(ProcessingUnit pu)  | 
void | 
MachinesStateBackup.recoverAndStartBackup(ProcessingUnit pu)  | 
void | 
MachinesStateBackupToSpace.validateBackupCompleted(ProcessingUnit pu)  | 
void | 
MachinesStateBackupStub.validateBackupCompleted(ProcessingUnit pu)  | 
void | 
MachinesStateBackup.validateBackupCompleted(ProcessingUnit pu)  | 
| Constructor and Description | 
|---|
MachinesStateBackupFailureException(ProcessingUnit pu,
                                   Throwable cause)  | 
MachinesStateBackupInProgressException(ProcessingUnit pu)  | 
MachinesStateRecoveryFailureException(ProcessingUnit pu,
                                     Exception t)  | 
MachinesStateRecoveryInProgressException(ProcessingUnit pu)  | 
| Constructor and Description | 
|---|
SomeProcessingUnitsHaveNotCompletedStateRecoveryException(ProcessingUnit pu,
                                                         List<ProcessingUnit> pusNotCompletedStateRecovery)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
DiscoveredMachineProvisioningBean.setProcessingUnit(ProcessingUnit pu)  | 
| Modifier and Type | Method and Description | 
|---|---|
ProcessingUnit | 
FutureStatefulProcessingUnitInstance.getProcessingUnit()  | 
ProcessingUnit | 
FutureStatelessProcessingUnitInstance.getProcessingUnit()  | 
| Modifier and Type | Method and Description | 
|---|---|
ENDPOINT | 
ServiceLevelAgreementEnforcement.createEndpoint(ProcessingUnit pu)
Creates a new endpoint for the specified pu, if one does not already exist. 
 | 
void | 
ServiceLevelAgreementEnforcement.destroyEndpoint(ProcessingUnit pu)
Destroys the endpoint for the specified pu. 
 | 
| Constructor and Description | 
|---|
BlockingAfterPropertiesSetFailedException(ProcessingUnit pu,
                                         Throwable cause)  | 
BlockingAfterPropertiesSetInProgressException(ProcessingUnit pu)  | 
DisconnectedFromLookupServiceException(ProcessingUnit pu,
                                      LookupLocator[] locators,
                                      String[] groups)  | 
SlaEnforcementInProgressException(ProcessingUnit pu,
                                 String message)  | 
SlaEnforcementInProgressException(ProcessingUnit pu,
                                 String message,
                                 Throwable cause)  | 
| Modifier and Type | Method and Description | 
|---|---|
protected MachinesSlaEnforcementState.RecoveryState | 
AbstractCapacityScaleStrategyBean.getRecoveredStateOnEsmStart(ProcessingUnit otherPu)  | 
protected MachinesSlaEnforcementState.RecoveryState | 
EagerScaleStrategyBean.getRecoveredStateOnEsmStart(ProcessingUnit otherPu)  | 
protected MachinesSlaEnforcementState.RecoveryState | 
UndeployScaleStrategyBean.getRecoveredStateOnEsmStart(ProcessingUnit otherPu)  | 
protected abstract MachinesSlaEnforcementState.RecoveryState | 
AbstractScaleStrategyBean.getRecoveredStateOnEsmStart(ProcessingUnit otherPu)  | 
void | 
AbstractScaleStrategyBean.setProcessingUnit(ProcessingUnit pu)  | 
| Constructor and Description | 
|---|
ElasticMachineProvisioningDiscoveredMachinesCache(ProcessingUnit pu,
                                                 NonBlockingElasticMachineProvisioning machineProvisioning,
                                                 boolean quiteMode,
                                                 long pollingIntervalSeconds)
Deprecated.  
Quite mode fall backs to the admin API (lookup discovery) in case of exceptions from the
 machine provisioning 
 | 
Copyright © GigaSpaces.