org.openspaces.admin.internal.pu

Class DefaultProcessingUnits

java.lang.Object

org.openspaces.admin.internal.pu.DefaultProcessingUnits

All Implemented Interfaces:

Iterable<ProcessingUnit>, AdminAware, InternalProcessingUnitInstancesAware, InternalProcessingUnits, ProcessingUnits, StatisticsMonitor

public class DefaultProcessingUnits
extends Object
implements InternalProcessingUnits

Author:

kimchy

Field Summary

Fields inherited from interface org.openspaces.admin.StatisticsMonitor

DEFAULT_HISTORY_SIZE, DEFAULT_MONITOR_INTERVAL

Constructor Summary

Constructors

Constructor and Description
DefaultProcessingUnits(InternalAdmin admin)

Method Summary

Modifier and Type	Method and Description
void	addLifecycleListener(ProcessingUnitInstanceLifecycleEventListener eventListener) Allows to add a ProcessingUnitInstanceLifecycleEventListener.
void	addLifecycleListener(ProcessingUnitLifecycleEventListener eventListener) Allows to add a ProcessingUnitLifecycleEventListener.
void	addProcessingUnit(ProcessingUnit processingUnit)
Admin	getAdmin() Returns the Admin associated with this element.
BackupGridServiceManagerChangedEventManager	getBackupGridServiceManagerChanged() Returns an event manager allowing to globally register for any BackupGridServiceManagerChangedEvents occurring on any processing unit.
ElasticAutoScalingFailureEventManager	getElasticAutoScalingFailure()
ElasticAutoScalingProgressChangedEventManager	getElasticAutoScalingProgressChanged()
ManagingGridServiceManagerChangedEventManager	getManagingGridServiceManagerChanged() Returns an event manager allowing to globally register for any ManagingGridServiceManagerChangedEvents occurring on any processing unit.
Map<String,ProcessingUnit>	getNames() Returns a map of ProcessingUnit keyed by their respective names.
Integer	getPlannedNumberOfInstancesOfElasticPU(ProcessingUnit pu)
ProcessingUnit	getProcessingUnit(String name) Returns the ProcessingUnit for the given processing unit name.
ProcessingUnitAddedEventManager	getProcessingUnitAdded() Returns an event manager allowing to register ProcessingUnitAddedEventListeners.
ProcessingUnitInstanceAddedEventManager	getProcessingUnitInstanceAdded() Returns an event manager allowing to register ProcessingUnitInstanceAddedEventListeners.
ProcessingUnitInstanceMemberAliveIndicatorStatusChangedEventManager	getProcessingUnitInstanceMemberAliveIndicatorStatusChanged() Returns an event manager allowing to register ProcessingUnitInstanceMemberAliveIndicatorStatusChangedEventListeners.
ProcessingUnitInstanceProvisionStatusChangedEventManager	getProcessingUnitInstanceProvisionStatusChanged() Returns an event manager allowing to register ProcessingUnitInstanceProvisionStatusChangedEventListeners.
ProcessingUnitInstanceRemovedEventManager	getProcessingUnitInstanceRemoved() Returns an event manager allowing to register ProcessingUnitInstanceRemovedEventListeners.
ProcessingUnitInstance[]	getProcessingUnitInstances()
ProcessingUnitInstanceStatisticsChangedEventManager	getProcessingUnitInstanceStatisticsChanged() Returns a processing unit instance statistics change event manger allowing to register for events of ProcessingUnitInstanceStatisticsChangedEvent.
ProcessingUnitRemovedEventManager	getProcessingUnitRemoved() Returns an event manager allowing to register ProcessingUnitRemovedEventListeners.
ProcessingUnit[]	getProcessingUnits() Returns the ProcessingUnits currently deployed.
ProcessingUnitStatusChangedEventManager	getProcessingUnitStatusChanged() Returns an event manager allowing to globally register for any ProcessingUnitSpaceCorrelatedEvents occurring on any processing unit.
int	getSize() Returns the number of currently deployed ProcessingUnits.
boolean	isEmpty() Returns true if there are no currently deployed processing units.
boolean	isMonitoring() Returns true if statistics are now being monitored.
Iterator<ProcessingUnit>	iterator()
void	processElasticScaleStrategyEvent(ElasticProcessingUnitEvent event) If relevant raises events to relevant subscribers
ProcessingUnit	removeEmbeddedSpace(InternalSpace space) Removes the reference to the specified space from the hosting processing unit.
void	removeLifecycleListener(ProcessingUnitInstanceLifecycleEventListener eventListener) Allows to remove a ProcessingUnitInstanceLifecycleEventListener.
void	removeLifecycleListener(ProcessingUnitLifecycleEventListener eventListener) Allows to remove a ProcessingUnitLifecycleEventListener.
void	removeProcessingUnit(String name)
void	setStatisticsHistorySize(int historySize) Sets the history size of number of statistics stored.
void	setStatisticsInterval(long interval, TimeUnit timeUnit) Sets the statistics interval, automatically updating the monitoring scheduled tasks if monitoring is enabled.
void	startStatisticsMonitor() Starts the statistics monitor, starting a scheduled monitor that polls for statistics.
void	stopStatisticsMonitor() Stops the statistics monitor.
ProcessingUnit	waitFor(String processingUnitName) Waits indefinitely till the processing unit is identified as deployed.
ProcessingUnit	waitFor(String processingUnitName, long timeout, TimeUnit timeUnit) Waits for the specified timeout (in time interval) till the processing unit is identified as deployed.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Constructor Detail

