Uses of Interface
org.openspaces.admin.pu.ProcessingUnit

Packages that use ProcessingUnit

org.openspaces.admin.application
org.openspaces.admin.gateway
org.openspaces.admin.gsm	Support for managing of Grid Service Manager(s) through the Admin API.
org.openspaces.admin.pu	Support for managing of Processing Unit(s) through the Admin API.
org.openspaces.admin.pu.elastic.events
org.openspaces.admin.pu.events	Support for managing of Processing Unit events through the Admin API.
org.openspaces.admin.samples
org.openspaces.core.gateway
org.openspaces.grid.esm
org.openspaces.grid.gsm
org.openspaces.grid.gsm.autoscaling
org.openspaces.grid.gsm.autoscaling.exceptions
org.openspaces.grid.gsm.containers
org.openspaces.grid.gsm.containers.exceptions
org.openspaces.grid.gsm.machines
org.openspaces.grid.gsm.machines.backup
org.openspaces.grid.gsm.machines.exceptions
org.openspaces.grid.gsm.machines.plugins.discovered
org.openspaces.grid.gsm.rebalancing
org.openspaces.grid.gsm.rebalancing.exceptions
org.openspaces.grid.gsm.sla
org.openspaces.grid.gsm.sla.exceptions
org.openspaces.grid.gsm.strategy

Uses of ProcessingUnit in org.openspaces.admin.application

Methods in org.openspaces.admin.application that return ProcessingUnit

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

Uses of ProcessingUnit in org.openspaces.admin.gateway

Methods in org.openspaces.admin.gateway that return ProcessingUnit

ProcessingUnit

GatewayProcessingUnit.getProcessingUnit() Returns the hosting ProcessingUnit.

Uses of ProcessingUnit in org.openspaces.admin.gsm

Methods in org.openspaces.admin.gsm that return ProcessingUnit

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 The deployment process will wait for the given timeout and return the actual processing unit that can be used.
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).

Uses of ProcessingUnit in org.openspaces.admin.pu

Methods in org.openspaces.admin.pu that return ProcessingUnit

ProcessingUnit	ProcessingUnitInstance.getProcessingUnit() Returns the processing unit this processing unit instance belongs to.
ProcessingUnit	ProcessingUnitPartition.getProcessingUnit() Returns the processing unit this partition is part of.
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.

Methods in org.openspaces.admin.pu that return types with arguments of type ProcessingUnit

Map<String,ProcessingUnit>

ProcessingUnits.getNames() Returns a map of ProcessingUnit keyed by their respective names.

Uses of ProcessingUnit in org.openspaces.admin.pu.elastic.events

Constructors in org.openspaces.admin.pu.elastic.events with parameters of type ProcessingUnit

ElasticStatelessReachedMaximumNumberOfInstancesEvent(ProcessingUnit pu, int existingNumberOfInstances, int requestedNumberOfInstances, int maximumNumberOfInstances)

Uses of ProcessingUnit in org.openspaces.admin.pu.events

Methods in org.openspaces.admin.pu.events that return ProcessingUnit

ProcessingUnit	BackupGridServiceManagerChangedEvent.getProcessingUnit() Returns the Processing Unit that the backup GSM event occurred on.
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	ProcessingUnitInstanceProvisionStatusChangedEvent.getProcessingUnit()
ProcessingUnit	ProcessingUnitStatusChangedEvent.getProcessingUnit() Returns the Processing Unit that the deployment status changed for.

Methods in org.openspaces.admin.pu.events with parameters of type ProcessingUnit

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).

Constructors in org.openspaces.admin.pu.events with parameters of type ProcessingUnit

BackupGridServiceManagerChangedEvent(ProcessingUnit processingUnit, BackupGridServiceManagerChangedEvent.Type type, GridServiceManager gridServiceManager)

ManagingGridServiceManagerChangedEvent(ProcessingUnit processingUnit, GridServiceManager newGridServiceManager, GridServiceManager previousGridServiceManager)

