org.openspaces.admin.internal.lus

Class DefaultLookupServices

java.lang.Object

org.openspaces.admin.internal.lus.DefaultLookupServices

All Implemented Interfaces:

Iterable<LookupService>, AdminAware, DumpProvider, InternalLookupServices, LookupServices

public class DefaultLookupServices
extends Object
implements InternalLookupServices

Author:

kimchy

Constructor Summary

Constructors

Constructor and Description
DefaultLookupServices(InternalAdmin admin)

Method Summary

Modifier and Type	Method and Description
void	addLifecycleListener(LookupServiceLifecycleEventListener eventListener) Allows to add a LookupServiceLifecycleEventListener.
void	addLookupService(InternalLookupService lookupService)
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.
LookupServiceAddedEventManager	getLookupServiceAdded() Returns the lookup service added event manager allowing to add and remove LookupServiceAddedEventListeners.
LookupService	getLookupServiceByUID(String id) Returns a lus based on its uid.
LookupServiceRemovedEventManager	getLookupServiceRemoved() Returns the grid service container added event manager allowing to add and remove LookupServiceRemovedEventManagers.
LookupService[]	getLookupServices() Returns all the currently discovered lus.
int	getSize() Returns the number of lookup services current discovered.
Map<String,LookupService>	getUids() Returns a map of lookup service with the key as the uid.
boolean	isEmpty() Returns true if there are no containers, false otherwise.
Iterator<LookupService>	iterator()
void	removeLifecycleListener(LookupServiceLifecycleEventListener eventListener) Allows to remove a LookupServiceLifecycleEventListener.
InternalLookupService	removeLookupService(String UID)
boolean	waitFor(int numberOfLookupServices) Waits indefinitely till the provided number of lookup services are up.
boolean	waitFor(int numberOfLookupServices, long timeout, TimeUnit timeUnit) Waits for the given timeout (in time unit) till the provided number of lookup services are up.

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

DefaultLookupServices

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

getLookupServices

public LookupService[] getLookupServices()

Description copied from interface: LookupServices

Returns all the currently discovered lus.

Specified by:

getLookupServices in interface LookupServices

iterator

public Iterator<LookupService> iterator()

Specified by:

iterator in interface Iterable<LookupService>

getLookupServiceByUID

public LookupService getLookupServiceByUID(String id)

Description copied from interface: LookupServices

Returns a lus based on its uid.

Specified by:

getLookupServiceByUID in interface LookupServices

See Also:

GridComponent.getUid()

getUids

public Map<String,LookupService> getUids()

Description copied from interface: LookupServices

Returns a map of lookup service with the key as the uid.

Specified by:

getUids in interface LookupServices

getSize

public int getSize()

Description copied from interface: LookupServices

Returns the number of lookup services current discovered.

Specified by:

getSize in interface LookupServices

isEmpty

public boolean isEmpty()

Description copied from interface: LookupServices

Returns true if there are no containers, false otherwise.

Specified by:

isEmpty in interface LookupServices

waitFor

public boolean waitFor(int numberOfLookupServices)

Description copied from interface: LookupServices

Waits indefinitely till the provided number of lookup services are up.

Specified by:

waitFor in interface LookupServices

Parameters:

numberOfLookupServices - The number of lookup services to wait for

waitFor

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

Description copied from interface: LookupServices

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

Specified by:

waitFor in interface LookupServices

Parameters:

numberOfLookupServices - The number of lookup services to wait for

addLifecycleListener

public void addLifecycleListener(LookupServiceLifecycleEventListener eventListener)

Description copied from interface: LookupServices

Allows to add a LookupServiceLifecycleEventListener.

Specified by:

addLifecycleListener in interface LookupServices

removeLifecycleListener

public void removeLifecycleListener(LookupServiceLifecycleEventListener eventListener)

Description copied from interface: LookupServices

Allows to remove a LookupServiceLifecycleEventListener.

Specified by:

removeLifecycleListener in interface LookupServices

addLookupService

public void addLookupService(InternalLookupService lookupService)

Specified by:

addLookupService in interface InternalLookupServices

removeLookupService

public InternalLookupService removeLookupService(String UID)

Specified by:

removeLookupService in interface InternalLookupServices

getLookupServiceAdded

public LookupServiceAddedEventManager getLookupServiceAdded()

Description copied from interface: LookupServices

Returns the lookup service added event manager allowing to add and remove LookupServiceAddedEventListeners.

Specified by:

getLookupServiceAdded in interface LookupServices

getLookupServiceRemoved

public LookupServiceRemovedEventManager getLookupServiceRemoved()

Description copied from interface: LookupServices

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

Specified by:

getLookupServiceRemoved in interface LookupServices

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