DefaultProcessingUnits

public DefaultProcessingUnits(InternalAdmin admin)

Method Detail

getAdmin

public Admin getAdmin()

Description copied from interface: AdminAware

Returns the Admin associated with this element.

Specified by:

getAdmin in interface AdminAware

getProcessingUnitAdded

public ProcessingUnitAddedEventManager getProcessingUnitAdded()

Description copied from interface: ProcessingUnits

Returns an event manager allowing to register ProcessingUnitAddedEventListeners.

Specified by:

getProcessingUnitAdded in interface ProcessingUnits

getProcessingUnitRemoved

public ProcessingUnitRemovedEventManager getProcessingUnitRemoved()

Description copied from interface: ProcessingUnits

Returns an event manager allowing to register ProcessingUnitRemovedEventListeners.

Specified by:

getProcessingUnitRemoved in interface ProcessingUnits

getManagingGridServiceManagerChanged

public ManagingGridServiceManagerChangedEventManager getManagingGridServiceManagerChanged()

Description copied from interface: ProcessingUnits

Returns an event manager allowing to globally register for any ManagingGridServiceManagerChangedEvents occurring on any processing unit.

Specified by:

getManagingGridServiceManagerChanged in interface ProcessingUnits

getBackupGridServiceManagerChanged

public BackupGridServiceManagerChangedEventManager getBackupGridServiceManagerChanged()

Description copied from interface: ProcessingUnits

Returns an event manager allowing to globally register for any BackupGridServiceManagerChangedEvents occurring on any processing unit.

Specified by:

getBackupGridServiceManagerChanged in interface ProcessingUnits

getProcessingUnitStatusChanged

public ProcessingUnitStatusChangedEventManager getProcessingUnitStatusChanged()

Description copied from interface: ProcessingUnits

Returns an event manager allowing to globally register for any ProcessingUnitSpaceCorrelatedEvents occurring on any processing unit.

Specified by:

getProcessingUnitStatusChanged in interface ProcessingUnits

getProcessingUnitInstanceAdded

public ProcessingUnitInstanceAddedEventManager getProcessingUnitInstanceAdded()

Description copied from interface: ProcessingUnits

Returns an event manager allowing to register ProcessingUnitInstanceAddedEventListeners.

Specified by:

getProcessingUnitInstanceAdded in interface ProcessingUnits

getProcessingUnitInstanceRemoved

public ProcessingUnitInstanceRemovedEventManager getProcessingUnitInstanceRemoved()

Description copied from interface: ProcessingUnits

Returns an event manager allowing to register ProcessingUnitInstanceRemovedEventListeners.

