org.openspaces.admin.internal.admin

Class DefaultAdmin

java.lang.Object

org.openspaces.admin.internal.admin.DefaultAdmin

All Implemented Interfaces:

Admin, DumpProvider, InternalAdmin, StatisticsMonitor

public class DefaultAdmin
extends Object
implements InternalAdmin

Author:

kimchy, itaif - added Applications

Field Summary

Fields inherited from interface org.openspaces.admin.StatisticsMonitor

DEFAULT_HISTORY_SIZE, DEFAULT_MONITOR_INTERVAL

Constructor Summary

Constructors

Constructor and Description
DefaultAdmin(boolean useDaemonThreads, boolean singleThreadedEventListeners)

Method Summary

Modifier and Type	Method and Description
void	addEventListener(AdminEventListener eventListener) Smart addition of event listeners.
void	addEventListener(AdminEventListener eventListener, boolean withStatisticsHistory) Smart addition of event listeners.
void	addGatewayProcessingUnit(GatewayProcessingUnit gatewayProcessingUnit)
void	addGridServiceAgent(InternalGridServiceAgent gridServiceAgent, NIODetails nioDetails, OSDetails osDetails, JVMDetails jvmDetails, String jmxUrl, String[] zones)
void	addGridServiceContainer(InternalGridServiceContainer gridServiceContainer, NIODetails nioDetails, OSDetails osDetails, JVMDetails jvmDetails, String jmxUrl, String[] zones)
void	addGridServiceManager(InternalGridServiceManager gridServiceManager, NIODetails nioDetails, OSDetails osDetails, JVMDetails jvmDetails, String jmxUrl, String[] zones, boolean acceptVM)
void	addGroup(String group)
void	addLocator(String locator)
void	addLookupService(InternalLookupService lookupService, NIODetails nioDetails, OSDetails osDetails, JVMDetails jvmDetails, String jmxUrl, String[] zones)
void	addProcessingUnitInstance(InternalProcessingUnitInstance processingUnitInstance, NIODetails nioDetails, OSDetails osDetails, JVMDetails jvmDetails, String jmxUrl, String[] zones)
void	addSpaceInstance(InternalSpaceInstance spaceInstance, NIODetails nioDetails, OSDetails osDetails, JVMDetails jvmDetails, String jmxUrl, String[] zones)
void	assertStateChangesPermitted()
void	begin()
void	close() Closes the Admin, releasing any resource and stops listening for events from the lookup service.
protected void	executeScaleThread()
void	flushEvents()
void	flushScheduleMonitorCorrelatedEvents()
DumpResult	generateDump(Set<DumpProvider> dumpProviders, DumpGeneratedListener listener, String cause, Map<String,Object> context, String... processor) Generates dump for an explicit set of dump providers.
DumpResult	generateDump(String cause, Map<String,Object> context) Generates dump for all the provided dump processors.
DumpResult	generateDump(String cause, Map<String,Object> context, String... processor) Generates dump for the provided processors.
AdminFilter	getAdminFilter()
org.apache.commons.logging.Log	getAdminLogger()
AlertManager	getAlertManager() Returns the alert manager through which alert strategies are managed, alerts are fired and alert events are registered for.
Applications	getApplications()
org.openspaces.zookeeper.attribute_store.ZooKeeperAttributeStore	getAttributeStore()
CredentialsProvider	getCredentialsProvider()
long	getDefaultTimeout()
TimeUnit	getDefaultTimeoutTimeUnit()
DiscoveryService	getDiscoveryService()
InternalAdminDriver	getDriver()
InternalAdminDriver	getDriverIfActive()
int	getEventListenersCount() Returns number of registered event listeners.
GatewayProcessingUnits	getGatewayProcessingUnits() Returns the Gateway Processing Units discovered.
Gateways	getGateways() Returns the gateways discovered.
GridComponent	getGridComponentByUID(String uid) Returns the Grid Component represented by this UID; e.g.
GridServiceAgents	getGridServiceAgents() Returns the grid service agents discovered.
GridServiceContainers	getGridServiceContainers() Returns the grid service containers discovered.
GridServiceManagers	getGridServiceManagers() Returns the grid service managers discovered.
String[]	getGroups() Returns the lookup groups this admin uses.
ScheduledThreadPoolExecutor	getHorizontalScaleScheduledExecutorService()
LookupLocator[]	getLocators() Returns the lookup locators this admin uses.
LookupServices	getLookupServices() Returns the lookup services discovered.
Machines	getMachines() Returns the machines discovered.
ManagerClusterInfo	getManagerClusterInfo() Returns the cluster manager information (if not initialized yet - return null)
OperatingSystems	getOperatingSystems() Returns the Operating Systems discovered.
ProcessingUnitInstance[]	getOrphanProcessingUnitInstances()
ProcessingUnits	getProcessingUnits() Returns the Processing Units discovered.
ScaleManager	getScaleManager()
ScaleVerticalManager	getScaleVerticalManager()
long	getScheduledSpaceMonitorInterval()
ScheduledThreadPoolExecutor	getScheduler()
SharedLockProvider	getSharedLockProvider()
Spaces	getSpaces() Returns the spaces discovered.
Transports	getTransports() Returns the transports discovered.
VirtualMachines	getVirtualMachines() Returns the Virtual Machines discovered.
Zones	getZones() Returns the zones discovered.
void	initManagerClusterInfo(ManagerClusterInfo extractedClusterInfo)
boolean	isMonitoring() Returns true if statistics are now being monitored.
boolean	isSingleThreadedEventListeners()
void	login(SecuredService service)
void	pushEvent(Object listener, Runnable notifier)
void	pushEventAsFirst(Object listener, Runnable notifier)
void	pushScheduleMonitorCorrelatedEvent(Object listener, Runnable notifier) All events that need to be correlated with the Admin ScheduledMonitor polling mechanism.
void	raiseEvent(Object listener, Runnable notifier)
void	removeEventListener(AdminEventListener eventListener) Smart removal of event listeners.
void	removeGatewayProcessingUnit(String uid)
void	removeGridServiceAgent(String uid)
void	removeGridServiceContainer(String uid)
void	removeGridServiceManager(String uid)
void	removeLookupService(String uid)
void	removeProcessingUnitInstance(String uid, boolean removeEmbeddedSpaces)
void	removeSpaceInstance(String uid)
void	scheduleAdminOperation(Runnable command) A generic thread pool for network based operations such as creating a new grid service container.
void	scheduleNonBlockingStateChange(Runnable command) Any internal admin objects state change must be scheduled using this method.
ScheduledFuture<?>	scheduleOneTimeWithDelayNonBlockingStateChange(Runnable command, long delay, TimeUnit unit) Any internal delayed admin objects state change based on polling must be scheduled using this method.
ScheduledFuture<?>	scheduleWithFixedDelay(Runnable command, long initialDelay, long delay, TimeUnit unit)
ScheduledFuture<?>	scheduleWithFixedDelayNonBlockingStateChange(Runnable command, long initialDelay, long delay, TimeUnit unit) Any internal admin objects state change based on polling must be scheduled using this method.
void	setAdminFilter(AdminFilter adminFilter)
void	setAgentProcessessMonitorInterval(long interval, TimeUnit timeUnit) Sets the Grid Service Agent processes monitor (not statistics) interval.
void	setCredentialsProvider(CredentialsProvider credentialsProvider)
void	setDefaultTimeout(long timeout, TimeUnit timeUnit) The default timeout to be used for operations that have a wait for mechanism, i.e.
void	setDiscoveryServices(Class... discoveryServices) Set the service types that will be monitored Supported types: GridServiceAgent, GridServiceManager, GridServiceContainer, ProcessingUnit, Space
void	setProcessingUnitMonitorInterval(long interval, TimeUnit timeUnit) Sets the processing unit monitor (not statistics) interval.
void	setSchedulerCorePoolSize(int coreThreads) The Admin API uses a shared scheduler thread pool to perform *all* scheduled operations (monitoring, statistics monitoring).
void	setSpaceMonitorInterval(long interval, TimeUnit timeUnit) Sets the Space monitor (not statistics) interval.
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.
InternalAdminDriver	waitForDriver()
ManagerClusterInfo	waitForManagerClusterInfo() Waits indefinitely for the cluster manager information to be initialized, then return it
ManagerClusterInfo	waitForManagerClusterInfo(long timeout, TimeUnit timeUnit) Waits for the specified timeout for the cluster manager information to be initialized, then return it.

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultAdmin

public DefaultAdmin(boolean useDaemonThreads,
                    boolean singleThreadedEventListeners)

Parameters:

useDaemonThreads - Sets worker and events threads to be automatically closed when the process dies.

singleThreadedEventListeners - Enables a single event loop threading model in which all event listeners and admin state updates are done on the same thread. The underlying assumption is that event listeners do not perform an I/O operation so they won't block the single event thread. Call this method before begin()

Method Detail

getAdminLogger

public org.apache.commons.logging.Log getAdminLogger()

Specified by:

getAdminLogger in interface InternalAdmin

getGroups

public String[] getGroups()

Description copied from interface: Admin

Returns the lookup groups this admin uses.

Specified by:

getGroups in interface Admin

See Also:

AdminFactory.addGroup(String)

getLocators

public LookupLocator[] getLocators()

Description copied from interface: Admin

Returns the lookup locators this admin uses.

Specified by:

getLocators in interface Admin

See Also:

AdminFactory.addLocator(String)

getDriver

public InternalAdminDriver getDriver()

Specified by:

getDriver in interface InternalAdmin

getHorizontalScaleScheduledExecutorService

public ScheduledThreadPoolExecutor getHorizontalScaleScheduledExecutorService()

waitForDriver

public InternalAdminDriver waitForDriver()