ProcessingUnitInstanceProvisionStatusChangedEvent(ProcessingUnit processingUnit, String processingUnitInstanceName, ProvisionStatus previousStatus, ProvisionStatus newStatus, GridServiceContainer gridServiceContainer, ProcessingUnitInstance processingUnitInstance)

ProcessingUnitInstanceProvisionStatusChangedEvent(ProcessingUnit processingUnit, String processingUnitInstanceName, ProvisionStatus previousStatus, ProvisionStatus newStatus, String gscServiceId)

ProcessingUnitSpaceCorrelatedEvent(Space space, ProcessingUnit processingUnit)

ProcessingUnitStatusChangedEvent(ProcessingUnit processingUnit, DeploymentStatus previousStatus, DeploymentStatus newStatus)

Uses of ProcessingUnit in org.openspaces.admin.samples

Methods in org.openspaces.admin.samples with parameters of type ProcessingUnit

void	TestEventSampler.processingUnitAdded(ProcessingUnit processingUnit)
void	TestEventSampler.processingUnitRemoved(ProcessingUnit processingUnit)

Uses of ProcessingUnit in org.openspaces.core.gateway

Methods in org.openspaces.core.gateway with parameters of type ProcessingUnit

static String	GatewayUtils.extractGatewayNameIfExists(ProcessingUnit processingUnit)
static ProcessingUnitInstance	GatewayUtils.extractInstanceIfPuOfGateway(String gatewayName, ProcessingUnit processingUnit)

Uses of ProcessingUnit in org.openspaces.grid.esm

Methods in org.openspaces.grid.esm with parameters of type ProcessingUnit

void	ESMImpl.processingUnitAdded(ProcessingUnit pu)
void	ESMImpl.processingUnitRemoved(ProcessingUnit pu)

Uses of ProcessingUnit in org.openspaces.grid.gsm

Methods in org.openspaces.grid.gsm with parameters of type ProcessingUnit

void	ProcessingUnitAware.setProcessingUnit(ProcessingUnit pu)

Constructors in org.openspaces.grid.gsm with parameters of type ProcessingUnit

LogPerProcessingUnit(Log logger, ProcessingUnit pu)

ScaleBeanServer(ProcessingUnit pu, org.openspaces.admin.internal.pu.elastic.ProcessingUnitSchemaConfig schemaConfig, RebalancingSlaEnforcement rebalancingSlaEnforcement, ContainersSlaEnforcement containersSlaEnforcement, MachinesSlaEnforcement machinesSlaEnforcement, AutoScalingSlaEnforcement autoScalingSlaEnforcement, NonBlockingElasticMachineProvisioningAdapterFactory nonBlockingAdapterFactory, org.openspaces.admin.internal.pu.elastic.ElasticMachineIsolationConfig isolationConfig, org.jini.rio.monitor.event.EventsStore eventStore, MachinesStateBackup machinesStateBackup, GigaSpace managementSpace)

Uses of ProcessingUnit in org.openspaces.grid.gsm.autoscaling

Methods in org.openspaces.grid.gsm.autoscaling with parameters of type ProcessingUnit

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

Constructors in org.openspaces.grid.gsm.autoscaling with parameters of type ProcessingUnit

DefaultAutoScalingSlaEnforcementEndpoint(ProcessingUnit pu)

Uses of ProcessingUnit in org.openspaces.grid.gsm.autoscaling.exceptions

Constructors in org.openspaces.grid.gsm.autoscaling.exceptions with parameters of type ProcessingUnit

AutoScalingConfigConflictException(ProcessingUnit pu, CapacityRequirements minimum, CapacityRequirements maximum, Set<String> zones, CapacityRequirementsPerZones lastEnforcedCapacityPerZones, CapacityRequirementsPerZones newCapacityRequirementsPerZones)

AutoScalingHighThresholdBreachedException(ProcessingUnit pu, CapacityRequirements actual, CapacityRequirements newPlan, long containerCapacityInMB, AutomaticCapacityScaleRuleConfig rule, String metricValue)

