org.openspaces.admin.internal.pu

Interface InternalProcessingUnit

All Superinterfaces:

AdminAware, InternalApplicationAware, InternalProcessingUnitInstancesAware, Iterable<ProcessingUnitInstance>, ProcessingUnit, StatisticsMonitor

All Known Implementing Classes:

DefaultProcessingUnit

public interface InternalProcessingUnit
extends ProcessingUnit, InternalProcessingUnitInstancesAware, InternalApplicationAware

Author:

kimchy

Field Summary

Fields inherited from interface org.openspaces.admin.StatisticsMonitor

DEFAULT_HISTORY_SIZE, DEFAULT_MONITOR_INTERVAL

Method Summary

Modifier and Type	Method and Description
void	addBackupGridServiceManager(GridServiceManager backupGridServiceManager)
void	addEmbeddedSpace(Space space)
void	addManagingGridServiceManager(GridServiceManager gridServiceManager)
void	addProcessingUnitInstance(ProcessingUnitInstance processingUnitInstance)
void	addStatisticsCalculation(ProcessingUnitStatisticsId statisticsId) Adds the specified statistics calculation
void	cancelScaleOut()
boolean	decrementPlannedInstances() Decrements a planned instance if the number of planned instances is less then the actual instances to maintain.
String	getApplicationDependencies() Retrieves a context property containing the order of dependencies within an application.
String	getApplicationName()
String	getClusterSchema()
ClusterTopology	getClusterTopology()
Map<String,String>	getElasticProperties()
ExactZonesConfig	getHostingGridServiceAgentZones(ProcessingUnitInstance processingUnitInstance) return the exact zones of the agent that belongs to processing unit instance
ProcessingUnitInstance	getProcessingUnitInstanceByUid(String uid) returns the processing unit instance based on its uid (see GridComponent.getUid())
Map<String,InternalProvisionStatusHolder>	getProvisionStatusPerInstance()
ScaleStrategyConfig	getScaleStrategyConfig() Returns the current scale strategy config
String	getSimpleName() In the case of application name prefix just processing unit name will be returned.
ProcessingUnitStatistics	getStatistics()
Set<ProcessingUnitStatisticsId>	getStatisticsCalculations()
boolean	isBackupGsmInSync()
boolean	isStandaloneProcessingUnit()
boolean	isStub()
SharedLock	lock()
SharedLock	lock(long timeout, TimeUnit timeunit)
void	processProvisionEvent(org.jini.rio.monitor.ProvisionLifeCycleEvent provisionLifeCycleEvent)
void	removeBackupGridServiceManager(String gsmUID)
boolean	removeEmbeddedSpace(Space space)
void	removeProcessingUnitInstance(String uid)
void	removeStatisticsCalculation(ProcessingUnitStatisticsId statisticsId) Removes the specified statistics calculation
void	scaleHorizontal(int target, String memory, String cpu)
void	scaleVertical(String memory, String cpu, Long timeout, PuScaleVStatusChangedEventListener listener)
void	setBackupGsmInSync(boolean isBackupInSync)
void	setManagingGridServiceManager(GridServiceManager gridServiceManager)
void	setNumberOfBackups(int numberOfBackups)
void	setNumberOfInstances(int numberOfInstances)
boolean	setStatus(int statusCode)
void	setStub(boolean stub)
void	updateStub(ProcessingUnitInstance processingUnitInstance)

Methods inherited from interface org.openspaces.admin.pu.ProcessingUnit

addLifecycleListener, canDecrementInstance, canIncrementInstance, decrementInstance, getApplication, getArchiveName, getBackupGridServiceManager, getBackupGridServiceManagerChanged, getBackupGridServiceManagers, getBeanLevelProperties, getDependencies, getGridServiceContainers, getInstances, getManagingGridServiceManager, getManagingGridServiceManagerChanged, getMaxInstancesPerMachine, getMaxInstancesPerVM, getMaxInstancesPerZone, getName, getNumberOfBackups, getNumberOfInstances, getPartition, getPartitions, getPlannedNumberOfInstances, getPlannedNumberOfPartitions, getPrimaryZones, getProcessingUnitInstance, getProcessingUnitInstanceAdded, getProcessingUnitInstanceMemberAliveIndicatorStatusChanged, getProcessingUnitInstanceProvisionStatusChanged, getProcessingUnitInstanceRemoved, getProcessingUnitInstanceStatisticsChanged, getProcessingUnits, getProcessingUnitStatusChanged, getQuiesceDetails, getRequiredContainerZones, getRequiredZones, getSpace, getSpaceCorrelated, getSpaces, getStatus, getTotalNumberOfInstances, getType, hasSpace, incrementInstance, isManaged, isRequiresIsolation, quiesce, removeLifecycleListener, scale, scaleAndWait, scaleAndWait, setLogLevel, undeploy, undeployAndWait, undeployAndWait, undeployAsync, undeployAsync, unquiesce, waitFor, waitFor, waitFor, waitFor, waitForManaged, waitForManaged, waitForSpace, waitForSpace

Methods inherited from interface java.lang.Iterable

forEach, iterator, spliterator

Methods inherited from interface org.openspaces.admin.AdminAware

getAdmin

Methods inherited from interface org.openspaces.admin.StatisticsMonitor

