Modifier and Type | Method and Description |
---|---|
ProcessingUnit |
Application.deployProcessingUnit(ProcessingUnitDeploymentTopology puDeployment)
Deploys the specified processing unit adding it to this application
|
ProcessingUnit |
Application.deployProcessingUnit(ProcessingUnitDeploymentTopology puDeployment,
long timeout,
TimeUnit timeUnit)
Deploys the specified processing unit adding it to this application
|
Modifier and Type | Method and Description |
---|---|
ProcessingUnit |
GatewayProcessingUnit.getProcessingUnit()
Returns the hosting
ProcessingUnit . |
Modifier and Type | Method and Description |
---|---|
ProcessingUnit |
GridServiceManager.deploy(ProcessingUnitConfigHolder puConfigHolder)
Deploys a new processing unit based on the specified configuration
|
ProcessingUnit |
GridServiceManager.deploy(ProcessingUnitConfigHolder puConfigHolder,
long timeout,
TimeUnit timeUnit)
Deploys a new processing unit based on the specified configuration
|
ProcessingUnit |
GridServiceManager.deploy(ProcessingUnitDeployment deployment)
Deploys a processing unit based on the processing unit deployment information on the given
grid service manager (it will act as the primary GSM for the deployed processing unit).
|
ProcessingUnit |
GridServiceManagers.deploy(ProcessingUnitDeployment deployment)
Deploys a processing unit based on the processing unit deployment information on a random
grid service manager (it will act as the primary GSM for the deployed processing unit).
|
ProcessingUnit |
GridServiceManager.deploy(ProcessingUnitDeployment deployment,
long timeout,
TimeUnit timeUnit)
Deploys a processing unit based on the processing unit deployment information on the given
grid service manager (it will act as the primary GSM for the deployed processing unit).
|
ProcessingUnit |
GridServiceManagers.deploy(ProcessingUnitDeployment deployment,
long timeout,
TimeUnit timeUnit)
Deploys a processing unit based on the processing unit deployment information on a random
grid service manager (it will act as the primary GSM for the deployed processing unit).
|
ProcessingUnit |
GridServiceManager.deploy(SpaceDeployment deployment)
Deploys a space based on the space deployment information on the given grid service manager
(it will act as the primary GSM for the deployed processing unit).
|
ProcessingUnit |
GridServiceManagers.deploy(SpaceDeployment deployment)
Deploys a space based on the space deployment information on a random grid service manager
(it will act as the primary GSM for the deployed processing unit).
|
ProcessingUnit |
GridServiceManager.deploy(SpaceDeployment deployment,
long timeout,
TimeUnit timeUnit)
Deploys a space based on the space deployment information on the given grid service manager
(it will act as the primary GSM for the deployed processing unit).
|
ProcessingUnit |
GridServiceManagers.deploy(SpaceDeployment deployment,
long timeout,
TimeUnit timeUnit)
Deploys a space based on the space deployment information on a random grid service manager
(it will act as the primary GSM for the deployed processing unit).
|
Modifier and Type | Method and Description |
---|---|
void |
ProvisionFailureAlertBean.processingUnitRemoved(ProcessingUnit processingUnit) |
void |
ProcessingUnitInstanceMemberAliveIndicatorAlertBean.processingUnitRemoved(ProcessingUnit processingUnit) |
Modifier and Type | Method and Description |
---|---|
static String |
AlertBeanUtils.getProcessingUnitDescription(ProcessingUnit processingUnit) |
Modifier and Type | Method and Description |
---|---|
ProcessingUnit |
DefaultApplication.deployProcessingUnit(ProcessingUnitDeploymentTopology puDeployment) |
ProcessingUnit |
DefaultApplication.deployProcessingUnit(ProcessingUnitDeploymentTopology puDeployment,
long timeout,
TimeUnit timeUnit) |
Modifier and Type | Method and Description |
---|---|
void |
DefaultApplications.addApplication(Application application,
ProcessingUnit processingUnit) |
void |
InternalApplications.addApplication(Application application,
ProcessingUnit processingUnit) |
void |
DefaultApplications.removeProcessingUnit(ProcessingUnit processingUnit) |
void |
InternalApplications.removeProcessingUnit(ProcessingUnit 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() |
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) |
abstract boolean |
InternalAdminDriver.checkIfPartitionHasAlreadyProvidedResource(ProcessingUnit pu,
Integer partitionId,
String memory,
String cpu) |
boolean |
KubernetesAdminDriver.checkIfPartitionHasAlreadyProvidedResource(ProcessingUnit pu,
Integer partitionId,
String memory,
String cpu) |
com.gigaspaces.grid.gsm.PUDetails |
ServiceGridAdminDriver.getPuDetails(ProcessingUnit pu) |
abstract com.gigaspaces.grid.gsm.PUDetails |
InternalAdminDriver.getPuDetails(ProcessingUnit pu) |
com.gigaspaces.grid.gsm.PUDetails |
KubernetesAdminDriver.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) |
abstract void |
InternalAdminDriver.scaleIn(ProcessingUnit pu,
int factor) |
void |
KubernetesAdminDriver.scaleIn(ProcessingUnit pu,
int factor) |
void |
ServiceGridAdminDriver.scaleOut(ProcessingUnit pu,
int factor,
String memory,
String cpu) |
abstract void |
InternalAdminDriver.scaleOut(ProcessingUnit pu,
int factor,
String memory,
String cpu) |
void |
KubernetesAdminDriver.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) |
protected abstract void |
InternalAdminDriver.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) |
CompletableFuture<?> |
InternalAdminDriver.undeployAsync(ProcessingUnit pu) |
CompletableFuture<?> |
InternalAdminDriver.undeployAsync(ProcessingUnit pu,
UndeployOptions options) |
CompletableFuture<?> |
KubernetesAdminDriver.undeployAsync(ProcessingUnit pu,
UndeployOptions options) |
Constructor and Description |
---|
UndeployListener(ProcessingUnit pu) |
Modifier and Type | Method and Description |
---|---|
ProcessingUnit |
DefaultGatewayProcessingUnit.getProcessingUnit() |
Modifier and Type | Method and Description |
---|---|
ProcessingUnit |
DefaultGridServiceManager.deploy(Application application,
ProcessingUnitDeploymentTopology deploymentTopology,
long timeout,
TimeUnit timeUnit) |
ProcessingUnit |
InternalGridServiceManagers.deploy(Application application,
ProcessingUnitDeploymentTopology puDeployment,
long timeout,
TimeUnit timeUnit) |
ProcessingUnit |
DefaultGridServiceManagers.deploy(Application application,
ProcessingUnitDeploymentTopology puDeploymentTopology,
long timeout,
TimeUnit timeUnit) |
ProcessingUnit |
InternalGridServiceManager.deploy(Application application,
ProcessingUnitDeploymentTopology deploymentTopology,
long timeout,
TimeUnit timeUnit) |
ProcessingUnit |
DefaultGridServiceManager.deploy(ProcessingUnitConfigHolder puConfigHolder) |
ProcessingUnit |
DefaultGridServiceManager.deploy(ProcessingUnitConfigHolder puConfigHolder,
long timeout,
TimeUnit timeUnit) |
ProcessingUnit |
DefaultGridServiceManager.deploy(ProcessingUnitDeployment deployment) |
ProcessingUnit |
DefaultGridServiceManagers.deploy(ProcessingUnitDeployment deployment) |
ProcessingUnit |
DefaultGridServiceManager.deploy(ProcessingUnitDeployment deployment,
long timeout,
TimeUnit timeUnit) |
ProcessingUnit |
DefaultGridServiceManagers.deploy(ProcessingUnitDeployment deployment,
long timeout,
TimeUnit timeUnit) |
ProcessingUnit |
DefaultGridServiceManager.deploy(SpaceDeployment deployment) |
ProcessingUnit |
DefaultGridServiceManagers.deploy(SpaceDeployment deployment) |
ProcessingUnit |
DefaultGridServiceManager.deploy(SpaceDeployment deployment,
long timeout,
TimeUnit timeUnit) |
ProcessingUnit |
DefaultGridServiceManagers.deploy(SpaceDeployment deployment,
long timeout,
TimeUnit timeUnit) |
Modifier and Type | Method and Description |
---|---|
boolean |
DefaultGridServiceManager.decrementPlannedInstances(ProcessingUnit processingUnit) |
boolean |
InternalGridServiceManager.decrementPlannedInstances(ProcessingUnit processingUnit)
Decrements a planned instance if the number of planned instances is less then the actual
instances to maintain.
|
void |
DefaultGridServiceManager.incrementInstance(ProcessingUnit processingUnit) |
void |
InternalGridServiceManager.incrementInstance(ProcessingUnit processingUnit) |
Modifier and Type | Method and Description |
---|---|
ProcessingUnit[] |
DefaultMachine.getProcessingUnits() |
Modifier and Type | Interface and Description |
---|---|
interface |
InternalProcessingUnit |
Modifier and Type | Class and Description |
---|---|
class |
DefaultProcessingUnit |
Modifier and Type | Method and Description |
---|---|
ProcessingUnit |
DefaultProcessingUnitInstance.getProcessingUnit() |
ProcessingUnit |
DefaultProcessingUnitPartition.getProcessingUnit() |
ProcessingUnit |
DefaultProcessingUnits.getProcessingUnit(String name) |
ProcessingUnit |
DefaultProcessingUnits.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) |
Modifier and Type | Method and Description |
---|---|
Map<String,ProcessingUnit> |
DefaultProcessingUnits.getNames() |
Iterator<ProcessingUnit> |
DefaultProcessingUnits.iterator() |
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) |
Constructor and Description |
---|
DefaultProcessingUnitPartition(ProcessingUnit processingUnit,
int patitionId) |
Modifier and Type | Method and Description |
---|---|
void |
ClosureProcessingUnitAddedEventListener.processingUnitAdded(ProcessingUnit processingUnit) |
void |
DefaultProcessingUnitAddedEventManager.processingUnitAdded(ProcessingUnit processingUnit) |
void |
DefaultProcessingUnitRemovedEventManager.processingUnitRemoved(ProcessingUnit processingUnit) |
void |
ClosureProcessingUnitRemovedEventListener.processingUnitRemoved(ProcessingUnit processingUnit) |
Constructor and Description |
---|
DefaultBackupGridServiceManagerChangedEventManager(InternalAdmin admin,
ProcessingUnit processingUnit) |
DefaultProcessingUnitStatusChangedEventManager(InternalAdmin admin,
ProcessingUnit processingUnit) |
Constructor and Description |
---|
DynamicPartitionProxy(ProcessingUnit pu,
int partitionId) |
Modifier and Type | Method and Description |
---|---|
void |
ScaleVerticalManager.scaleUpDown(ProcessingUnit pu,
String memory,
String cpu,
Long timeout,
PuScaleVStatusChangedEventListener listener,
InternalAdminDriver driver) |
Modifier and Type | Method and Description |
---|---|
ProcessingUnit[] |
Machine.getProcessingUnits() |
Modifier and Type | Method and Description |
---|---|
ProcessingUnit |
ProcessingUnitPartition.getProcessingUnit()
Returns the processing unit this partition is part of.
|
ProcessingUnit |
ProcessingUnitInstance.getProcessingUnit()
Returns the processing unit this processing unit instance belongs to.
|
ProcessingUnit |
ProcessingUnits.getProcessingUnit(String name)
Returns the
ProcessingUnit for the given processing unit
name. |
ProcessingUnit[] |
ProcessingUnits.getProcessingUnits()
Returns the
ProcessingUnit s currently deployed. |
ProcessingUnit |
ProcessingUnits.waitFor(String processingUnitName)
Waits indefinitely till the processing unit is identified as deployed.
|
ProcessingUnit |
ProcessingUnits.waitFor(String processingUnitName,
long timeout,
TimeUnit timeUnit)
Waits for the specified timeout (in time interval) till the processing unit is identified as
deployed.
|
Modifier and Type | Method and Description |
---|---|
Map<String,ProcessingUnit> |
ProcessingUnits.getNames()
Returns a map of
ProcessingUnit keyed by their respective
names. |
Modifier and Type | Method and Description |
---|---|
ProcessingUnit |
ProcessingUnitInstanceProvisionStatusChangedEvent.getProcessingUnit() |
ProcessingUnit |
BackupGridServiceManagerChangedEvent.getProcessingUnit()
Returns the Processing Unit that the backup GSM event occurred on.
|
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 |
ProcessingUnitStatusChangedEvent.getProcessingUnit()
Returns the Processing Unit that the deployment status changed for.
|
Modifier and Type | Method and Description |
---|---|
void |
ProcessingUnitAddedEventListener.processingUnitAdded(ProcessingUnit processingUnit)
A callback indicating that a Processing Unit was added (deployed/discovered).
|
void |
ProcessingUnitRemovedEventListener.processingUnitRemoved(ProcessingUnit processingUnit)
A callback indicating that a Processing Unit was removed (undeployed).
|
Modifier and Type | Method and Description |
---|---|
void |
TestEventSampler.processingUnitAdded(ProcessingUnit processingUnit) |
void |
TestEventSampler.processingUnitRemoved(ProcessingUnit processingUnit) |
Modifier and Type | Method and Description |
---|---|
static String |
GatewayUtils.extractGatewayNameIfExists(ProcessingUnit processingUnit) |
static ProcessingUnitInstance |
GatewayUtils.extractInstanceIfPuOfGateway(String gatewayName,
ProcessingUnit processingUnit) |
Copyright © GigaSpaces.