AutoScalingLowThresholdBreachedException(ProcessingUnit pu, CapacityRequirements actual, CapacityRequirements newPlan, long containerCapacityInMB, AutomaticCapacityScaleRuleConfig rule, String metricValue)

AutoScalingSlaEnforcementInProgressException(ProcessingUnit pu, String message)

AutoScalingSlaEnforcementInProgressException(ProcessingUnit pu, String message, Throwable reason)

AutoScalingStatisticsException(ProcessingUnit pu, ProcessingUnitStatisticsId statisticsId)

AutoScalingStatisticsException(ProcessingUnit pu, String message)

AutoScalingStatisticsException(ProcessingUnit pu, String message, Throwable reason)

AutoScalingStatisticsFormatException(ProcessingUnit pu, Object value, Object threshold, NumberFormatException e)

AutoScalingTemporarilyDisabledCooldownException(ProcessingUnit pu, long timeLeftMillis)

AutoScalingThresholdBreachedException(String message, ProcessingUnit pu, CapacityRequirements actual, CapacityRequirements newPlan, long containerCapacityInMB, AutomaticCapacityScaleRuleConfig rule, boolean highThresholdBreached, String metricValue)

PerZoneAutoScalingSlaEnforcementInProgressException(ProcessingUnit pu, String message)

ReachedMaximumCapacityAutoScalingException(ProcessingUnit pu, CapacityRequirements existingCapacity, CapacityRequirements newCapacity, CapacityRequirements maxCapacity, long containerCapacityInMB)

Uses of ProcessingUnit in org.openspaces.grid.gsm.containers

Methods in org.openspaces.grid.gsm.containers that return ProcessingUnit

static ProcessingUnit	ContainersSlaUtils.findProcessingUnitWithSameName(Set<ProcessingUnit> processingUnits, ProcessingUnit pu)
static ProcessingUnit	ContainersSlaUtils.findProcessingUnitWithSameZone(Set<ProcessingUnit> processingUnits, ProcessingUnit pu)

Methods in org.openspaces.grid.gsm.containers with parameters of type ProcessingUnit

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)

Method parameters in org.openspaces.grid.gsm.containers with type arguments of type ProcessingUnit

static ProcessingUnit	ContainersSlaUtils.findProcessingUnitWithSameName(Set<ProcessingUnit> processingUnits, ProcessingUnit pu)
static ProcessingUnit	ContainersSlaUtils.findProcessingUnitWithSameZone(Set<ProcessingUnit> processingUnits, ProcessingUnit pu)

Uses of ProcessingUnit in org.openspaces.grid.gsm.containers.exceptions

Constructors in org.openspaces.grid.gsm.containers.exceptions with parameters of type ProcessingUnit

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)

Uses of ProcessingUnit in org.openspaces.grid.gsm.machines

Methods in org.openspaces.grid.gsm.machines that return types with arguments of type ProcessingUnit

Map<GridServiceAgent,Map<ProcessingUnit,CapacityRequirements>>

MachinesSlaEnforcementState.groupCapacityPerProcessingUnitPerAgent(MachinesSlaEnforcementState.StateKey key)

Methods in org.openspaces.grid.gsm.machines with parameters of type ProcessingUnit

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	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)

Constructors in org.openspaces.grid.gsm.machines with parameters of type ProcessingUnit

MachinesSlaEnforcementState.StateKey(ProcessingUnit pu, ZonesConfig gridServiceAgentZones)

Uses of ProcessingUnit in org.openspaces.grid.gsm.machines.backup

Methods in org.openspaces.grid.gsm.machines.backup with parameters of type ProcessingUnit