isMonitoring, setStatisticsHistorySize, setStatisticsInterval, startStatisticsMonitor, stopStatisticsMonitor

Methods inherited from interface org.openspaces.admin.internal.pu.InternalProcessingUnitInstancesAware

getProcessingUnitInstances

Methods inherited from interface org.openspaces.admin.internal.application.InternalApplicationAware

setApplication

Method Detail

setNumberOfInstances

void setNumberOfInstances(int numberOfInstances)

setNumberOfBackups

void setNumberOfBackups(int numberOfBackups)

setManagingGridServiceManager

void setManagingGridServiceManager(GridServiceManager gridServiceManager)

addManagingGridServiceManager

void addManagingGridServiceManager(GridServiceManager gridServiceManager)

addBackupGridServiceManager

void addBackupGridServiceManager(GridServiceManager backupGridServiceManager)

removeBackupGridServiceManager

void removeBackupGridServiceManager(String gsmUID)

setStatus

boolean setStatus(int statusCode)

addProcessingUnitInstance

void addProcessingUnitInstance(ProcessingUnitInstance processingUnitInstance)

removeProcessingUnitInstance

void removeProcessingUnitInstance(String uid)

addEmbeddedSpace

void addEmbeddedSpace(Space space)

removeEmbeddedSpace

boolean removeEmbeddedSpace(Space space)

Since:

9.1.0

getElasticProperties

Map<String,String> getElasticProperties()

getApplicationName

String getApplicationName()

getClusterSchema

String getClusterSchema()

getSimpleName

String getSimpleName()

In the case of application name prefix just processing unit name will be returned. Otherwise name will be returned.

Since:

8.0.6

getApplicationDependencies

String getApplicationDependencies()

Retrieves a context property containing the order of dependencies within an application.

Returns:

The property value, in a CSV format.

Since:

8.0.4

getScaleStrategyConfig

ScaleStrategyConfig getScaleStrategyConfig()

Returns the current scale strategy config

Since:

8.0.3

decrementPlannedInstances

boolean decrementPlannedInstances()

Decrements a planned instance if the number of planned instances is less then the actual instances to maintain.

Returns:

true if a planned instance was successfully decremented; false planned instances hasn't changed.

Since:

8.0.4

processProvisionEvent

void processProvisionEvent(org.jini.rio.monitor.ProvisionLifeCycleEvent provisionLifeCycleEvent)

Since:

8.0.6

getProvisionStatusPerInstance

Map<String,InternalProvisionStatusHolder> getProvisionStatusPerInstance()

Since:

8.0.6

getStatistics

ProcessingUnitStatistics getStatistics()

Returns:

the processing unit (aggregated) statistics.

Since:

9.0.0

addStatisticsCalculation

void addStatisticsCalculation(ProcessingUnitStatisticsId statisticsId)

Adds the specified statistics calculation

Since:

9.0.0

removeStatisticsCalculation

void removeStatisticsCalculation(ProcessingUnitStatisticsId statisticsId)

Removes the specified statistics calculation

Since:

9.0.0

getStatisticsCalculations

Set<ProcessingUnitStatisticsId> getStatisticsCalculations()

Returns:

the generated statistics identifiers.

Since:

9.0.0

getHostingGridServiceAgentZones

ExactZonesConfig getHostingGridServiceAgentZones(ProcessingUnitInstance processingUnitInstance)
                                          throws AdminException

return the exact zones of the agent that belongs to processing unit instance

Throws:

AdminException

Since:

9.1.0

setBackupGsmInSync

void setBackupGsmInSync(boolean isBackupInSync)

Parameters:

isBackupInSync - - true if backup GSM is in sync with primary GSM, false if out of sync.

isBackupGsmInSync

boolean isBackupGsmInSync()

Returns:

true if backup GSM is in sync with primary GSM, false if out of sync or no backup gsm.

getProcessingUnitInstanceByUid

ProcessingUnitInstance getProcessingUnitInstanceByUid(String uid)

returns the processing unit instance based on its uid (see GridComponent.getUid())

Parameters:

uid - the unique id of the processing unit instance

Returns:

the processing unit instance or null

Since:

10.1.1

isStandaloneProcessingUnit

boolean isStandaloneProcessingUnit()

Returns:

true if this processing unit is un-managed by the Service Grid.

Since:

14.0.0

scaleHorizontal

void scaleHorizontal(int target,
                     String memory,
                     String cpu)

scaleVertical

void scaleVertical(String memory,
                   String cpu,
                   Long timeout,
                   PuScaleVStatusChangedEventListener listener)

cancelScaleOut

void cancelScaleOut()
             throws IOException,
                    InterruptedException,
                    TimeoutException

Throws:

IOException

InterruptedException

TimeoutException

getClusterTopology

ClusterTopology getClusterTopology()
                            throws IOException

Throws:

IOException

lock

SharedLock lock()
         throws IOException,
                TimeoutException,
                InterruptedException

Throws:

IOException

TimeoutException

InterruptedException

lock

SharedLock lock(long timeout,
                TimeUnit timeunit)
         throws IOException,
                TimeoutException,
                InterruptedException

Throws:

IOException

TimeoutException

InterruptedException

setStub

void setStub(boolean stub)

Parameters:

stub - - true if PU was created before any instance

isStub

boolean isStub()

updateStub

void updateStub(ProcessingUnitInstance processingUnitInstance)