Uses of Interface
org.openspaces.admin.pu.ProcessingUnit
Packages that use ProcessingUnit
Package
Description
Support for managing of Grid Service Manager(s) through the Admin API.
Internally Used.
Internally Used.
Internally Used.
Internally Used.
Support for managing of Machine(s) through the Admin API.
Support for managing of Processing Unit(s) through the Admin API.
Support for managing of Processing Unit events through the Admin API.
-
Uses of ProcessingUnit in org.openspaces.admin.application
Methods in org.openspaces.admin.application that return ProcessingUnitModifier and TypeMethodDescriptionApplication.deployProcessingUnit(ProcessingUnitDeploymentTopology puDeployment) Deploys the specified processing unit adding it to this applicationApplication.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 ProcessingUnitModifier and TypeMethodDescriptionGatewayProcessingUnit.getProcessingUnit()Returns the hostingProcessingUnit. -
Uses of ProcessingUnit in org.openspaces.admin.gsm
Methods in org.openspaces.admin.gsm that return ProcessingUnitModifier and TypeMethodDescriptionGridServiceManager.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).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).GridServiceManager.deploy(ProcessingUnitConfigHolder puConfigHolder) Deploys a new processing unit based on the specified configurationGridServiceManager.deploy(ProcessingUnitConfigHolder puConfigHolder, long timeout, TimeUnit timeUnit) Deploys a new processing unit based on the specified configurationGridServiceManager.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).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).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).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).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).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.internal.alert.bean
Methods in org.openspaces.admin.internal.alert.bean with parameters of type ProcessingUnitModifier and TypeMethodDescriptionvoidProcessingUnitInstanceMemberAliveIndicatorAlertBean.processingUnitRemoved(ProcessingUnit processingUnit) voidProvisionFailureAlertBean.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 ProcessingUnitModifier and TypeMethodDescriptionstatic StringAlertBeanUtils.getProcessingUnitDescription(ProcessingUnit processingUnit) -
Uses of ProcessingUnit in org.openspaces.admin.internal.application
Methods in org.openspaces.admin.internal.application that return ProcessingUnitModifier and TypeMethodDescriptionDefaultApplication.deployProcessingUnit(ProcessingUnitDeploymentTopology puDeployment) DefaultApplication.deployProcessingUnit(ProcessingUnitDeploymentTopology puDeployment, long timeout, TimeUnit timeUnit) Methods in org.openspaces.admin.internal.application with parameters of type ProcessingUnitModifier and TypeMethodDescriptionvoidDefaultApplications.addApplication(Application application, ProcessingUnit processingUnit) voidInternalApplications.addApplication(Application application, ProcessingUnit processingUnit) voidDefaultApplications.removeProcessingUnit(ProcessingUnit processingUnit) voidInternalApplications.removeProcessingUnit(ProcessingUnit processingUnit) -
Uses of ProcessingUnit in org.openspaces.admin.internal.driver
Methods in org.openspaces.admin.internal.driver that return ProcessingUnitModifier and TypeMethodDescriptionInternalAdminDriver.deploy(ProcessingUnitConfig puConfig, String applicationName, long timeout, TimeUnit timeUnit) InternalAdminDriver.deploy(ProcessingUnitConfigHolder puConfigHolder) InternalAdminDriver.deploy(ProcessingUnitConfigHolder puConfigHolder, String applicationName, long timeout, TimeUnit timeUnit) InternalAdminDriver.UndeployListener.getPu()Methods in org.openspaces.admin.internal.driver with parameters of type ProcessingUnitModifier and TypeMethodDescriptionprotected voidInternalAdminDriver.afterDeploy(ProcessingUnit pu, long deadline) voidInternalAdminDriver.beforeUndeployK8s(ProcessingUnit pu, UndeployOptions options) abstract booleanInternalAdminDriver.checkIfPartitionHasAlreadyProvidedResource(ProcessingUnit pu, Integer partitionId, String memory, String cpu) booleanKubernetesAdminDriver.checkIfPartitionHasAlreadyProvidedResource(ProcessingUnit pu, Integer partitionId, String memory, String cpu) booleanServiceGridAdminDriver.checkIfPartitionHasAlreadyProvidedResource(ProcessingUnit pu, Integer partitionId, String memory, String cpu) abstract com.gigaspaces.grid.gsm.PUDetailsInternalAdminDriver.getPuDetails(ProcessingUnit pu) com.gigaspaces.grid.gsm.PUDetailsKubernetesAdminDriver.getPuDetails(ProcessingUnit pu) com.gigaspaces.grid.gsm.PUDetailsServiceGridAdminDriver.getPuDetails(ProcessingUnit pu) KubernetesAdminDriver.getPuLimits(ProcessingUnit pu) voidInternalAdminDriver.postDeploy(ProcessingUnit pu) This method is intended for usage by kubernetes operator only - the operator calls predeploy, performs the actual provisioning, then calls postdeployvoidInternalAdminDriver.UndeployListener.processingUnitRemoved(ProcessingUnit removedPu) abstract voidInternalAdminDriver.scaleIn(ProcessingUnit pu, int factor, String memory, String cpu) voidKubernetesAdminDriver.scaleIn(ProcessingUnit pu, int factor, String memory, String cpu) voidServiceGridAdminDriver.scaleIn(ProcessingUnit pu, int factor, String memory, String cpu) abstract voidInternalAdminDriver.scaleOut(ProcessingUnit pu, int factor, String memory, String cpu) voidKubernetesAdminDriver.scaleOut(ProcessingUnit pu, int factor, String memory, String cpu) voidServiceGridAdminDriver.scaleOut(ProcessingUnit pu, int factor, String memory, String cpu) voidInternalAdminDriver.scaleUpDown(ProcessingUnit pu, Integer partitionId, String memory, String cpu, Long timeout, PuScaleVStatusChangedEventListener listener) protected abstract voidInternalAdminDriver.scaleUpDownUnsafe(ProcessingUnit pu, Integer partitionId, String memory, String cpu, Long timeout, PuScaleVStatusChangedEventListener listener) voidKubernetesAdminDriver.scaleUpDownUnsafe(ProcessingUnit pu, Integer partitionId, String memory, String cpu, Long timeout, PuScaleVStatusChangedEventListener listener) voidServiceGridAdminDriver.scaleUpDownUnsafe(ProcessingUnit pu, Integer partitionId, String memory, String cpu, Long timeout, PuScaleVStatusChangedEventListener listener) InternalAdminDriver.undeployAsync(ProcessingUnit pu) InternalAdminDriver.undeployAsync(ProcessingUnit pu, UndeployOptions options) KubernetesAdminDriver.undeployAsync(ProcessingUnit pu, UndeployOptions options) Constructors in org.openspaces.admin.internal.driver with parameters of type ProcessingUnit -
Uses of ProcessingUnit in org.openspaces.admin.internal.gateway
Methods in org.openspaces.admin.internal.gateway that return ProcessingUnit -
Uses of ProcessingUnit in org.openspaces.admin.internal.gsm
Methods in org.openspaces.admin.internal.gsm that return ProcessingUnitModifier and TypeMethodDescriptionDefaultGridServiceManager.deploy(Application application, ProcessingUnitDeploymentTopology deploymentTopology, long timeout, TimeUnit timeUnit) DefaultGridServiceManager.deploy(ProcessingUnitDeployment deployment) DefaultGridServiceManager.deploy(ProcessingUnitDeployment deployment, long timeout, TimeUnit timeUnit) DefaultGridServiceManager.deploy(ProcessingUnitConfigHolder puConfigHolder) DefaultGridServiceManager.deploy(ProcessingUnitConfigHolder puConfigHolder, long timeout, TimeUnit timeUnit) DefaultGridServiceManager.deploy(SpaceDeployment deployment) DefaultGridServiceManager.deploy(SpaceDeployment deployment, long timeout, TimeUnit timeUnit) DefaultGridServiceManagers.deploy(Application application, ProcessingUnitDeploymentTopology puDeploymentTopology, long timeout, TimeUnit timeUnit) DefaultGridServiceManagers.deploy(ProcessingUnitDeployment deployment) DefaultGridServiceManagers.deploy(ProcessingUnitDeployment deployment, long timeout, TimeUnit timeUnit) DefaultGridServiceManagers.deploy(SpaceDeployment deployment) DefaultGridServiceManagers.deploy(SpaceDeployment deployment, long timeout, TimeUnit timeUnit) InternalGridServiceManager.deploy(Application application, ProcessingUnitDeploymentTopology deploymentTopology, long timeout, TimeUnit timeUnit) InternalGridServiceManagers.deploy(Application application, ProcessingUnitDeploymentTopology puDeployment, long timeout, TimeUnit timeUnit) Methods in org.openspaces.admin.internal.gsm with parameters of type ProcessingUnitModifier and TypeMethodDescriptionbooleanDefaultGridServiceManager.decrementPlannedInstances(ProcessingUnit processingUnit) booleanInternalGridServiceManager.decrementPlannedInstances(ProcessingUnit processingUnit) Decrements a planned instance if the number of planned instances is less then the actual instances to maintain.voidDefaultGridServiceManager.incrementInstance(ProcessingUnit processingUnit) voidInternalGridServiceManager.incrementInstance(ProcessingUnit processingUnit) -
Uses of ProcessingUnit in org.openspaces.admin.internal.machine
Methods in org.openspaces.admin.internal.machine that return ProcessingUnit -
Uses of ProcessingUnit in org.openspaces.admin.internal.pu
Subinterfaces of ProcessingUnit in org.openspaces.admin.internal.puClasses in org.openspaces.admin.internal.pu that implement ProcessingUnitMethods in org.openspaces.admin.internal.pu that return ProcessingUnitModifier and TypeMethodDescriptionDefaultProcessingUnitInstance.getProcessingUnit()DefaultProcessingUnitPartition.getProcessingUnit()DefaultProcessingUnits.getProcessingUnit(String name) DefaultProcessingUnits.getProcessingUnitBySpace(String spaceName) InternalProcessingUnits.getProcessingUnitBySpace(String name) DefaultProcessingUnits.getProcessingUnits()DefaultProcessingUnits.removeEmbeddedSpace(InternalSpace space) InternalProcessingUnits.removeEmbeddedSpace(InternalSpace space) Removes the reference to the specified space from the hosting processing unit.Methods in org.openspaces.admin.internal.pu that return types with arguments of type ProcessingUnitModifier and TypeMethodDescriptionDefaultProcessingUnits.getNames()DefaultProcessingUnits.iterator()Methods in org.openspaces.admin.internal.pu with parameters of type ProcessingUnitModifier and TypeMethodDescriptionvoidDefaultProcessingUnits.addProcessingUnit(ProcessingUnit processingUnit) voidInternalProcessingUnits.addProcessingUnit(ProcessingUnit processingUnit) voidDefaultAdminProcessingUnitInstances.processRemovedOnProcessingUnitRemoval(ProcessingUnit processingUnit) voidDefaultProcessingUnitInstance.setProcessingUnit(ProcessingUnit processingUnit) voidInternalProcessingUnitInstance.setProcessingUnit(ProcessingUnit processingUnit) Constructors in org.openspaces.admin.internal.pu with parameters of type ProcessingUnitModifierConstructorDescriptionDefaultProcessingUnitPartition(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 ProcessingUnitModifier and TypeMethodDescriptionvoidClosureProcessingUnitAddedEventListener.processingUnitAdded(ProcessingUnit processingUnit) voidDefaultProcessingUnitAddedEventManager.processingUnitAdded(ProcessingUnit processingUnit) voidClosureProcessingUnitRemovedEventListener.processingUnitRemoved(ProcessingUnit processingUnit) voidDefaultProcessingUnitRemovedEventManager.processingUnitRemoved(ProcessingUnit processingUnit) Constructors in org.openspaces.admin.internal.pu.events with parameters of type ProcessingUnitModifierConstructorDescriptionDefaultBackupGridServiceManagerChangedEventManager(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 ProcessingUnitModifier and TypeMethodDescriptionGsmQuiesceManager.getInternalQuiesceDetails(ProcessingUnit processingUnit) QuiesceManager.getInternalQuiesceDetails(ProcessingUnit processingUnit) ZookeeperQuiesceManager.getInternalQuiesceDetails(ProcessingUnit processingUnit) GsmQuiesceManager.getQuiesceDetails(ProcessingUnit processingUnit) QuiesceManager.getQuiesceDetails(ProcessingUnit processingUnit) ZookeeperQuiesceManager.getQuiesceDetails(ProcessingUnit processingUnit) GsmQuiesceManager.quiesce(ProcessingUnit processingUnit, QuiesceRequest request) QuiesceManager.quiesce(ProcessingUnit processingUnit, QuiesceRequest request) ZookeeperQuiesceManager.quiesce(ProcessingUnit processingUnit, QuiesceRequest request) voidGsmQuiesceManager.unquiesce(ProcessingUnit processingUnit, QuiesceRequest request) voidQuiesceManager.unquiesce(ProcessingUnit processingUnit, QuiesceRequest request) voidZookeeperQuiesceManager.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 -
Uses of ProcessingUnit in org.openspaces.admin.internal.pu.scale_vertical
Methods in org.openspaces.admin.internal.pu.scale_vertical with parameters of type ProcessingUnitModifier and TypeMethodDescriptionvoidScaleVerticalManager.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 -
Uses of ProcessingUnit in org.openspaces.admin.pu
Methods in org.openspaces.admin.pu that return ProcessingUnitModifier and TypeMethodDescriptionProcessingUnitInstance.getProcessingUnit()Returns the processing unit this processing unit instance belongs to.ProcessingUnitPartition.getProcessingUnit()Returns the processing unit this partition is part of.ProcessingUnits.getProcessingUnit(String name) Returns theProcessingUnitfor the given processing unit name.ProcessingUnits.getProcessingUnits()Returns theProcessingUnits currently deployed.Waits indefinitely till the processing unit is identified as deployed.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 ProcessingUnitModifier and TypeMethodDescriptionProcessingUnits.getNames()Returns a map ofProcessingUnitkeyed by their respective names. -
Uses of ProcessingUnit in org.openspaces.admin.pu.events
Methods in org.openspaces.admin.pu.events that return ProcessingUnitModifier and TypeMethodDescriptionBackupGridServiceManagerChangedEvent.getProcessingUnit()Returns the Processing Unit that the backup GSM event occurred on.ManagingGridServiceManagerChangedEvent.getProcessingUnit()Returns the processing unit the managing GSM was changed for.ProcessingUnitInstanceProvisionStatusChangedEvent.getProcessingUnit()ProcessingUnitSpaceCorrelatedEvent.getProcessingUnit()Returns the Processing Unit the space was correlated with.ProcessingUnitStatusChangedEvent.getProcessingUnit()Returns the Processing Unit that the deployment status changed for.Methods in org.openspaces.admin.pu.events with parameters of type ProcessingUnitModifier and TypeMethodDescriptionvoidProcessingUnitAddedEventListener.processingUnitAdded(ProcessingUnit processingUnit) A callback indicating that a Processing Unit was added (deployed/discovered).voidProcessingUnitRemovedEventListener.processingUnitRemoved(ProcessingUnit processingUnit) A callback indicating that a Processing Unit was removed (undeployed).Constructors in org.openspaces.admin.pu.events with parameters of type ProcessingUnitModifierConstructorDescriptionBackupGridServiceManagerChangedEvent(ProcessingUnit processingUnit, BackupGridServiceManagerChangedEvent.Type type, GridServiceManager gridServiceManager) ManagingGridServiceManagerChangedEvent(ProcessingUnit processingUnit, GridServiceManager newGridServiceManager, GridServiceManager previousGridServiceManager) ProcessingUnitInstanceProvisionStatusChangedEvent(ProcessingUnit processingUnit, String processingUnitInstanceName, ProvisionStatus previousStatus, ProvisionStatus newStatus, String gscServiceId, ProcessingUnitInstanceProvisionFailure provisionFailure) ProcessingUnitInstanceProvisionStatusChangedEvent(ProcessingUnit processingUnit, String processingUnitInstanceName, ProvisionStatus previousStatus, ProvisionStatus newStatus, GridServiceContainer gridServiceContainer, ProcessingUnitInstance processingUnitInstance, 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 ProcessingUnitModifier and TypeMethodDescriptionvoidTestEventSampler.processingUnitAdded(ProcessingUnit processingUnit) voidTestEventSampler.processingUnitRemoved(ProcessingUnit processingUnit) -
Uses of ProcessingUnit in org.openspaces.core.gateway
Methods in org.openspaces.core.gateway with parameters of type ProcessingUnitModifier and TypeMethodDescriptionstatic StringGatewayUtils.extractGatewayNameIfExists(ProcessingUnit processingUnit) static ProcessingUnitInstanceGatewayUtils.extractInstanceIfPuOfGateway(String gatewayName, ProcessingUnit processingUnit)