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

Packages that use ProcessingUnit

Package	Description
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.internal.alert.bean
org.openspaces.admin.internal.alert.bean.util
org.openspaces.admin.internal.application
org.openspaces.admin.internal.driver
org.openspaces.admin.internal.gateway
org.openspaces.admin.internal.gsm	Internally Used.
org.openspaces.admin.internal.machine	Internally Used.
org.openspaces.admin.internal.pu	Internally Used.
org.openspaces.admin.internal.pu.events	Internally Used.
org.openspaces.admin.internal.pu.quiesce
org.openspaces.admin.internal.pu.scale_horizontal
org.openspaces.admin.internal.pu.scale_vertical
org.openspaces.admin.machine	Support for managing of Machine(s) through the Admin API.
org.openspaces.admin.pu	Support for managing of Processing Unit(s) through the Admin API.
org.openspaces.admin.pu.events	Support for managing of Processing Unit events through the Admin API.
org.openspaces.admin.samples
org.openspaces.core.gateway

Uses of ProcessingUnit in org.openspaces.admin.application

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

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

Uses of ProcessingUnit in org.openspaces.admin.gateway

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

Modifier and Type	Method and Description
ProcessingUnit	GatewayProcessingUnit.getProcessingUnit() Returns the hosting ProcessingUnit.

Uses of ProcessingUnit in org.openspaces.admin.gsm

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

Modifier and Type	Method and Description
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).

Uses of ProcessingUnit in org.openspaces.admin.internal.alert.bean

Methods in org.openspaces.admin.internal.alert.bean with parameters of type ProcessingUnit

Modifier and Type	Method and Description
void	ProvisionFailureAlertBean.processingUnitRemoved(ProcessingUnit processingUnit)
void	ProcessingUnitInstanceMemberAliveIndicatorAlertBean.processingUnitRemoved(ProcessingUnit processingUnit)

Uses of ProcessingUnit in org.openspaces.admin.internal.alert.bean.util

Methods in org.openspaces.admin.internal.alert.bean.util with parameters of type ProcessingUnit

Modifier and Type	Method and Description
static String	AlertBeanUtils.getProcessingUnitDescription(ProcessingUnit processingUnit)

Uses of ProcessingUnit in org.openspaces.admin.internal.application

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

Modifier and Type	Method and Description
ProcessingUnit	DefaultApplication.deployProcessingUnit(ProcessingUnitDeploymentTopology puDeployment)
ProcessingUnit	DefaultApplication.deployProcessingUnit(ProcessingUnitDeploymentTopology puDeployment, long timeout, TimeUnit timeUnit)

Methods in org.openspaces.admin.internal.application with parameters of type ProcessingUnit

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)

Uses of ProcessingUnit in org.openspaces.admin.internal.driver

Methods in org.openspaces.admin.internal.driver that return ProcessingUnit

Modifier and Type	Method and Description
ProcessingUnit	InternalAdminDriver.deploy(ProcessingUnitConfigHolder puConfigHolder)
ProcessingUnit	InternalAdminDriver.deploy(ProcessingUnitConfigHolder puConfigHolder, String applicationName, long timeout, TimeUnit timeUnit)
ProcessingUnit	InternalAdminDriver.deploy(ProcessingUnitConfig puConfig, String applicationName, long timeout, TimeUnit timeUnit)
ProcessingUnit	InternalAdminDriver.UndeployListener.getPu()

Methods in org.openspaces.admin.internal.driver with parameters of type ProcessingUnit