Specified by:

waitForDriver in interface InternalAdmin

initManagerClusterInfo

public void initManagerClusterInfo(ManagerClusterInfo extractedClusterInfo)

Specified by:

initManagerClusterInfo in interface InternalAdmin

executeScaleThread

protected void executeScaleThread()

getDriverIfActive

public InternalAdminDriver getDriverIfActive()
                                      throws UnknownHostException

Throws:

UnknownHostException

getManagerClusterInfo

public ManagerClusterInfo getManagerClusterInfo()

Description copied from interface: Admin

Returns the cluster manager information (if not initialized yet - return null)

Specified by:

getManagerClusterInfo in interface Admin

See Also:

Admin.waitForManagerClusterInfo()

waitForManagerClusterInfo

public ManagerClusterInfo waitForManagerClusterInfo()

Description copied from interface: Admin

Waits indefinitely for the cluster manager information to be initialized, then return it

Specified by:

waitForManagerClusterInfo in interface Admin

waitForManagerClusterInfo

public ManagerClusterInfo waitForManagerClusterInfo(long timeout,
                                                    TimeUnit timeUnit)

Description copied from interface: Admin

Waits for the specified timeout for the cluster manager information to be initialized, then return it. If the timeout elapses before initialization - return null.

Specified by:

waitForManagerClusterInfo in interface Admin

login

public void login(SecuredService service)
           throws SecurityException,
                  RemoteException

Specified by:

login in interface InternalAdmin

Throws:

SecurityException

RemoteException

setCredentialsProvider

public void setCredentialsProvider(CredentialsProvider credentialsProvider)

getCredentialsProvider

public CredentialsProvider getCredentialsProvider()

Specified by:

getCredentialsProvider in interface InternalAdmin

Since:

12.1

getAttributeStore

public org.openspaces.zookeeper.attribute_store.ZooKeeperAttributeStore getAttributeStore()

Specified by:

getAttributeStore in interface InternalAdmin

getSharedLockProvider

public SharedLockProvider getSharedLockProvider()

Specified by:

getSharedLockProvider in interface InternalAdmin

getScaleManager

public ScaleManager getScaleManager()

Specified by:

getScaleManager in interface InternalAdmin

getScaleVerticalManager

public ScaleVerticalManager getScaleVerticalManager()

Specified by:

getScaleVerticalManager in interface InternalAdmin

addGroup

public void addGroup(String group)

addLocator

public void addLocator(String locator)

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

begin

public void begin()

setProcessingUnitMonitorInterval

