GigaSpaces XAP 7.0 API

org.openspaces.admin.pu
Interface ProcessingUnits

All Superinterfaces:
AdminAware, Iterable<ProcessingUnit>, StatisticsMonitor

public interface ProcessingUnits
extends Iterable<ProcessingUnit>, AdminAware, StatisticsMonitor

Holds one or more ProcessingUnits.

Author:
kimchy

Field Summary
 
Fields inherited from interface org.openspaces.admin.StatisticsMonitor
DEFAULT_HISTORY_SIZE, DEFAULT_MONITOR_INTERVAL
 
Method Summary
 void addLifecycleListener(ProcessingUnitInstanceLifecycleEventListener eventListener)
          Allows to add a ProcessingUnitInstanceLifecycleEventListener.
 void addLifecycleListener(ProcessingUnitLifecycleEventListener eventListener)
          Allows to add a ProcessingUnitLifecycleEventListener.
 BackupGridServiceManagerChangedEventManager getBackupGridServiceManagerChanged()
          Returns an event manager allowing to globally register for any BackupGridServiceManagerChangedEvents occurring on any processing unit.
 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.
 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.
 ProcessingUnitInstanceRemovedEventManager getProcessingUnitInstanceRemoved()
          Returns an event manager allowing to register ProcessingUnitInstanceRemovedEventListeners.
 ProcessingUnitInstanceStatisticsChangedEventManager getProcessingUnitInstanceStatisticsChange()
          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.
 void removeLifecycleListener(ProcessingUnitInstanceLifecycleEventListener eventListener)
          Allows to remove a ProcessingUnitInstanceLifecycleEventListener.
 void removeLifecycleListener(ProcessingUnitLifecycleEventListener eventListener)
          Allows to remove a ProcessingUnitLifecycleEventListener.
 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 interface java.lang.Iterable
iterator
 
Methods inherited from interface org.openspaces.admin.AdminAware
getAdmin
 
Methods inherited from interface org.openspaces.admin.StatisticsMonitor
isMonitoring, setStatisticsHistorySize, setStatisticsInterval, startStatisticsMonitor, stopStatisticsMontior
 

Method Detail

getSize

int getSize()
Returns the number of currently deployed ProcessingUnits.


isEmpty

boolean isEmpty()
Returns true if there are no currently deployed processing units.


getProcessingUnits

ProcessingUnit[] getProcessingUnits()
Returns the ProcessingUnits currently deployed.


getProcessingUnit

ProcessingUnit getProcessingUnit(String name)
Returns the ProcessingUnit for the given processing unit name.


getNames

Map<String,ProcessingUnit> getNames()
Returns a map of ProcessingUnit keyed by their respective names.


waitFor

ProcessingUnit waitFor(String processingUnitName)
Waits indefinitely till the processing unit is identified as deployed. Returns the ProcessingUnit.


waitFor

ProcessingUnit waitFor(String processingUnitName,
                       long timeout,
                       TimeUnit timeUnit)
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.


getProcessingUnitAdded

ProcessingUnitAddedEventManager getProcessingUnitAdded()
Returns an event manager allowing to register ProcessingUnitAddedEventListeners.


getProcessingUnitRemoved

ProcessingUnitRemovedEventManager getProcessingUnitRemoved()
Returns an event manager allowing to register ProcessingUnitRemovedEventListeners.


addLifecycleListener

void addLifecycleListener(ProcessingUnitLifecycleEventListener eventListener)
Allows to add a ProcessingUnitLifecycleEventListener.


removeLifecycleListener

void removeLifecycleListener(ProcessingUnitLifecycleEventListener eventListener)
Allows to remove a ProcessingUnitLifecycleEventListener.


getProcessingUnitInstanceAdded

ProcessingUnitInstanceAddedEventManager getProcessingUnitInstanceAdded()
Returns an event manager allowing to register ProcessingUnitInstanceAddedEventListeners.


getProcessingUnitInstanceRemoved

ProcessingUnitInstanceRemovedEventManager getProcessingUnitInstanceRemoved()
Returns an event manager allowing to register ProcessingUnitInstanceRemovedEventListeners.


addLifecycleListener

void addLifecycleListener(ProcessingUnitInstanceLifecycleEventListener eventListener)
Allows to add a ProcessingUnitInstanceLifecycleEventListener.


removeLifecycleListener

void removeLifecycleListener(ProcessingUnitInstanceLifecycleEventListener eventListener)
Allows to remove a ProcessingUnitInstanceLifecycleEventListener.


getManagingGridServiceManagerChanged

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


getBackupGridServiceManagerChanged

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


getProcessingUnitStatusChanged

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


getProcessingUnitInstanceStatisticsChange

ProcessingUnitInstanceStatisticsChangedEventManager getProcessingUnitInstanceStatisticsChange()
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.


GigaSpaces XAP 7.0 API

Copyright © GigaSpaces.