org.openspaces.admin.internal.esm

Class DefaultElasticServiceManagers

java.lang.Object

org.openspaces.admin.internal.esm.DefaultElasticServiceManagers

All Implemented Interfaces:

Iterable<ElasticServiceManager>, AdminAware, DumpProvider, ElasticServiceManagers, InternalElasticServiceManagers

public class DefaultElasticServiceManagers
extends Object
implements InternalElasticServiceManagers

Author:

Moran Avigdor

Constructor Summary

Constructors

Constructor and Description
DefaultElasticServiceManagers(InternalAdmin admin)

Method Summary

Modifier and Type	Method and Description
void	addElasticServiceManager(InternalElasticServiceManager elasticServiceManager)
void	addLifecycleListener(ElasticServiceManagerLifecycleEventListener eventListener) Allows to add a ElasticServiceManagerLifecycleEventListener.
protected void	assertStateChangesPermitted()
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.
Admin	getAdmin() Returns the Admin associated with this element.
ElasticServiceManagerAddedEventManager	getElasticServiceManagerAdded() Returns the grid service manager added event manager allowing to add and remove GridServiceManagerAddedEventListeners.
ElasticServiceManagerRemovedEventManager	getElasticServiceManagerRemoved() Returns the grid service container added event manager allowing to add and remove GridServiceManagerRemovedEventListeners.
ElasticServiceManager	getManagerByUID(String uid) Returns a manager based on its uid.
ElasticServiceManager[]	getManagers() Returns all the currently discovered managers.
ElasticServiceManager[]	getManagersNonFiltered()
int	getSize() Returns the number of managers currently discovered.
Map<String,ElasticServiceManager>	getUids() Returns a map of elastic service manager with the key as the uid.
boolean	isEmpty() Returns true if there are no managers, false otherwise.
Iterator<ElasticServiceManager>	iterator()
InternalElasticServiceManager	removeElasticServiceManager(String uid)
void	removeLifecycleListener(ElasticServiceManagerLifecycleEventListener eventListener) Allows to remove a ElasticServiceManagerLifecycleEventListener.
boolean	waitFor(int numberOfElasticServiceManagers) Waits indefinitely till the provided number of managers are up.
boolean	waitFor(int numberOfElasticServiceManagers, long timeout, TimeUnit timeUnit) Waits for the given timeout (in time unit) till the provided number of managers are up.
ElasticServiceManager	waitForAtLeastOne() Waits indefinitely till at least one ESM is discovered and returns it.
ElasticServiceManager	waitForAtLeastOne(long timeout, TimeUnit timeUnit) Waits for the given timeout (in time unit) till at least one ESM is discovered and returns it.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.openspaces.admin.esm.ElasticServiceManagers

hasElasticManager

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Constructor Detail

DefaultElasticServiceManagers

public DefaultElasticServiceManagers(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

getManagerByUID

public ElasticServiceManager getManagerByUID(String uid)

Description copied from interface: ElasticServiceManagers

Returns a manager based on its uid.

Specified by:

getManagerByUID in interface ElasticServiceManagers

See Also:

GridComponent.getUid()

getManagers

public ElasticServiceManager[] getManagers()

Description copied from interface: ElasticServiceManagers

Returns all the currently discovered managers.

Specified by:

getManagers in interface ElasticServiceManagers

getSize

public int getSize()

Description copied from interface: ElasticServiceManagers

Returns the number of managers currently discovered.

Specified by:

getSize in interface ElasticServiceManagers

getUids

public Map<String,ElasticServiceManager> getUids()

Description copied from interface: ElasticServiceManagers

Returns a map of elastic service manager with the key as the uid.

Specified by:

getUids in interface ElasticServiceManagers

isEmpty

public boolean isEmpty()

Description copied from interface: ElasticServiceManagers

Returns true if there are no managers, false otherwise.

Specified by:

isEmpty in interface ElasticServiceManagers

iterator

public Iterator<ElasticServiceManager> iterator()

Specified by:

iterator in interface Iterable<ElasticServiceManager>

getElasticServiceManagerAdded

public ElasticServiceManagerAddedEventManager getElasticServiceManagerAdded()

Description copied from interface: ElasticServiceManagers

Returns the grid service manager added event manager allowing to add and remove GridServiceManagerAddedEventListeners.

Specified by:

getElasticServiceManagerAdded in interface ElasticServiceManagers

getElasticServiceManagerRemoved

public ElasticServiceManagerRemovedEventManager getElasticServiceManagerRemoved()

Description copied from interface: ElasticServiceManagers

Returns the grid service container added event manager allowing to add and remove GridServiceManagerRemovedEventListeners.

Specified by:

getElasticServiceManagerRemoved in interface ElasticServiceManagers

addElasticServiceManager

public void addElasticServiceManager(InternalElasticServiceManager elasticServiceManager)

Specified by:

addElasticServiceManager in interface InternalElasticServiceManagers

removeElasticServiceManager

public InternalElasticServiceManager removeElasticServiceManager(String uid)

Specified by:

removeElasticServiceManager in interface InternalElasticServiceManagers

addLifecycleListener

public void addLifecycleListener(ElasticServiceManagerLifecycleEventListener eventListener)

Description copied from interface: ElasticServiceManagers

Allows to add a ElasticServiceManagerLifecycleEventListener.

Specified by:

addLifecycleListener in interface ElasticServiceManagers

removeLifecycleListener

public void removeLifecycleListener(ElasticServiceManagerLifecycleEventListener eventListener)

Description copied from interface: ElasticServiceManagers

Allows to remove a ElasticServiceManagerLifecycleEventListener.

Specified by:

removeLifecycleListener in interface ElasticServiceManagers

waitFor

public boolean waitFor(int numberOfElasticServiceManagers)

Description copied from interface: ElasticServiceManagers

Waits indefinitely till the provided number of managers are up. When passing 0, will wait till there are no more managers.

Specified by:

waitFor in interface ElasticServiceManagers

Parameters:

numberOfElasticServiceManagers - The number of managers to wait for

waitFor

public boolean waitFor(int numberOfElasticServiceManagers,
                       long timeout,
                       TimeUnit timeUnit)

Description copied from interface: ElasticServiceManagers

Waits for the given timeout (in time unit) till the provided number of managers are up. Returns true if the required number of managers were discovered, false if the timeout expired.

When passing 0, will wait till there are no more managers.

Specified by:

waitFor in interface ElasticServiceManagers

Parameters:

numberOfElasticServiceManagers - The number of managers to wait for

waitForAtLeastOne

public ElasticServiceManager waitForAtLeastOne()

Description copied from interface: ElasticServiceManagers

Waits indefinitely till at least one ESM is discovered and returns it.

Specified by:

waitForAtLeastOne in interface ElasticServiceManagers

waitForAtLeastOne

public ElasticServiceManager waitForAtLeastOne(long timeout,
                                               TimeUnit timeUnit)

Description copied from interface: ElasticServiceManagers

Waits for the given timeout (in time unit) till at least one ESM is discovered and returns it.

Specified by:

waitForAtLeastOne in interface ElasticServiceManagers

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

assertStateChangesPermitted

protected void assertStateChangesPermitted()

getManagersNonFiltered

public ElasticServiceManager[] getManagersNonFiltered()

Specified by:

getManagersNonFiltered in interface InternalElasticServiceManagers