Package com.gigaspaces.cluster.activeelection

Class LusBasedSelectorHandler

java.lang.Object

com.gigaspaces.cluster.activeelection.LeaderSelectorHandler

com.gigaspaces.cluster.activeelection.LusBasedSelectorHandler

All Implemented Interfaces:

IActiveElectionListener, LeaderSelector

public class LusBasedSelectorHandler
extends LeaderSelectorHandler
implements IActiveElectionListener

Provides runtime primary/backup selection in cluster topologies.

Since:

6.0

Version:

1.0

Author:

Igor Goldenberg

Field Summary

Fields inherited from class com.gigaspaces.cluster.activeelection.LeaderSelectorHandler

_lastError, _logger, _primarySpaceModeListeners, _space, _spaceMember, _spaceMode

Constructor Summary

Constructors

Constructor	Description
LusBasedSelectorHandler(SpaceProxyImpl securedProxy)

Method Summary

Modifier and Type	Method	Description
void	forceMoveToPrimary()	Forcefully make this space to be primary
Throwable	getLastError()
String	getPrimaryMemberName()
void	initialize(LeaderSelectorHandlerConfig config)
boolean	isPrimary()
void	onActive(ActiveElectionEvent theEvent)	Notification about new elected Active service.
void	onExtraBackup(ActiveElectionEvent theEvent)	Notification that an extra-backup was resolved.
void	onSplitBrain(ActiveElectionEvent theEvent)	Notification about split-brain.
void	onSplitBrainActive(ActiveElectionEvent theEvent)	Notification that split-brain was resolved - current service remains primary.
void	onSplitBrainBackup(ActiveElectionEvent theEvent)	Notification about a backup that it's primary has changed due to split-brain.
void	select()	start the primary election manager
void	setLastError(Throwable lastError)
void	terminate()	terminate the PrimarySpaceSelector

Methods inherited from class com.gigaspaces.cluster.activeelection.LeaderSelectorHandler

addListenerAndNotify, afterSpaceModeChange, beforeSpaceModeChange, compareAndRegister, dispatchBeforeEventToRemoteListeners, getSpaceMode, moveToBackup, moveToPrimary, moveToUnusable, removeListener, setSpaceMode

Methods inherited from class java.lang.Object

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

Constructor Details

LusBasedSelectorHandler

public LusBasedSelectorHandler(SpaceProxyImpl securedProxy)

Method Details

initialize

public void initialize(LeaderSelectorHandlerConfig config)
                throws Exception

Overrides:

initialize in class LeaderSelectorHandler

Throws:

Exception

isPrimary

public boolean isPrimary()

Specified by:

isPrimary in interface LeaderSelector

Overrides:

isPrimary in class LeaderSelectorHandler

Returns:

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

getPrimaryMemberName

public String getPrimaryMemberName()

Specified by:

getPrimaryMemberName in interface LeaderSelector

Returns:

the reference to the primary space

select

public void select()
            throws RemoteException

start the primary election manager

Specified by:

select in interface LeaderSelector

Throws:

RemoteException

onActive

public void onActive(ActiveElectionEvent theEvent)

Description copied from interface: IActiveElectionListener

Notification about new elected Active service.

Specified by:

onActive in interface IActiveElectionListener

Parameters:

theEvent - The election event with an Active service reference.

See Also:

• IActiveElectionListener.onActive(ActiveElectionEvent)

onSplitBrain

public void onSplitBrain(ActiveElectionEvent theEvent)

Description copied from interface: IActiveElectionListener

Notification about split-brain. Identified more then 1 ACTIVE services. This method will be called only after the split-brain was resolved.

Specified by:

onSplitBrain in interface IActiveElectionListener

Parameters:

theEvent - the active service (the new primary)

See Also:

• IActiveElectionListener.onSplitBrain(ActiveElectionEvent)

onSplitBrainActive

public void onSplitBrainActive(ActiveElectionEvent theEvent)

Description copied from interface: IActiveElectionListener

Notification that split-brain was resolved - current service remains primary.

Specified by:

onSplitBrainActive in interface IActiveElectionListener

Parameters:

theEvent - the active service (same as the current elected)

onExtraBackup

public void onExtraBackup(ActiveElectionEvent theEvent)

Description copied from interface: IActiveElectionListener

Notification that an extra-backup was resolved. This method will be called on backup Spaces that should terminate.

Specified by:

onExtraBackup in interface IActiveElectionListener

Parameters:

theEvent - the active service used as reference for resolution

onSplitBrainBackup

public void onSplitBrainBackup(ActiveElectionEvent theEvent)

Description copied from interface: IActiveElectionListener

Notification about a backup that it's primary has changed due to split-brain.

Specified by:

onSplitBrainBackup in interface IActiveElectionListener

Parameters:

theEvent - the active service (the new primary)

terminate

public void terminate()

terminate the PrimarySpaceSelector

Specified by:

terminate in interface LeaderSelector

forceMoveToPrimary

public void forceMoveToPrimary()
                        throws RemoteException

Forcefully make this space to be primary

Overrides:

forceMoveToPrimary in class LeaderSelectorHandler

Throws:

RemoteException

getLastError

public Throwable getLastError()

Specified by:

getLastError in interface LeaderSelector

Overrides:

getLastError in class LeaderSelectorHandler

setLastError

public void setLastError(Throwable lastError)

Specified by:

setLastError in interface LeaderSelector

Overrides:

setLastError in class LeaderSelectorHandler