Modifier and Type	Method and Description
protected void	InternalAdminDriver.afterDeploy(ProcessingUnit pu, long deadline)
void	InternalAdminDriver.beforeUndeployK8s(ProcessingUnit pu, UndeployOptions options)
boolean	ServiceGridAdminDriver.checkIfPartitionHasAlreadyProvidedResource(ProcessingUnit pu, Integer partitionId, String memory, String cpu)
boolean	KubernetesAdminDriver.checkIfPartitionHasAlreadyProvidedResource(ProcessingUnit pu, Integer partitionId, String memory, String cpu)
abstract boolean	InternalAdminDriver.checkIfPartitionHasAlreadyProvidedResource(ProcessingUnit pu, Integer partitionId, String memory, String cpu)
com.gigaspaces.grid.gsm.PUDetails	ServiceGridAdminDriver.getPuDetails(ProcessingUnit pu)
com.gigaspaces.grid.gsm.PUDetails	KubernetesAdminDriver.getPuDetails(ProcessingUnit pu)
abstract com.gigaspaces.grid.gsm.PUDetails	InternalAdminDriver.getPuDetails(ProcessingUnit pu)
void	InternalAdminDriver.postDeploy(ProcessingUnit pu) This method is intended for usage by kubernetes operator only - the operator calls predeploy, performs the actual provisioning, then calls postdeploy
void	InternalAdminDriver.UndeployListener.processingUnitRemoved(ProcessingUnit removedPu)
void	ServiceGridAdminDriver.scaleIn(ProcessingUnit pu, int factor)
void	KubernetesAdminDriver.scaleIn(ProcessingUnit pu, int factor)
abstract void	InternalAdminDriver.scaleIn(ProcessingUnit pu, int factor)
void	ServiceGridAdminDriver.scaleOut(ProcessingUnit pu, int factor, String memory, String cpu)
void	KubernetesAdminDriver.scaleOut(ProcessingUnit pu, int factor, String memory, String cpu)
abstract void	InternalAdminDriver.scaleOut(ProcessingUnit pu, int factor, String memory, String cpu)
void	InternalAdminDriver.scaleUpDown(ProcessingUnit pu, Integer partitionId, String memory, String cpu, Long timeout, PuScaleVStatusChangedEventListener listener)
void	ServiceGridAdminDriver.scaleUpDownUnsafe(ProcessingUnit pu, Integer partitionId, String memory, String cpu, Long timeout, PuScaleVStatusChangedEventListener listener)
void	KubernetesAdminDriver.scaleUpDownUnsafe(ProcessingUnit pu, Integer partitionId, String memory, String cpu, Long timeout, PuScaleVStatusChangedEventListener listener)
protected abstract void	InternalAdminDriver.scaleUpDownUnsafe(ProcessingUnit pu, Integer partitionId, String memory, String cpu, Long timeout, PuScaleVStatusChangedEventListener listener)
CompletableFuture<?>	InternalAdminDriver.undeployAsync(ProcessingUnit pu)
CompletableFuture<?>	KubernetesAdminDriver.undeployAsync(ProcessingUnit pu, UndeployOptions options)
CompletableFuture<?>	InternalAdminDriver.undeployAsync(ProcessingUnit pu, UndeployOptions options)

Constructors in org.openspaces.admin.internal.driver with parameters of type ProcessingUnit

Constructor and Description
UndeployListener(ProcessingUnit pu)

Uses of ProcessingUnit in org.openspaces.admin.internal.gateway

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

Modifier and Type	Method and Description
ProcessingUnit	DefaultGatewayProcessingUnit.getProcessingUnit()

Uses of ProcessingUnit in org.openspaces.admin.internal.gsm

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

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

Methods in org.openspaces.admin.internal.gsm with parameters of type ProcessingUnit

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.
void	DefaultGridServiceManager.incrementInstance(ProcessingUnit processingUnit)
void	InternalGridServiceManager.incrementInstance(ProcessingUnit processingUnit)

Uses of ProcessingUnit in org.openspaces.admin.internal.machine

Methods in org.openspaces.admin.internal.machine that return ProcessingUnit

Modifier and Type	Method and Description
ProcessingUnit[]	DefaultMachine.getProcessingUnits()

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

Subinterfaces of ProcessingUnit in org.openspaces.admin.internal.pu

Modifier and Type	Interface and Description
interface	InternalProcessingUnit

Classes in org.openspaces.admin.internal.pu that implement ProcessingUnit

Modifier and Type	Class and Description
class	DefaultProcessingUnit

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

Modifier and Type	Method and Description
ProcessingUnit	DefaultProcessingUnitPartition.getProcessingUnit()
ProcessingUnit	DefaultProcessingUnitInstance.getProcessingUnit()
ProcessingUnit	DefaultProcessingUnits.getProcessingUnit(String name)
ProcessingUnit	DefaultProcessingUnits.getProcessingUnitBySpace(String spaceName)
ProcessingUnit	InternalProcessingUnits.getProcessingUnitBySpace(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)

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

Modifier and Type	Method and Description
Map<String,ProcessingUnit>	DefaultProcessingUnits.getNames()
Iterator<ProcessingUnit>	DefaultProcessingUnits.iterator()

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

Modifier and Type	Method and Description
void	DefaultProcessingUnits.addProcessingUnit(ProcessingUnit processingUnit)
void	InternalProcessingUnits.addProcessingUnit(ProcessingUnit processingUnit)
void	DefaultAdminProcessingUnitInstances.processRemovedOnProcessingUnitRemoval(ProcessingUnit processingUnit)
void	DefaultProcessingUnitInstance.setProcessingUnit(ProcessingUnit processingUnit)
void	InternalProcessingUnitInstance.setProcessingUnit(ProcessingUnit processingUnit)

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

Constructor and Description
DefaultProcessingUnitPartition(ProcessingUnit processingUnit, int patitionId)

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

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

Modifier and Type	Method and Description
void	ClosureProcessingUnitAddedEventListener.processingUnitAdded(ProcessingUnit processingUnit)
void	DefaultProcessingUnitAddedEventManager.processingUnitAdded(ProcessingUnit processingUnit)
void	ClosureProcessingUnitRemovedEventListener.processingUnitRemoved(ProcessingUnit processingUnit)
void	DefaultProcessingUnitRemovedEventManager.processingUnitRemoved(ProcessingUnit processingUnit)

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