public void setProcessingUnitMonitorInterval(long interval,
                                             TimeUnit timeUnit)

Description copied from interface: Admin

Sets the processing unit monitor (not statistics) interval. The monitor basically checks the status of each processing unit (ProcessingUnit.getStatus() among other things.

Defaults to 1 second.

Specified by:

setProcessingUnitMonitorInterval in interface Admin

Parameters:

interval - The interval to use.

timeUnit - The time unit the interval is at.

setAgentProcessessMonitorInterval

public void setAgentProcessessMonitorInterval(long interval,
                                              TimeUnit timeUnit)

Description copied from interface: Admin

Sets the Grid Service Agent processes monitor (not statistics) interval. The monitor basically updates the list of processes the agent manages (GridServiceAgent.getProcessesDetails().

Defaults to 5 seconds.

Specified by:

setAgentProcessessMonitorInterval in interface Admin

Parameters:

interval - The interval to use.

timeUnit - The time unit the interval is at.

getScheduledSpaceMonitorInterval

public long getScheduledSpaceMonitorInterval()

Specified by:

getScheduledSpaceMonitorInterval in interface InternalAdmin

getDefaultTimeout

public long getDefaultTimeout()

Specified by:

getDefaultTimeout in interface InternalAdmin

getDefaultTimeoutTimeUnit

public TimeUnit getDefaultTimeoutTimeUnit()

Specified by:

getDefaultTimeoutTimeUnit in interface InternalAdmin

getDiscoveryService

public DiscoveryService getDiscoveryService()

setSpaceMonitorInterval

public void setSpaceMonitorInterval(long interval,
                                    TimeUnit timeUnit)

Description copied from interface: Admin

Sets the Space monitor (not statistics) interval. The monitor checks each space instance and updates its different status (such as the replication status).

Defaults to 1 second.

Specified by:

setSpaceMonitorInterval in interface Admin

Parameters:

interval - The interval to use.

timeUnit - The time unit the interval is at.

getScheduler

public ScheduledThreadPoolExecutor getScheduler()

Specified by:

getScheduler in interface InternalAdmin

scheduleWithFixedDelay

public ScheduledFuture<?> scheduleWithFixedDelay(Runnable command,
                                                 long initialDelay,
                                                 long delay,
                                                 TimeUnit unit)

Specified by:

scheduleWithFixedDelay in interface InternalAdmin

setSchedulerCorePoolSize

public void setSchedulerCorePoolSize(int coreThreads)

Description copied from interface: Admin

The Admin API uses a shared scheduler thread pool to perform *all* scheduled operations (monitoring, statistics monitoring). The number of threads used can be set here.

Defaults to 10 threads.

Specified by:

setSchedulerCorePoolSize in interface Admin

Parameters:

coreThreads - The number of threads the shared scheduler thread pool will use,

setDefaultTimeout

public void setDefaultTimeout(long timeout,
                              TimeUnit timeUnit)

Description copied from interface: Admin

The default timeout to be used for operations that have a wait for mechanism, i.e. operations with overloaded methods containing (..., long timeout, TimeUnit timeUnit). If not set, the default is Long.MAX_VALUE, TimeUnit.MILLISECONDS

Specified by:

setDefaultTimeout in interface Admin

Parameters:

timeout - The timeout value to be used as the default operation timeout if non was provided.

timeUnit - The time-unit corresponding to the timeout.

close

public void close()

Description copied from interface: Admin

Closes the Admin, releasing any resource and stops listening for events from the lookup service.

Specified by:

close in interface Admin

getLookupServices

public LookupServices getLookupServices()

Description copied from interface: Admin

Returns the lookup services discovered.

Specified by:

getLookupServices in interface Admin

getGridServiceAgents

public GridServiceAgents getGridServiceAgents()

Description copied from interface: Admin

Returns the grid service agents discovered.

Specified by:

getGridServiceAgents in interface Admin

getGridServiceManagers

public GridServiceManagers getGridServiceManagers()

Description copied from interface: Admin

Returns the grid service managers discovered.

Specified by:

getGridServiceManagers in interface Admin

getGridServiceContainers

public GridServiceContainers getGridServiceContainers()

Description copied from interface: Admin

Returns the grid service containers discovered.

Specified by:

getGridServiceContainers in interface Admin

getGateways

public Gateways getGateways()

Description copied from interface: Admin

Returns the gateways discovered.

Specified by:

getGateways in interface Admin

getGridComponentByUID

public GridComponent getGridComponentByUID(String uid)

Description copied from interface: Admin

Returns the Grid Component represented by this UID; e.g. ESM, GSA, LUS, GSM, GSC

Specified by:

getGridComponentByUID in interface Admin

Parameters:

uid - The UID of the service returned by GridComponent.getUid(); null if no representation.

Returns:

The Grid Component represented by this UID.

See Also:

GridComponent.getUid()

getMachines

public Machines getMachines()

Description copied from interface: Admin

Returns the machines discovered.

Specified by:

getMachines in interface Admin

getZones

public Zones getZones()

Description copied from interface: Admin

Returns the zones discovered.

Specified by:

getZones in interface Admin

getApplications

public Applications getApplications()

Specified by:

getApplications in interface Admin

Returns:

the discovered applications

getTransports

public Transports getTransports()

Description copied from interface: Admin

Returns the transports discovered.

Specified by:

getTransports in interface Admin

getVirtualMachines

public VirtualMachines getVirtualMachines()

Description copied from interface: Admin

Returns the Virtual Machines discovered.

Specified by:

getVirtualMachines in interface Admin

getOperatingSystems

public OperatingSystems getOperatingSystems()

Description copied from interface: Admin

Returns the Operating Systems discovered.

Specified by:

getOperatingSystems in interface Admin

getProcessingUnits

public ProcessingUnits getProcessingUnits()

Description copied from interface: Admin

Returns the Processing Units discovered.

Specified by:

getProcessingUnits in interface Admin

getGatewayProcessingUnits

public GatewayProcessingUnits getGatewayProcessingUnits()

Description copied from interface: Admin

Returns the Gateway Processing Units discovered.

Specified by:

getGatewayProcessingUnits in interface Admin

getSpaces

public Spaces getSpaces()

Description copied from interface: Admin

Returns the spaces discovered.

Specified by:

getSpaces in interface Admin

getAlertManager

public AlertManager getAlertManager()

Description copied from interface: Admin

Returns the alert manager through which alert strategies are managed, alerts are fired and alert events are registered for.

Specified by:

getAlertManager in interface Admin

addEventListener

public void addEventListener(AdminEventListener eventListener)

Description copied from interface: Admin

Smart addition of event listeners. Will automatically add to the correct place any interface that extends the AdminEventListener interface.

Specified by:

addEventListener in interface Admin

See Also:

Admin.removeEventListener(AdminEventListener)

addEventListener

public void addEventListener(AdminEventListener eventListener,
                             boolean withStatisticsHistory)

Description copied from interface: Admin

Smart addition of event listeners. Will automatically add to the correct place any interface that extends the AdminEventListener interface.

Specified by:

addEventListener in interface Admin

withStatisticsHistory - if all statistics histories will be fired on registration statistics listener

See Also:

Admin.removeEventListener(AdminEventListener)

removeEventListener

public void removeEventListener(AdminEventListener eventListener)

Description copied from interface: Admin

Smart removal of event listeners. Will automatically remove to the correct place any interface that extends the AdminEventListener interface.

Specified by:

removeEventListener in interface Admin

See Also:

Admin.addEventListener(AdminEventListener)

getEventListenersCount

public int getEventListenersCount()

Description copied from interface: Admin

Returns number of registered event listeners. See AdminEventListener. Only for calls issued by either addEventListener or removeEventListener

Specified by:

getEventListenersCount in interface Admin

See Also:

Admin.addEventListener(AdminEventListener), Admin.removeEventListener(AdminEventListener)

pushEvent

public void pushEvent(Object listener,
                      Runnable notifier)

Specified by:

pushEvent in interface InternalAdmin

pushScheduleMonitorCorrelatedEvent

public void pushScheduleMonitorCorrelatedEvent(Object listener,
                                               Runnable notifier)

Description copied from interface: InternalAdmin

All events that need to be correlated with the Admin ScheduledMonitor polling mechanism.

Specified by:

pushScheduleMonitorCorrelatedEvent in interface InternalAdmin

pushEventAsFirst

public void pushEventAsFirst(Object listener,
                             Runnable notifier)

Specified by:

pushEventAsFirst in interface InternalAdmin

flushEvents

public void flushEvents()

flushScheduleMonitorCorrelatedEvents

public void flushScheduleMonitorCorrelatedEvents()

raiseEvent

public void raiseEvent(Object listener,
                       Runnable notifier)

Specified by:

raiseEvent in interface InternalAdmin

scheduleNonBlockingStateChange

public void scheduleNonBlockingStateChange(Runnable command)

Description copied from interface: InternalAdmin

Any internal admin objects state change must be scheduled using this method. In case there is a single event loop thread (non blocking event listeners), the specified runnable is added to the event loop queue. Otherwise it is executed on the calling thread.

Specified by:

scheduleNonBlockingStateChange in interface InternalAdmin

scheduleAdminOperation

public void scheduleAdminOperation(Runnable command)

Description copied from interface: InternalAdmin

A generic thread pool for network based operations such as creating a new grid service container.

Specified by:

scheduleAdminOperation in interface InternalAdmin

assertStateChangesPermitted

public void assertStateChangesPermitted()

Specified by:

assertStateChangesPermitted in interface InternalAdmin

addGridServiceAgent

public void addGridServiceAgent(InternalGridServiceAgent gridServiceAgent,
                                NIODetails nioDetails,
                                OSDetails osDetails,
                                JVMDetails jvmDetails,
                                String jmxUrl,
                                String[] zones)

Specified by:

addGridServiceAgent in interface InternalAdmin

removeGridServiceAgent

public void removeGridServiceAgent(String uid)

Specified by:

removeGridServiceAgent in interface InternalAdmin

addLookupService

public void addLookupService(InternalLookupService lookupService,
                             NIODetails nioDetails,
                             OSDetails osDetails,
                             JVMDetails jvmDetails,
                             String jmxUrl,
                             String[] zones)

Specified by:

addLookupService in interface InternalAdmin

removeLookupService

public void removeLookupService(String uid)

Specified by:

removeLookupService in interface InternalAdmin

addGridServiceManager

public void addGridServiceManager(InternalGridServiceManager gridServiceManager,
                                  NIODetails nioDetails,
                                  OSDetails osDetails,
                                  JVMDetails jvmDetails,
                                  String jmxUrl,
                                  String[] zones,
                                  boolean acceptVM)

Specified by:

addGridServiceManager in interface InternalAdmin

removeGridServiceManager

public void removeGridServiceManager(String uid)

Specified by:

removeGridServiceManager in interface InternalAdmin

addGridServiceContainer

public void addGridServiceContainer(InternalGridServiceContainer gridServiceContainer,
                                    NIODetails nioDetails,
                                    OSDetails osDetails,
                                    JVMDetails jvmDetails,
                                    String jmxUrl,
                                    String[] zones)

Specified by:

addGridServiceContainer in interface InternalAdmin

removeGridServiceContainer

public void removeGridServiceContainer(String uid)

Specified by:

removeGridServiceContainer in interface InternalAdmin

addProcessingUnitInstance

public void addProcessingUnitInstance(InternalProcessingUnitInstance processingUnitInstance,
                                      NIODetails nioDetails,
                                      OSDetails osDetails,
                                      JVMDetails jvmDetails,
                                      String jmxUrl,
                                      String[] zones)

Specified by:

addProcessingUnitInstance in interface InternalAdmin

removeProcessingUnitInstance

public void removeProcessingUnitInstance(String uid,
                                         boolean removeEmbeddedSpaces)

Specified by:

removeProcessingUnitInstance in interface InternalAdmin

addSpaceInstance

public void addSpaceInstance(InternalSpaceInstance spaceInstance,
                             NIODetails nioDetails,
                             OSDetails osDetails,
                             JVMDetails jvmDetails,
                             String jmxUrl,
                             String[] zones)

Specified by:

addSpaceInstance in interface InternalAdmin

removeSpaceInstance

public void removeSpaceInstance(String uid)

Specified by:

removeSpaceInstance in interface InternalAdmin

generateDump

public DumpResult generateDump(Set<DumpProvider> dumpProviders,
                               DumpGeneratedListener listener,
                               String cause,
                               Map<String,Object> context,
                               String... processor)
                        throws AdminException

Description copied from interface: Admin

Generates dump for an explicit set of dump providers.

Specified by:

generateDump in interface Admin

Throws:

AdminException

generateDump

public DumpResult generateDump(String cause,
                               Map<String,Object> context)
                        throws AdminException

Description copied from interface: DumpProvider

Generates dump for all the provided dump processors. Note, this will include a heap dump which can consume time and potentially be of very large size

Specified by:

generateDump in interface DumpProvider

Parameters:

cause - The cause that this dump was generated

context - Allows to provide specific parameters to specific processors

Throws:

AdminException

generateDump

public DumpResult generateDump(String cause,
                               Map<String,Object> context,
                               String... processor)
                        throws AdminException

Description copied from interface: DumpProvider

Generates dump for the provided processors. The current list of processors include:

• summary: General summary information of the process.
• network: Information on the network layer of the process and the OS network stats.
• thread: Thread dump of the process.
• heap: Heap dump of the process. Note, this is a heavy operation and can produce very large dump files
• log: Adds all the log files of the process to the dump file.
• processingUnits: Dump of all the processing units (applicable only for GSCs) information.

Specified by:

generateDump in interface DumpProvider

Parameters:

cause - The cause this dump was generated.

context - Allows to provide specific parameters to specific processors.

processor - The list of processors to be used.

Throws:

AdminException

scheduleWithFixedDelayNonBlockingStateChange

public ScheduledFuture<?> scheduleWithFixedDelayNonBlockingStateChange(Runnable command,
                                                                       long initialDelay,
                                                                       long delay,
                                                                       TimeUnit unit)

Description copied from interface: InternalAdmin

Any internal admin objects state change based on polling must be scheduled using this method. In case there is a single event loop thread (non blocking event listeners), the specified command is added to the event loop queue. Otherwise it is executed on the admin scheduler thread pool.

Specified by:

scheduleWithFixedDelayNonBlockingStateChange in interface InternalAdmin

scheduleOneTimeWithDelayNonBlockingStateChange

public ScheduledFuture<?> scheduleOneTimeWithDelayNonBlockingStateChange(Runnable command,
                                                                         long delay,
                                                                         TimeUnit unit)

Description copied from interface: InternalAdmin

Any internal delayed admin objects state change based on polling must be scheduled using this method. In case there is a single event loop thread (non blocking event listeners), the specified command is added to the event loop queue. Otherwise it is executed on the admin scheduler thread pool.

Specified by:

scheduleOneTimeWithDelayNonBlockingStateChange in interface InternalAdmin

isSingleThreadedEventListeners

public boolean isSingleThreadedEventListeners()

Specified by:

isSingleThreadedEventListeners in interface InternalAdmin

setAdminFilter

public void setAdminFilter(AdminFilter adminFilter)

Parameters:

adminFilter -

getAdminFilter

public AdminFilter getAdminFilter()

Specified by:

getAdminFilter in interface InternalAdmin

addGatewayProcessingUnit

public void addGatewayProcessingUnit(GatewayProcessingUnit gatewayProcessingUnit)

Specified by:

addGatewayProcessingUnit in interface InternalAdmin

removeGatewayProcessingUnit

public void removeGatewayProcessingUnit(String uid)

Specified by:

removeGatewayProcessingUnit in interface InternalAdmin

getOrphanProcessingUnitInstances

public ProcessingUnitInstance[] getOrphanProcessingUnitInstances()

Specified by:

getOrphanProcessingUnitInstances in interface InternalAdmin

setDiscoveryServices

public void setDiscoveryServices(Class... discoveryServices)

Set the service types that will be monitored Supported types: GridServiceAgent, GridServiceManager, GridServiceContainer, ProcessingUnit, Space

Throws:

IllegalArgumentException - if other type is provided