void	MachinesStateBackupStub.recoverAndStartBackup(ProcessingUnit pu)
void	MachinesStateBackupToSpace.recoverAndStartBackup(ProcessingUnit pu)
void	MachinesStateBackup.recoverAndStartBackup(ProcessingUnit pu)
void	MachinesStateBackupStub.validateBackupCompleted(ProcessingUnit pu)
void	MachinesStateBackupToSpace.validateBackupCompleted(ProcessingUnit pu)
void	MachinesStateBackup.validateBackupCompleted(ProcessingUnit pu)

Constructors in org.openspaces.grid.gsm.machines.backup with parameters of type ProcessingUnit

MachinesStateBackupFailureException(ProcessingUnit pu, Throwable cause)

MachinesStateBackupInProgressException(ProcessingUnit pu)

MachinesStateRecoveryFailureException(ProcessingUnit pu, Exception t)

MachinesStateRecoveryInProgressException(ProcessingUnit pu)

Uses of ProcessingUnit in org.openspaces.grid.gsm.machines.exceptions

Constructors in org.openspaces.grid.gsm.machines.exceptions with parameters of type ProcessingUnit

CannotDetermineIfNeedToStartMoreMachinesException(ProcessingUnit pu, int machineShortage)

CloudCleanupFailedException(ProcessingUnit pu, Exception cause)

DelayingScaleInUntilAllMachinesHaveStartedException(ProcessingUnit pu)

DiscoveredTwoAgentsWithTheSameIpAddress(ProcessingUnit pu, String ipAddress, String agentUid1, String agentUid2)

ExpectedMachineWithMoreMemoryException(ProcessingUnit pu, Exception cause)

ExpectedMachineWithMoreMemoryException(ProcessingUnit pu, Machine machine, long totalMB, long reservedMB, long containerMB)

FailedGridServiceAgentReconnectedException(ProcessingUnit pu, GridServiceAgent newAgent, FailedGridServiceAgent failedAgent, GridServiceAgent reconnectedFailedAgent)

FailedToDiscoverMachinesException(ProcessingUnit pu, Exception cause)

FailedToStartNewGridServiceAgentException(ProcessingUnit pu, Exception cause)

FailedToStartNewMachineException(ProcessingUnit pu, Exception cause)

FailedToStopGridServiceAgentException(ProcessingUnit pu, GridServiceAgent agent, Exception cause)

FailedToStopMachineException(ProcessingUnit pu, GridServiceAgent agent, Exception exception)

GridServiceAgentSlaEnforcementInProgressException(ProcessingUnit pu, String message)

GridServiceAgentSlaEnforcementInProgressException(ProcessingUnit pu, String message, Throwable cause)

GridServiceAgentSlaEnforcementPendingContainerDeallocationException(ProcessingUnit pu, CapacityRequirementsPerAgent clusterCapacityRequirements)

InconsistentMachineProvisioningException(ProcessingUnit pu, Collection<GridServiceAgent> undiscoveredAgents)

InconsistentMachineProvisioningException(ProcessingUnit pu, GridServiceAgent undiscoveredAgents)

MachineFailureHandlingFailedException(ProcessingUnit pu, Exception cause)

MachinesSlaEnforcementInProgressException(ProcessingUnit pu)

MachinesSlaEnforcementInProgressException(ProcessingUnit pu, String message)

MachinesSlaEnforcementInProgressException(ProcessingUnit pu, String message, Exception cause)

MachinesSlaHasChangedException(ProcessingUnit pu, ZonesConfig zones, CapacityRequirements oldCapacity, CapacityRequirementsPerAgent allocatedCapacity)

NeedToStartMoreGridServiceAgentsException(AbstractMachinesSlaPolicy sla, MachinesSlaEnforcementState state, CapacityRequirements capacityShortage, ProcessingUnit pu)

NeedToWaitUntilAllGridServiceAgentsDiscoveredException(ProcessingUnit pu, GridServiceContainer container)

PerZonesGridServiceAgentSlaEnforcementInProgressException(ProcessingUnit pu)

PerZonesMachinesSlaEnforcementInProgressException(ProcessingUnit pu)

