|
GigaSpaces XAP 8.0 API | |||||||||
PREV NEXT | FRAMES NO FRAMES |
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.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.containers | |
org.openspaces.grid.gsm.machines | |
org.openspaces.grid.gsm.machines.exceptions | |
org.openspaces.grid.gsm.machines.plugins | |
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.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 |
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)
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(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(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)
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(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(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)
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(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(MemcachedDeployment deployment)
Deploys a memcached based on the space deployment information on a random grid service manager (it will act as the primary GSM for the deployed processing unit). |
ProcessingUnit |
GridServiceManager.deploy(MemcachedDeployment deployment)
Deploys a memcached based on the space deployment information on the given grid service manager (it will act as the primary GSM for the deployed processing unit). |
ProcessingUnit |
GridServiceManagers.deploy(MemcachedDeployment deployment,
long timeout,
TimeUnit timeUnit)
Deploys a memcached based on the space deployment information on a random grid service manager (it will act as the primary GSM for the deployed processing unit). |
ProcessingUnit |
GridServiceManager.deploy(MemcachedDeployment deployment,
long timeout,
TimeUnit timeUnit)
Deploys a memcached based on the space deployment information on the given grid service manager (it will act as the primary GSM for the deployed processing unit). |
ProcessingUnit |
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.pu |
---|
Methods in org.openspaces.admin.pu that return ProcessingUnit | |
---|---|
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. |
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.events |
---|
Methods in org.openspaces.admin.pu.events that return ProcessingUnit | |
---|---|
ProcessingUnit |
ProcessingUnitStatusChangedEvent.getProcessingUnit()
Returns the Processing Unit that the deployment status changed for. |
ProcessingUnit |
ProcessingUnitInstanceProvisionStatusChangedEvent.getProcessingUnit()
|
ProcessingUnit |
ProcessingUnitSpaceCorrelatedEvent.getProcessingUnit()
Returns the Processing Unit the space was correlated with. |
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. |
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). |
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,
NonBlockingElasticMachineProvisioningAdapterFactory nonBlockingAdapterFactory,
org.openspaces.admin.internal.pu.elastic.ElasticMachineIsolationConfig isolationConfig,
org.jini.rio.monitor.event.EventsStore eventStore)
|
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.machines |
---|
Methods in org.openspaces.grid.gsm.machines that return types with arguments of type ProcessingUnit | |
---|---|
Map<ProcessingUnit,ClusterCapacityRequirements> |
MachinesSlaEnforcementState.getAllocatedCapacityPerProcessingUnit()
|
List<ProcessingUnit> |
MachinesSlaEnforcementState.getAllProcessingUnitsNotCompletedStateRecovery(Admin admin)
|
Uses of ProcessingUnit in org.openspaces.grid.gsm.machines.exceptions |
---|
Constructors in org.openspaces.grid.gsm.machines.exceptions with parameters of type ProcessingUnit | |
---|---|
FailedToDiscoverMachinesException(ProcessingUnit pu,
Exception cause)
|
|
NeedToStartMoreGridServiceAgentsException(AbstractMachinesSlaPolicy sla,
MachinesSlaEnforcementState state,
CapacityRequirements capacityShortage,
ProcessingUnit pu)
|
|
NeedToStartMoreGridServiceAgentsException(CapacityRequirements capacityShortage,
ProcessingUnit pu)
|
|
NoClassDefFoundElasticMachineProvisioningException(ProcessingUnit pu,
NoClassDefFoundError cause)
|
|
StartedTooManyMachinesException(ProcessingUnit pu,
Collection<GridServiceAgent> agents)
|
Constructor parameters in org.openspaces.grid.gsm.machines.exceptions with type arguments of type ProcessingUnit | |
---|---|
SomeProcessingUnitsHaveNotCompletedStateRecoveryException(List<ProcessingUnit> pusNotCompletedStateRecovery)
|
Uses of ProcessingUnit in org.openspaces.grid.gsm.machines.plugins |
---|
Methods in org.openspaces.grid.gsm.machines.plugins with parameters of type ProcessingUnit | |
---|---|
NonBlockingElasticMachineProvisioningAdapter |
NonBlockingElasticMachineProvisioningAdapterFactory.create(ProcessingUnit pu,
ElasticMachineProvisioning machineProvisioning)
|
Constructors in org.openspaces.grid.gsm.machines.plugins with parameters of type ProcessingUnit | |
---|---|
NonBlockingElasticMachineProvisioningAdapter(ProcessingUnit pu,
ElasticMachineProvisioning machineProvisioning,
ExecutorService executorService,
ScheduledThreadPoolExecutor scheduledExecutorService)
|
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 |
FutureStatelessProcessingUnitInstance.getProcessingUnit()
|
ProcessingUnit |
FutureStatefulProcessingUnitInstance.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,
ClusterCapacityRequirements aggregatedAllocatedCapacity)
|
static int |
RebalancingUtils.getNumberOfPrimaryInstancesOnMachine(ProcessingUnit pu,
Machine machine)
|
static org.openspaces.core.internal.commons.math.fraction.Fraction |
RebalancingUtils.getNumberOfPrimaryInstancesPerCpuCore(ProcessingUnit pu,
Machine machine,
ClusterCapacityRequirements 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,
ClusterCapacityRequirements aggregatedAllocatedCapacity)
|
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,
ClusterCapacityRequirements 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,
ClusterCapacityRequirements allocatedCapacity)
|
Uses of ProcessingUnit in org.openspaces.grid.gsm.rebalancing.exceptions |
---|
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.strategy |
---|
Methods in org.openspaces.grid.gsm.strategy that return ProcessingUnit | |
---|---|
protected ProcessingUnit |
AbstractScaleStrategyBean.getProcessingUnit()
|
Methods in org.openspaces.grid.gsm.strategy with parameters of type ProcessingUnit | |
---|---|
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 |
|
GigaSpaces XAP 8.0 API | |||||||||
PREV NEXT | FRAMES NO FRAMES |