org.openspaces.admin.internal.space

Class DefaultSpacePartition

java.lang.Object

org.openspaces.admin.internal.space.DefaultSpacePartition

All Implemented Interfaces:

Iterable<SpaceInstance>, InternalSpacePartition, SpacePartition

public class DefaultSpacePartition
extends Object
implements InternalSpacePartition

Author:

kimchy

Constructor Summary

Constructors

Constructor and Description
DefaultSpacePartition(Space space, int partitionId)

Method Summary

Modifier and Type	Method and Description
void	addSpaceInstance(SpaceInstance spaceInstance)
SpaceInstance	getBackup() Returns the (first) backup space instance, null if currently there is no backup.
SpaceInstance[]	getInstances() Returns all the space instances that form the partition.
int	getPartitionId() Returns the partition id (starting from 0).
SpaceInstance	getPrimary() Returns the primary space instance, null if currently there is no primary.
Space	getSpace() Returns the Space this Space Partition is part of.
InternalSpacePartitionModeChangedEventManager	getSpaceModeChanged() Returns an event manager allowing to globally register for SpaceModeChangedEventListeners that happen on any Space partition currently discovered.
Iterator<SpaceInstance>	iterator()
void	removeSpaceInstance(String uid)
boolean	waitFor(SpaceMode spaceMode) Waits (default timeout) till one of the Space partition instances has the provided space mode.
boolean	waitFor(SpaceMode spaceMode, long timeout, TimeUnit timeUnit) Waits (given timeout) till one of the Space partition instances has the provided space mode.

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

DefaultSpacePartition

public DefaultSpacePartition(Space space,
                             int partitionId)

Method Detail

getSpace

public Space getSpace()

Description copied from interface: SpacePartition

Returns the Space this Space Partition is part of.

Specified by:

getSpace in interface SpacePartition

getPrimary

public SpaceInstance getPrimary()

Description copied from interface: SpacePartition

Returns the primary space instance, null if currently there is no primary.

Specified by:

getPrimary in interface SpacePartition

getBackup

public SpaceInstance getBackup()

Description copied from interface: SpacePartition

Returns the (first) backup space instance, null if currently there is no backup.

Specified by:

getBackup in interface SpacePartition

waitFor

public boolean waitFor(SpaceMode spaceMode)

Description copied from interface: SpacePartition

Waits (default timeout) till one of the Space partition instances has the provided space mode.

Specified by:

waitFor in interface SpacePartition

Parameters:

spaceMode - the requested space mode (PRIMARY / BACKUP)

Returns:

returns true if a space instance was found in the default timeout, false otherwise.

waitFor

public boolean waitFor(SpaceMode spaceMode,
                       long timeout,
                       TimeUnit timeUnit)

Description copied from interface: SpacePartition

Waits (given timeout) till one of the Space partition instances has the provided space mode.

Specified by:

waitFor in interface SpacePartition

Parameters:

spaceMode - the requested space mode (PRIMARY / BACKUP)

timeout - the time to wait based on the time unit

timeUnit - the time unit to use for the timeout parameter

Returns:

returns true if a space instance was found in the specified timeout, false otherwise.

iterator

public Iterator<SpaceInstance> iterator()

Specified by:

iterator in interface Iterable<SpaceInstance>

getInstances

public SpaceInstance[] getInstances()

Description copied from interface: SpacePartition

Returns all the space instances that form the partition.

Specified by:

getInstances in interface SpacePartition

getPartitionId

public int getPartitionId()

Description copied from interface: SpacePartition

Returns the partition id (starting from 0). Note, SpaceInstance.getInstanceId() starts from 1.

Specified by:

getPartitionId in interface SpacePartition

addSpaceInstance

public void addSpaceInstance(SpaceInstance spaceInstance)

Specified by:

addSpaceInstance in interface InternalSpacePartition

removeSpaceInstance

public void removeSpaceInstance(String uid)

Specified by:

removeSpaceInstance in interface InternalSpacePartition

getSpaceModeChanged

public InternalSpacePartitionModeChangedEventManager getSpaceModeChanged()

Description copied from interface: SpacePartition

Returns an event manager allowing to globally register for SpaceModeChangedEventListeners that happen on any Space partition currently discovered.

Specified by:

getSpaceModeChanged in interface SpacePartition