SomeProcessingUnitsHaveNotCompletedStateRecoveryException(ProcessingUnit pu, List<ProcessingUnit> pusNotCompletedStateRecovery)

StartedTooManyMachinesException(ProcessingUnit pu, Collection<GridServiceAgent> agents)

UndeployInProgressException(ProcessingUnit pu)

UnexpectedShutdownOfNewGridServiceAgentException(Machine machine, ProcessingUnit pu)

WaitingForDiscoveredMachinesException(ProcessingUnit pu, String message)

Constructor parameters in org.openspaces.grid.gsm.machines.exceptions with type arguments of type ProcessingUnit

SomeProcessingUnitsHaveNotCompletedStateRecoveryException(ProcessingUnit pu, List<ProcessingUnit> pusNotCompletedStateRecovery)

Uses of ProcessingUnit in org.openspaces.grid.gsm.machines.plugins.discovered

Methods in org.openspaces.grid.gsm.machines.plugins.discovered with parameters of type ProcessingUnit

void	DiscoveredMachineProvisioningBean.setProcessingUnit(ProcessingUnit pu)

Uses of ProcessingUnit in org.openspaces.grid.gsm.rebalancing

Methods in org.openspaces.grid.gsm.rebalancing that return ProcessingUnit

ProcessingUnit	FutureStatefulProcessingUnitInstance.getProcessingUnit()
ProcessingUnit	FutureStatelessProcessingUnitInstance.getProcessingUnit()

Methods in org.openspaces.grid.gsm.rebalancing with parameters of type ProcessingUnit

RebalancingSlaEnforcementEndpoint	RebalancingSlaEnforcement.createEndpoint(ProcessingUnit pu)
void	RebalancingSlaEnforcement.destroyEndpoint(ProcessingUnit pu)
static org.openspaces.core.internal.commons.math.fraction.Fraction	RebalancingUtils.getAverageCpuCoresPerPrimary(ProcessingUnit pu, CapacityRequirementsPerAgent aggregatedAllocatedCapacity)
static GridServiceContainer[]	RebalancingUtils.getContainersOnMachines(ProcessingUnit pu)
static int	RebalancingUtils.getNumberOfPrimaryInstancesOnMachine(ProcessingUnit pu, Machine machine)
static org.openspaces.core.internal.commons.math.fraction.Fraction	RebalancingUtils.getNumberOfPrimaryInstancesPerCpuCore(ProcessingUnit pu, Machine machine, CapacityRequirementsPerAgent allocatedCapacity)
static int	RebalancingUtils.getPlannedMaximumNumberOfInstancesForContainer(GridServiceContainer container, GridServiceContainer[] approvedContainers, ProcessingUnit pu)
static int	RebalancingUtils.getPlannedMinimumNumberOfInstancesForContainer(GridServiceContainer container, GridServiceContainer[] approvedContainers, ProcessingUnit pu)
static boolean	RebalancingUtils.isEvenlyDistributedAcrossContainers(ProcessingUnit pu, GridServiceContainer[] containers)
static boolean	RebalancingUtils.isEvenlyDistributedAcrossMachines(ProcessingUnit pu, CapacityRequirementsPerAgent aggregatedAllocatedCapacity)
static boolean	RebalancingUtils.isProcessingUnitHasMinimumNumberOfInstancesPerPartition(ProcessingUnit pu, int minimumNumberOfInstancesPerPartition)
static boolean	RebalancingUtils.isProcessingUnitIntact(ProcessingUnit pu)
static boolean	RebalancingUtils.isProcessingUnitIntact(ProcessingUnit pu, GridServiceContainer[] containers)
static boolean	RebalancingUtils.isProcessingUnitPartitionIntact(ProcessingUnit pu, int instanceId, GridServiceContainer[] containers)
static boolean	RebalancingUtils.isRestartRecommended(ProcessingUnit pu, Machine source, Machine target, org.openspaces.core.internal.commons.math.fraction.Fraction optimalCpuCoresPerPrimary, CapacityRequirementsPerAgent allocatedCapacity)
static String	RebalancingUtils.processingUnitDeploymentToString(ProcessingUnit pu)
static List<GridServiceContainer>	RebalancingUtils.sortAllContainersByNumberOfInstancesAboveMinimum(ProcessingUnit pu, GridServiceContainer[] approvedContainers) Sorts all of the admin containers based on (number of instances from the specified pu - min number of instances) If the container is not in the specified approved container list then min=0, meaning it will get a higher weight in the sort.
static List<Machine>	RebalancingUtils.sortMachinesByNumberOfPrimaryInstancesPerCpuCore(ProcessingUnit pu, Machine[] machines, CapacityRequirementsPerAgent allocatedCapacity)

