org.openspaces.admin.internal.machine

Class DefaultMachines

java.lang.Object

org.openspaces.admin.internal.machine.DefaultMachines

All Implemented Interfaces:

Iterable<Machine>, AdminAware, InternalMachines, Machines

public class DefaultMachines
extends Object
implements InternalMachines

Author:

kimchy

Constructor Summary

Constructors

Constructor and Description
DefaultMachines(InternalAdmin admin)

Method Summary

Modifier and Type	Method and Description
void	addLifecycleListener(MachineLifecycleEventListener eventListener) Allows to add a MachineLifecycleEventListener.
void	addMachine(InternalMachine machine)
Admin	getAdmin() Returns the Admin associated with this element.
ElasticMachineProvisioningFailureEventManager	getElasticMachineProvisioningFailure() Returns the elastic machine provisioning failure event manager allowing to add and remove ElasticMachineProvisioningFailureEventListeners.
ElasticMachineProvisioningProgressChangedEventManager	getElasticMachineProvisioningProgressChanged() Returns the elastic machine provisioning failure event manager allowing to add and remove ElasticMachineProvisioningProgressChangedEventListeners.
Map<String,Machine>	getHostsByAddress() Returns a map of machines by host address.
Map<String,Machine>	getHostsByName() Returns a map of machines by host names.
MachineAddedEventManager	getMachineAdded() Returns the machines added event manager allowing to add and remove MachineAddedEventListeners.
Machine	getMachineByHostAddress(String ipAddress) Returns the machine by the host address.
Machine	getMachineByHostName(String hostName) Returns the machine by the host name.
Machine	getMachineByUID(String uid)
MachineRemovedEventManager	getMachineRemoved() Returns the grid service container added event manager allowing to add and remove MachineRemovedEventListeners.
Machine[]	getMachines() Returns all currently discovered machines.
int	getSize() Returns the number of machines current discovered.
Map<String,Machine>	getUids() Returns a map of machines with the key as the uid.
boolean	isEmpty() Returns true if there are no machines, false otherwise.
Iterator<Machine>	iterator()
void	processElasticScaleStrategyEvent(ElasticProcessingUnitEvent event) If relevant raises events to relevant subscribers
void	removeLifeycleListener(MachineLifecycleEventListener eventListener) Allows to remove a MachineLifecycleEventListener.
void	removeMachine(Machine machine)
boolean	waitFor(int numberOfMachines) Waits indefinitely till the provided number of machines are up.
boolean	waitFor(int numberOfMachines, long timeout, TimeUnit timeUnit) Waits for the given timeout (in time unit) till the provided number of machines are up.
Machine	waitFor(String hostAddress) Waits indefinitely till the machine with the given host (name/address) is discovered.
Machine	waitFor(String hostAddress, long timeout, TimeUnit timeUnit) Waits for the given timeout (in time unit) till the machien with the given host (name/address) is discovered.

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

DefaultMachines

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

getMachines

public Machine[] getMachines()

Description copied from interface: Machines

Returns all currently discovered machines.

Specified by:

getMachines in interface Machines

getMachineAdded

public MachineAddedEventManager getMachineAdded()

Description copied from interface: Machines

Returns the machines added event manager allowing to add and remove MachineAddedEventListeners.

Specified by:

getMachineAdded in interface Machines

getMachineRemoved

public MachineRemovedEventManager getMachineRemoved()

Description copied from interface: Machines

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

Specified by:

getMachineRemoved in interface Machines

getSize

public int getSize()

Description copied from interface: Machines

Returns the number of machines current discovered.

Specified by:

getSize in interface Machines

isEmpty

public boolean isEmpty()

Description copied from interface: Machines

Returns true if there are no machines, false otherwise.

Specified by:

isEmpty in interface Machines

waitFor

public boolean waitFor(int numberOfMachines)

Description copied from interface: Machines

Waits indefinitely till the provided number of machines are up.

Specified by:

waitFor in interface Machines

Parameters:

