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 |
---|---|
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 |
DefaultGatewayProcessingUnit.getProcessingUnit() |
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) |
QuiesceDetails |
DefaultGridServiceManager.getQuiesceDetails(ProcessingUnit processingUnit) |
QuiesceDetails |
InternalGridServiceManager.getQuiesceDetails(ProcessingUnit processingUnit) |
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) |
InternalQuiesceDetails |
DefaultGridServiceManager.quiesce(ProcessingUnit processingUnit,
QuiesceRequest request) |
InternalQuiesceDetails |
InternalGridServiceManager.quiesce(ProcessingUnit processingUnit,
QuiesceRequest request) |
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) |
boolean |
InternalGridServiceManagers.undeployProcessingUnitsAndWait(ProcessingUnit[] processingUnits,
long remaining,
TimeUnit milliseconds) |
boolean |
DefaultGridServiceManager.undeployProcessingUnitsAndWait(ProcessingUnit[] processingUnits,
long timeout,
TimeUnit timeUnit) |
boolean |
InternalGridServiceManager.undeployProcessingUnitsAndWait(ProcessingUnit[] processingUnits,
long timeout,
TimeUnit timeUnit) |
boolean |
DefaultGridServiceManagers.undeployProcessingUnitsAndWait(ProcessingUnit[] processingUnits,
long timeout,
TimeUnit timeUnit) |
void |
DefaultGridServiceManager.unquiesce(ProcessingUnit processingUnit,
QuiesceRequest request) |
void |
InternalGridServiceManager.unquiesce(ProcessingUnit processingUnit,
QuiesceRequest request) |
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 |
---|---|
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
ProcessingUnit s 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.