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 |
GridServiceManager.deploy(ElasticSpaceDeployment deployment)
Deploys an elastic 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(ElasticSpaceDeployment deployment)
Deploys an elastic 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 |
GridServiceManager.deploy(ElasticSpaceDeployment deployment,
long timeout,
TimeUnit timeUnit)
Deploys an elastic 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(ElasticSpaceDeployment deployment,
long timeout,
TimeUnit timeUnit)
Deploys an elastic 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 |
GridServiceManager.deploy(ElasticStatefulProcessingUnitDeployment deployment)
Deploys an elastic processing unit that has an embedded space 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(ElasticStatefulProcessingUnitDeployment deployment)
Deploys an elastic processing unit that has an embedded space 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 |
GridServiceManager.deploy(ElasticStatefulProcessingUnitDeployment deployment,
long timeout,
TimeUnit timeUnit)
Deploys an elastic processing unit that has an embedded space 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(ElasticStatefulProcessingUnitDeployment deployment,
long timeout,
TimeUnit timeUnit)
Deploys an elastic processing unit that has an embedded space 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 |
GridServiceManager.deploy(ElasticStatelessProcessingUnitDeployment deployment)
Deploys an elastic processing unit that does not have an embedded space 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(ElasticStatelessProcessingUnitDeployment deployment)
Deploys an elastic processing unit that does not have an embedded space 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 |
GridServiceManager.deploy(ElasticStatelessProcessingUnitDeployment deployment,
long timeout,
TimeUnit timeUnit)
Deploys an elastic processing unit that does not have an embedded space 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(ElasticStatelessProcessingUnitDeployment deployment,
long timeout,
TimeUnit timeUnit)
Deploys an elastic processing unit that does not have an embedded space 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 |
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)
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 |
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(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 |
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)
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(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(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)
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).
|
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).
|
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 |
InternalApplications.addApplication(Application application,
ProcessingUnit processingUnit) |
void |
DefaultApplications.addApplication(Application application,
ProcessingUnit processingUnit) |
void |
InternalApplications.removeProcessingUnit(ProcessingUnit processingUnit) |
void |
DefaultApplications.removeProcessingUnit(ProcessingUnit processingUnit) |
Modifier and Type | Method and Description |
---|---|
ProcessingUnit |
DefaultGatewayProcessingUnit.getProcessingUnit() |
Modifier and Type | Method and Description |
---|---|
ProcessingUnit |
DefaultGridServiceManagers.deploy(Application application,
ProcessingUnitDeploymentTopology puDeploymentTopology,
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 |
InternalGridServiceManagers.deploy(Application application,
ProcessingUnitDeploymentTopology puDeployment,
long timeout,
TimeUnit timeUnit) |
ProcessingUnit |
DefaultGridServiceManagers.deploy(ElasticSpaceDeployment deployment) |
ProcessingUnit |
DefaultGridServiceManager.deploy(ElasticSpaceDeployment deployment) |
ProcessingUnit |
DefaultGridServiceManagers.deploy(ElasticSpaceDeployment deployment,
long timeout,
TimeUnit timeUnit) |
ProcessingUnit |
DefaultGridServiceManager.deploy(ElasticSpaceDeployment deployment,
long timeout,
TimeUnit timeUnit) |
ProcessingUnit |
DefaultGridServiceManagers.deploy(ElasticStatefulProcessingUnitDeployment deployment) |
ProcessingUnit |
DefaultGridServiceManager.deploy(ElasticStatefulProcessingUnitDeployment deployment) |
ProcessingUnit |
DefaultGridServiceManagers.deploy(ElasticStatefulProcessingUnitDeployment deployment,
long timeout,
TimeUnit timeUnit) |
ProcessingUnit |
DefaultGridServiceManager.deploy(ElasticStatefulProcessingUnitDeployment deployment,
long timeout,
TimeUnit timeUnit) |
ProcessingUnit |
DefaultGridServiceManagers.deploy(ElasticStatelessProcessingUnitDeployment deployment) |
ProcessingUnit |
DefaultGridServiceManager.deploy(ElasticStatelessProcessingUnitDeployment deployment) |
ProcessingUnit |
DefaultGridServiceManagers.deploy(ElasticStatelessProcessingUnitDeployment deployment,
long timeout,
TimeUnit timeUnit) |
ProcessingUnit |
DefaultGridServiceManager.deploy(ElasticStatelessProcessingUnitDeployment deployment,
long timeout,
TimeUnit timeUnit) |
ProcessingUnit |
DefaultGridServiceManagers.deploy(MemcachedDeployment deployment) |
ProcessingUnit |
DefaultGridServiceManager.deploy(MemcachedDeployment deployment) |
ProcessingUnit |
DefaultGridServiceManagers.deploy(MemcachedDeployment deployment,
long timeout,
TimeUnit timeUnit) |
ProcessingUnit |
DefaultGridServiceManager.deploy(MemcachedDeployment deployment,
long timeout,
TimeUnit timeUnit) |
ProcessingUnit |
DefaultGridServiceManager.deploy(ProcessingUnitConfigHolder puConfigHolder) |
ProcessingUnit |
DefaultGridServiceManager.deploy(ProcessingUnitConfigHolder puConfigHolder,
long timeout,
TimeUnit timeUnit) |
ProcessingUnit |
DefaultGridServiceManagers.deploy(ProcessingUnitDeployment deployment) |
ProcessingUnit |
DefaultGridServiceManager.deploy(ProcessingUnitDeployment deployment) |
ProcessingUnit |
DefaultGridServiceManagers.deploy(ProcessingUnitDeployment deployment,
long timeout,
TimeUnit timeUnit) |
ProcessingUnit |
DefaultGridServiceManager.deploy(ProcessingUnitDeployment deployment,
long timeout,
TimeUnit timeUnit) |
ProcessingUnit |
DefaultGridServiceManagers.deploy(SpaceDeployment deployment) |
ProcessingUnit |
DefaultGridServiceManager.deploy(SpaceDeployment deployment) |
ProcessingUnit |
DefaultGridServiceManagers.deploy(SpaceDeployment deployment,
long timeout,
TimeUnit timeUnit) |
ProcessingUnit |
DefaultGridServiceManager.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 |
DefaultGridServiceManagers.undeployProcessingUnitsAndWait(ProcessingUnit[] processingUnits,
long timeout,
TimeUnit timeUnit) |
boolean |
DefaultGridServiceManager.undeployProcessingUnitsAndWait(ProcessingUnit[] processingUnits,
long timeout,
TimeUnit timeUnit) |
boolean |
InternalGridServiceManager.undeployProcessingUnitsAndWait(ProcessingUnit[] processingUnits,
long timeout,
TimeUnit timeUnit) |
boolean |
InternalGridServiceManagers.undeployProcessingUnitsAndWait(ProcessingUnit[] processingUnits,
long remaining,
TimeUnit milliseconds) |
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 |
DefaultProcessingUnitInstance.getProcessingUnit() |
ProcessingUnit |
DefaultProcessingUnitPartition.getProcessingUnit() |
ProcessingUnit |
DefaultProcessingUnits.getProcessingUnit(String name) |
ProcessingUnit[] |
DefaultProcessingUnits.getProcessingUnits() |
ProcessingUnit |
InternalProcessingUnits.removeEmbeddedSpace(InternalSpace space)
Removes the reference to the specified space from the hosting processing unit.
|
ProcessingUnit |
DefaultProcessingUnits.removeEmbeddedSpace(InternalSpace space) |
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 |
InternalProcessingUnits.addProcessingUnit(ProcessingUnit processingUnit) |
void |
DefaultProcessingUnits.addProcessingUnit(ProcessingUnit processingUnit) |
Integer |
InternalProcessingUnits.getPlannedNumberOfInstancesOfElasticPU(ProcessingUnit pu) |
Integer |
DefaultProcessingUnits.getPlannedNumberOfInstancesOfElasticPU(ProcessingUnit pu) |
void |
DefaultProcessingUnitInstance.setProcessingUnit(ProcessingUnit processingUnit) |
void |
InternalProcessingUnitInstance.setProcessingUnit(ProcessingUnit processingUnit) |
Constructor and Description |
---|
DefaultProcessingUnitPartition(ProcessingUnit processingUnit,
int patitionId) |
Modifier and Type | Method and Description |
---|---|
void |
ClosureProcessingUnitAddedEventListener.processingUnitAdded(ProcessingUnit processingUnit) |
void |
DefaultProcessingUnitAddedEventManager.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) |
Modifier and Type | Method and Description |
---|---|
ProcessingUnit |
ProcessingUnitSpaceCorrelatedEvent.getProcessingUnit()
Returns the Processing Unit the space was correlated with.
|
ProcessingUnit |
BackupGridServiceManagerChangedEvent.getProcessingUnit()
Returns the Processing Unit that the backup GSM event occurred on.
|
ProcessingUnit |
ProcessingUnitStatusChangedEvent.getProcessingUnit()
Returns the Processing Unit that the deployment status changed for.
|
ProcessingUnit |
ManagingGridServiceManagerChangedEvent.getProcessingUnit()
Returns the processing unit the managing GSM was changed for.
|
ProcessingUnit |
ProcessingUnitInstanceProvisionStatusChangedEvent.getProcessingUnit() |
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) |
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 |
MachinesSlaEnforcement.failedRecoveredStateOnEsmStart(ProcessingUnit pu) |
void |
MachinesSlaEnforcementState.failedRecoveredStateOnEsmStart(ProcessingUnit otherPu) |
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 |
MachinesSlaEnforcementEndpoint.getRecoveredStateOnEsmStart(ProcessingUnit processingUnit) |
MachinesSlaEnforcementState.RecoveryState |
MachinesSlaEnforcementState.getRecoveredStateOnEsmStart(ProcessingUnit pu) |
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 |
MachinesSlaEnforcementEndpoint.recoveredStateOnEsmStart(ProcessingUnit processingUnit)
Mark that the specified processing unit has recovered state.
|
void |
MachinesSlaEnforcementState.recoveredStateOnEsmStart(ProcessingUnit otherPu) |
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 |
MachinesStateBackupStub.recoverAndStartBackup(ProcessingUnit pu) |
void |
MachinesStateBackup.recoverAndStartBackup(ProcessingUnit pu) |
void |
MachinesStateBackupToSpace.recoverAndStartBackup(ProcessingUnit pu) |
void |
MachinesStateBackupStub.validateBackupCompleted(ProcessingUnit pu) |
void |
MachinesStateBackup.validateBackupCompleted(ProcessingUnit pu) |
void |
MachinesStateBackupToSpace.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 |
FutureStatelessProcessingUnitInstance.getProcessingUnit() |
ProcessingUnit |
FutureStatefulProcessingUnitInstance.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 |
UndeployScaleStrategyBean.getRecoveredStateOnEsmStart(ProcessingUnit otherPu) |
protected abstract MachinesSlaEnforcementState.RecoveryState |
AbstractScaleStrategyBean.getRecoveredStateOnEsmStart(ProcessingUnit otherPu) |
protected MachinesSlaEnforcementState.RecoveryState |
AbstractCapacityScaleStrategyBean.getRecoveredStateOnEsmStart(ProcessingUnit otherPu) |
protected MachinesSlaEnforcementState.RecoveryState |
EagerScaleStrategyBean.getRecoveredStateOnEsmStart(ProcessingUnit otherPu) |
void |
AbstractScaleStrategyBean.setProcessingUnit(ProcessingUnit pu) |
Constructor and Description |
---|
ElasticMachineProvisioningDiscoveredMachinesCache(ProcessingUnit pu,
NonBlockingElasticMachineProvisioning machineProvisioning,
boolean quiteMode,
long pollingIntervalSeconds)
Quite mode fall backs to the admin API (lookup discovery) in case of exceptions from the
machine provisioning
|
Copyright © GigaSpaces.