com.gigaspaces.cluster.activeelection

Class LeaderSelectorHandler

java.lang.Object

com.gigaspaces.cluster.activeelection.LeaderSelectorHandler

All Implemented Interfaces:

LeaderSelector

Direct Known Subclasses:

LusBasedSelectorHandler

public abstract class LeaderSelectorHandler
extends Object
implements LeaderSelector

Provides runtime primary/backup selection in cluster topologies.

Since:

6.0

Version:

1.0

Author:

Igor Goldenberg

Field Summary

Fields

Modifier and Type	Field and Description
protected Throwable	_lastError
protected ConsolidatedLogger	_logger
protected PrimarySpaceModeListeners	_primarySpaceModeListeners
protected SpaceImpl	_space
protected String	_spaceMember
protected SpaceMode	_spaceMode

Constructor Summary

Constructors

Constructor and Description
LeaderSelectorHandler()

Method Summary

Modifier and Type	Method and Description
void	addListenerAndNotify(ISpaceModeListener listener) Add listener for space availability and notify the listener with the current space mode
protected void	afterSpaceModeChange(SpaceMode newMode) Notify the listeners about the event
protected void	beforeSpaceModeChange(SpaceMode newMode) Notify the listeners about the event
boolean	compareAndRegister(SpaceMode spaceMode, ISpaceModeListener listener) Checks if space mode equals given mode.
protected void	dispatchBeforeEventToRemoteListeners(Queue<ISpaceModeListener> remoteListeners, SpaceMode newMode)
void	forceMoveToPrimary()
Throwable	getLastError()
SpaceMode	getSpaceMode()
void	initialize(LeaderSelectorHandlerConfig config)
boolean	isPrimary()
protected void	moveToBackup() Change space mode to backup
protected void	moveToPrimary() Change space mode to primary
protected void	moveToUnusable() Change space state to UNHEALTHY, so it is redeployed
void	removeListener(ISpaceModeListener listener) Remove listener for space availability
void	setLastError(Throwable lastError)
void	setSpaceMode(SpaceMode spaceMode)

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.gigaspaces.cluster.activeelection.LeaderSelector

getPrimaryMemberName, select, terminate

Field Detail

_logger

protected ConsolidatedLogger _logger

_spaceMember

protected String _spaceMember

_space

protected SpaceImpl _space

_primarySpaceModeListeners

protected PrimarySpaceModeListeners _primarySpaceModeListeners

_spaceMode

protected volatile SpaceMode _spaceMode

_lastError

protected volatile Throwable _lastError

Constructor Detail

LeaderSelectorHandler

public LeaderSelectorHandler()

Method Detail

initialize

public void initialize(LeaderSelectorHandlerConfig config)
                throws Exception

Throws:

Exception

isPrimary

public boolean isPrimary()

Specified by:

isPrimary in interface LeaderSelector

Returns:

trueif the Space is primary, otherwise the space in backup mode.

beforeSpaceModeChange

protected void beforeSpaceModeChange(SpaceMode newMode)

Notify the listeners about the event

afterSpaceModeChange

protected void afterSpaceModeChange(SpaceMode newMode)

Notify the listeners about the event

dispatchBeforeEventToRemoteListeners

protected void dispatchBeforeEventToRemoteListeners(Queue<ISpaceModeListener> remoteListeners,
                                                    SpaceMode newMode)

moveToPrimary

protected void moveToPrimary()

Change space mode to primary

moveToBackup

protected void moveToBackup()

Change space mode to backup

moveToUnusable

protected void moveToUnusable()

Change space state to UNHEALTHY, so it is redeployed

addListenerAndNotify

public void addListenerAndNotify(ISpaceModeListener listener)
                          throws RemoteException

Add listener for space availability and notify the listener with the current space mode

Throws:

RemoteException

removeListener

public void removeListener(ISpaceModeListener listener)

Remove listener for space availability

setSpaceMode

public void setSpaceMode(SpaceMode spaceMode)

getSpaceMode

public SpaceMode getSpaceMode()

compareAndRegister

public boolean compareAndRegister(SpaceMode spaceMode,
                                  ISpaceModeListener listener)

Checks if space mode equals given mode. If true - registers the given listener to election events. Otherwise returns false.

getLastError

public Throwable getLastError()

Specified by:

getLastError in interface LeaderSelector

setLastError

public void setLastError(Throwable lastError)

Specified by:

setLastError in interface LeaderSelector

forceMoveToPrimary

public void forceMoveToPrimary()
                        throws RemoteException

Throws:

RemoteException