Uses of ProcessingUnit in org.openspaces.grid.gsm.rebalancing.exceptions

Constructors in org.openspaces.grid.gsm.rebalancing.exceptions with parameters of type ProcessingUnit

ElasticProcessingUnitInstanceUndeployInProgress(ProcessingUnit pu)

FutureProcessingUnitInstanceDeploymentException(ProcessingUnit pu, Throwable cause)

MaximumNumberOfConcurrentRelocationsReachedException(ProcessingUnit pu, GridServiceContainer container)

NumberOfInstancesIsBelowMinimumException(ProcessingUnit pu, int minimumNumberOfInstances)

NumberOfInstancesPerPartitionIsBelowMinimumException(ProcessingUnit pu, int minimumNumberOfInstancesPerPartition)

ProcessingUnitIsNotEvenlyDistributedAccrossMachinesException(ProcessingUnit pu)

ProcessingUnitIsNotEvenlyDistributedAcrossContainersException(String context, ProcessingUnit pu, GridServiceContainer[] containers)

ProcessingUnitIsNotEvenlyDistributedAcrossContainersException(String context, ProcessingUnit pu, GridServiceContainer[] containers, AdminException e)

ProcessingUnitIsNotInTactException(ProcessingUnit pu)

ProcessingUnitIsNotInTactException(ProcessingUnit pu, String message)

RebalancingSlaEnforcementInProgressException(ProcessingUnit pu)

RebalancingSlaEnforcementInProgressException(ProcessingUnit pu, String message)

RebalancingSlaEnforcementInProgressException(ProcessingUnit pu, String message, Throwable cause)

RebalancingSlaEnforcementInProgressException(ProcessingUnit pu, Throwable cause)

RemovedContainerProcessingUnitDeploymentException(ProcessingUnit pu, GridServiceContainer expectedContainer)

Uses of ProcessingUnit in org.openspaces.grid.gsm.sla

Methods in org.openspaces.grid.gsm.sla with parameters of type ProcessingUnit

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.

Uses of ProcessingUnit in org.openspaces.grid.gsm.sla.exceptions

Constructors in org.openspaces.grid.gsm.sla.exceptions with parameters of type ProcessingUnit

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)

Uses of ProcessingUnit in org.openspaces.grid.gsm.strategy

Methods in org.openspaces.grid.gsm.strategy with parameters of type ProcessingUnit

protected MachinesSlaEnforcementState.RecoveryState	UndeployScaleStrategyBean.getRecoveredStateOnEsmStart(ProcessingUnit otherPu)
protected MachinesSlaEnforcementState.RecoveryState	AbstractCapacityScaleStrategyBean.getRecoveredStateOnEsmStart(ProcessingUnit otherPu)
protected abstract MachinesSlaEnforcementState.RecoveryState	AbstractScaleStrategyBean.getRecoveredStateOnEsmStart(ProcessingUnit otherPu)
protected MachinesSlaEnforcementState.RecoveryState	EagerScaleStrategyBean.getRecoveredStateOnEsmStart(ProcessingUnit otherPu)
void	AbstractScaleStrategyBean.setProcessingUnit(ProcessingUnit pu)

Constructors in org.openspaces.grid.gsm.strategy with parameters of type ProcessingUnit

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