Specified by:

getProcessingUnitInstanceRemoved in interface ProcessingUnits

iterator

public Iterator<ProcessingUnit> iterator()

Specified by:

iterator in interface Iterable<ProcessingUnit>

getProcessingUnits

public ProcessingUnit[] getProcessingUnits()

Description copied from interface: ProcessingUnits

Returns the ProcessingUnits currently deployed.

Specified by:

getProcessingUnits in interface ProcessingUnits

getProcessingUnitInstances

public ProcessingUnitInstance[] getProcessingUnitInstances()

Specified by:

getProcessingUnitInstances in interface InternalProcessingUnitInstancesAware

getProcessingUnit

public ProcessingUnit getProcessingUnit(String name)

Description copied from interface: ProcessingUnits

Returns the ProcessingUnit for the given processing unit name.

Specified by:

getProcessingUnit in interface ProcessingUnits

getNames

public Map<String,ProcessingUnit> getNames()

Description copied from interface: ProcessingUnits

Returns a map of ProcessingUnit keyed by their respective names.

Specified by:

getNames in interface ProcessingUnits

getSize

public int getSize()

Description copied from interface: ProcessingUnits

Returns the number of currently deployed ProcessingUnits.

Specified by:

getSize in interface ProcessingUnits

isEmpty

public boolean isEmpty()

Description copied from interface: ProcessingUnits

Returns true if there are no currently deployed processing units.

Specified by:

isEmpty in interface ProcessingUnits

waitFor

public ProcessingUnit waitFor(String processingUnitName)

Description copied from interface: ProcessingUnits

Waits indefinitely till the processing unit is identified as deployed. Returns the ProcessingUnit.

Specified by:

waitFor in interface ProcessingUnits

waitFor

public ProcessingUnit waitFor(String processingUnitName,
                              long timeout,
                              TimeUnit timeUnit)

Description copied from interface: ProcessingUnits

Waits for the specified timeout (in time interval) till the processing unit is identified as deployed. Returns the ProcessingUnit. Return null if the processing unit is not deployed within the specified timeout.

Specified by:

waitFor in interface ProcessingUnits

addLifecycleListener

public void addLifecycleListener(ProcessingUnitLifecycleEventListener eventListener)

Description copied from interface: ProcessingUnits

Allows to add a ProcessingUnitLifecycleEventListener.

Specified by:

addLifecycleListener in interface ProcessingUnits

removeLifecycleListener

public void removeLifecycleListener(ProcessingUnitLifecycleEventListener eventListener)

Description copied from interface: ProcessingUnits

Allows to remove a ProcessingUnitLifecycleEventListener.

Specified by:

removeLifecycleListener in interface ProcessingUnits

addLifecycleListener

public void addLifecycleListener(ProcessingUnitInstanceLifecycleEventListener eventListener)

Description copied from interface: ProcessingUnits

Allows to add a ProcessingUnitInstanceLifecycleEventListener.

Specified by:

addLifecycleListener in interface ProcessingUnits

removeLifecycleListener

public void removeLifecycleListener(ProcessingUnitInstanceLifecycleEventListener eventListener)

Description copied from interface: ProcessingUnits

Allows to remove a ProcessingUnitInstanceLifecycleEventListener.

Specified by:

removeLifecycleListener in interface ProcessingUnits

addProcessingUnit

public void addProcessingUnit(ProcessingUnit processingUnit)

Specified by:

addProcessingUnit in interface InternalProcessingUnits

removeProcessingUnit

public void removeProcessingUnit(String name)

Specified by:

removeProcessingUnit in interface InternalProcessingUnits

getProcessingUnitInstanceStatisticsChanged

public ProcessingUnitInstanceStatisticsChangedEventManager getProcessingUnitInstanceStatisticsChanged()

Description copied from interface: ProcessingUnits

Returns a processing unit instance statistics change event manger allowing to register for events of ProcessingUnitInstanceStatisticsChangedEvent.

Note, in order to receive events, the virtual machines need to be in a "statistics" monitored state.