numberOfMachines - The number of containers to wait for

waitFor

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

Description copied from interface: Machines

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

Specified by:

waitFor in interface Machines

Parameters:

numberOfMachines - The number of containers to wait for

waitFor

public Machine waitFor(String hostAddress)

Description copied from interface: Machines

Waits indefinitely till the machine with the given host (name/address) is discovered.

Specified by:

waitFor in interface Machines

Parameters:

hostAddress - The machine host name or address

Returns:

The machine discovered

waitFor

public Machine waitFor(String hostAddress,
                       long timeout,
                       TimeUnit timeUnit)

Description copied from interface: Machines

Waits for the given timeout (in time unit) till the machien with the given host (name/address) is discovered. Returns the machine if it was discovered within the provided timeout, or null if the machine was not discovered.

Specified by:

waitFor in interface Machines

Parameters:

hostAddress - The machine host name or address

timeout - The timeout value to wait

timeUnit - The time unit of the timeout value

Returns:

The machien discovered, or null if it was not discovered within the provided timeout

iterator

public Iterator<Machine> iterator()

Specified by:

iterator in interface Iterable<Machine>

getMachineByUID

public Machine getMachineByUID(String uid)

Specified by:

getMachineByUID in interface InternalMachines

getMachineByHostAddress

public Machine getMachineByHostAddress(String ipAddress)

Description copied from interface: Machines

Returns the machine by the host address.

Specified by:

getMachineByHostAddress in interface Machines

Parameters:

ipAddress - The host address to lookup the machine by

Returns:

The machine correlated to the specified host address, null if there is no one

getMachineByHostName

public Machine getMachineByHostName(String hostName)

Description copied from interface: Machines

Returns the machine by the host name.

Specified by:

getMachineByHostName in interface Machines

getUids

public Map<String,Machine> getUids()

Description copied from interface: Machines

Returns a map of machines with the key as the uid.

Specified by:

getUids in interface Machines

getHostsByAddress

public Map<String,Machine> getHostsByAddress()

Description copied from interface: Machines

Returns a map of machines by host address.

Specified by:

getHostsByAddress in interface Machines

getHostsByName

public Map<String,Machine> getHostsByName()

Description copied from interface: Machines

Returns a map of machines by host names.

Specified by:

getHostsByName in interface Machines

addLifecycleListener

public void addLifecycleListener(MachineLifecycleEventListener eventListener)

Description copied from interface: Machines

Allows to add a MachineLifecycleEventListener.

Specified by:

addLifecycleListener in interface Machines

removeLifeycleListener

public void removeLifeycleListener(MachineLifecycleEventListener eventListener)

Description copied from interface: Machines

Allows to remove a MachineLifecycleEventListener.

Specified by:

removeLifeycleListener in interface Machines

addMachine

public void addMachine(InternalMachine machine)

Specified by:

addMachine in interface InternalMachines

removeMachine

public void removeMachine(Machine machine)

Specified by:

removeMachine in interface InternalMachines

getElasticMachineProvisioningFailure

public ElasticMachineProvisioningFailureEventManager getElasticMachineProvisioningFailure()

Description copied from interface: Machines

Returns the elastic machine provisioning failure event manager allowing to add and remove ElasticMachineProvisioningFailureEventListeners.

Specified by:

getElasticMachineProvisioningFailure in interface Machines

getElasticMachineProvisioningProgressChanged

public ElasticMachineProvisioningProgressChangedEventManager getElasticMachineProvisioningProgressChanged()

Description copied from interface: Machines

Returns the elastic machine provisioning failure event manager allowing to add and remove ElasticMachineProvisioningProgressChangedEventListeners.

Specified by:

getElasticMachineProvisioningProgressChanged in interface Machines

processElasticScaleStrategyEvent

public void processElasticScaleStrategyEvent(ElasticProcessingUnitEvent event)

Description copied from interface: InternalMachines

If relevant raises events to relevant subscribers

Specified by:

processElasticScaleStrategyEvent in interface InternalMachines