Constructor and Description
DefaultBackupGridServiceManagerChangedEventManager(InternalAdmin admin, ProcessingUnit processingUnit)
DefaultProcessingUnitStatusChangedEventManager(InternalAdmin admin, ProcessingUnit processingUnit)

Uses of ProcessingUnit in org.openspaces.admin.internal.pu.quiesce

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

Modifier and Type	Method and Description
InternalQuiesceDetails	GsmQuiesceManager.getInternalQuiesceDetails(ProcessingUnit processingUnit)
InternalQuiesceDetails	QuiesceManager.getInternalQuiesceDetails(ProcessingUnit processingUnit)
InternalQuiesceDetails	ZookeeperQuiesceManager.getInternalQuiesceDetails(ProcessingUnit processingUnit)
QuiesceDetails	GsmQuiesceManager.getQuiesceDetails(ProcessingUnit processingUnit)
QuiesceDetails	QuiesceManager.getQuiesceDetails(ProcessingUnit processingUnit)
QuiesceDetails	ZookeeperQuiesceManager.getQuiesceDetails(ProcessingUnit processingUnit)
InternalQuiesceDetails	GsmQuiesceManager.quiesce(ProcessingUnit processingUnit, QuiesceRequest request)
InternalQuiesceDetails	QuiesceManager.quiesce(ProcessingUnit processingUnit, QuiesceRequest request)
InternalQuiesceDetails	ZookeeperQuiesceManager.quiesce(ProcessingUnit processingUnit, QuiesceRequest request)
void	GsmQuiesceManager.unquiesce(ProcessingUnit processingUnit, QuiesceRequest request)
void	QuiesceManager.unquiesce(ProcessingUnit processingUnit, QuiesceRequest request)
void	ZookeeperQuiesceManager.unquiesce(ProcessingUnit processingUnit, QuiesceRequest request)

Uses of ProcessingUnit in org.openspaces.admin.internal.pu.scale_horizontal

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

Constructor and Description
DynamicPartitionProxy(ProcessingUnit pu, int partitionId)

Uses of ProcessingUnit in org.openspaces.admin.internal.pu.scale_vertical

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

Modifier and Type	Method and Description
void	ScaleVerticalManager.scaleUpDown(ProcessingUnit pu, String memory, String cpu, Long timeout, PuScaleVStatusChangedEventListener listener, InternalAdminDriver driver)

Uses of ProcessingUnit in org.openspaces.admin.machine

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

Modifier and Type	Method and Description
ProcessingUnit[]	Machine.getProcessingUnits()

Uses of ProcessingUnit in org.openspaces.admin.pu

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

Modifier and Type	Method and Description
ProcessingUnit	ProcessingUnitPartition.getProcessingUnit() Returns the processing unit this partition is part of.
ProcessingUnit	ProcessingUnitInstance.getProcessingUnit() Returns the processing unit this processing unit instance belongs to.
ProcessingUnit	ProcessingUnits.getProcessingUnit(String name) Returns the ProcessingUnit for the given processing unit name.
ProcessingUnit[]	ProcessingUnits.getProcessingUnits() Returns the ProcessingUnits currently deployed.
ProcessingUnit	ProcessingUnits.waitFor(String processingUnitName) Waits indefinitely till the processing unit is identified as deployed.
ProcessingUnit	ProcessingUnits.waitFor(String processingUnitName, long timeout, TimeUnit timeUnit) Waits for the specified timeout (in time interval) till the processing unit is identified as deployed.

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

Modifier and Type	Method and Description
Map<String,ProcessingUnit>	ProcessingUnits.getNames() Returns a map of ProcessingUnit keyed by their respective names.

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

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

Modifier and Type	Method and Description
ProcessingUnit	ManagingGridServiceManagerChangedEvent.getProcessingUnit() Returns the processing unit the managing GSM was changed for.
ProcessingUnit	BackupGridServiceManagerChangedEvent.getProcessingUnit() Returns the Processing Unit that the backup GSM event occurred on.
ProcessingUnit	ProcessingUnitInstanceProvisionStatusChangedEvent.getProcessingUnit()
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.

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

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

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

Constructor and Description
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, ProcessingUnitInstanceProvisionFailure provisionFailure)
ProcessingUnitInstanceProvisionStatusChangedEvent(ProcessingUnit processingUnit, String processingUnitInstanceName, ProvisionStatus previousStatus, ProvisionStatus newStatus, String gscServiceId, ProcessingUnitInstanceProvisionFailure provisionFailure)
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

Modifier and Type	Method and Description
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

Modifier and Type	Method and Description
static String	GatewayUtils.extractGatewayNameIfExists(ProcessingUnit processingUnit)
static ProcessingUnitInstance	GatewayUtils.extractInstanceIfPuOfGateway(String gatewayName, ProcessingUnit processingUnit)