Specified by:

getProcessingUnitInstanceStatisticsChanged in interface ProcessingUnits

getProcessingUnitInstanceProvisionStatusChanged

public ProcessingUnitInstanceProvisionStatusChangedEventManager getProcessingUnitInstanceProvisionStatusChanged()

Description copied from interface: ProcessingUnits

Returns an event manager allowing to register ProcessingUnitInstanceProvisionStatusChangedEventListeners.

Specified by:

getProcessingUnitInstanceProvisionStatusChanged in interface ProcessingUnits

getProcessingUnitInstanceMemberAliveIndicatorStatusChanged

public ProcessingUnitInstanceMemberAliveIndicatorStatusChangedEventManager getProcessingUnitInstanceMemberAliveIndicatorStatusChanged()

Description copied from interface: ProcessingUnits

Returns an event manager allowing to register ProcessingUnitInstanceMemberAliveIndicatorStatusChangedEventListeners.

Specified by:

getProcessingUnitInstanceMemberAliveIndicatorStatusChanged in interface ProcessingUnits

setStatisticsInterval

public void setStatisticsInterval(long interval,
                                  TimeUnit timeUnit)

Description copied from interface: StatisticsMonitor

Sets the statistics interval, automatically updating the monitoring scheduled tasks if monitoring is enabled.

Specified by:

setStatisticsInterval in interface StatisticsMonitor

setStatisticsHistorySize

public void setStatisticsHistorySize(int historySize)

Description copied from interface: StatisticsMonitor

Sets the history size of number of statistics stored.

Specified by:

setStatisticsHistorySize in interface StatisticsMonitor

startStatisticsMonitor

public void startStatisticsMonitor()

Description copied from interface: StatisticsMonitor

Starts the statistics monitor, starting a scheduled monitor that polls for statistics. Monitoring is required only when wanting to receive statistics change events.

Specified by:

startStatisticsMonitor in interface StatisticsMonitor

stopStatisticsMonitor

public void stopStatisticsMonitor()

Description copied from interface: StatisticsMonitor

Stops the statistics monitor.

Specified by:

stopStatisticsMonitor in interface StatisticsMonitor

isMonitoring

public boolean isMonitoring()

Description copied from interface: StatisticsMonitor

Returns true if statistics are now being monitored.

Specified by:

isMonitoring in interface StatisticsMonitor

getElasticAutoScalingProgressChanged

public ElasticAutoScalingProgressChangedEventManager getElasticAutoScalingProgressChanged()

Specified by:

getElasticAutoScalingProgressChanged in interface ProcessingUnits

Returns:

an event manager allowing to register ElasticAutoScalingProgressChangedEventListeners

getElasticAutoScalingFailure

public ElasticAutoScalingFailureEventManager getElasticAutoScalingFailure()

Specified by:

getElasticAutoScalingFailure in interface ProcessingUnits

Returns:

an event manager allowing to register ElasticAutoScalingFailureEventListeners

processElasticScaleStrategyEvent

public void processElasticScaleStrategyEvent(ElasticProcessingUnitEvent event)

Description copied from interface: InternalProcessingUnits

If relevant raises events to relevant subscribers

Specified by:

processElasticScaleStrategyEvent in interface InternalProcessingUnits

removeEmbeddedSpace

public ProcessingUnit removeEmbeddedSpace(InternalSpace space)

Description copied from interface: InternalProcessingUnits

Removes the reference to the specified space from the hosting processing unit.

Specified by:

removeEmbeddedSpace in interface InternalProcessingUnits

Returns:

the hosting processing unit from which the space was removed, or null if such a processing unit was not found

getPlannedNumberOfInstancesOfElasticPU

public Integer getPlannedNumberOfInstancesOfElasticPU(ProcessingUnit pu)

Specified by:

getPlannedNumberOfInstancesOfElasticPU in interface InternalProcessingUnits

Returns:

The planned number of instances for the specified pu name, regardless of the GSM and the LUS status of this pu. Or null if not managed by ESM.

See Also:

ProcessingUnit.getPlannedNumberOfInstances()