com.cisco.oss.foundation.cluster.masterslave.mongo

Class MongoMastershipElector

java.lang.Object

com.cisco.oss.foundation.cluster.masterslave.mongo.MongoMastershipElector

All Implemented Interfaces:

MastershipElector

public class MongoMastershipElector
extends Object
implements MastershipElector

Mongo implementation for logic for electing new masters. Created by Yair Ogen (yaogen) on 14/02/2016.

Field Summary

Fields

Modifier and Type	Field and Description
static String	ACTIVE_DATACENTER
static String	ACTIVE_VERSION
static String	COMPONENT
static String	ID
static String	JOB
static String	LEASE_RENEWED
static String	MASTER_INSTANCE_ID

Constructor Summary

Constructors

Constructor and Description
MongoMastershipElector()

Method Summary

Modifier and Type	Method and Description
void	cleanupMaster()
void	close()
com.allanbank.mongodb.bson.Document	createNewDocument()
String	getActiveVersion()
void	init(String id, String jobName)
boolean	isActiveDataCenter(String currentDataCenter)
boolean	isActiveVersion(String currentVersion)
boolean	isMaster()
boolean	isReady()

Methods inherited from class java.lang.Object

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

Field Detail

LEASE_RENEWED

public static final String LEASE_RENEWED

See Also:

Constant Field Values

ACTIVE_VERSION

public static final String ACTIVE_VERSION

See Also:

Constant Field Values

ACTIVE_DATACENTER

public static final String ACTIVE_DATACENTER

See Also:

Constant Field Values

MASTER_INSTANCE_ID

public static final String MASTER_INSTANCE_ID

See Also:

Constant Field Values

COMPONENT

public static final String COMPONENT

See Also:

Constant Field Values

JOB

public static final String JOB

See Also:

Constant Field Values

ID

public static final String ID

See Also:

Constant Field Values

Constructor Detail

MongoMastershipElector

public MongoMastershipElector()

Method Detail

init

public void init(String id,
                 String jobName)

Specified by:

init in interface MastershipElector

isReady

public boolean isReady()

Specified by:

isReady in interface MastershipElector

isActiveVersion

public boolean isActiveVersion(String currentVersion)

Specified by:

isActiveVersion in interface MastershipElector

isActiveDataCenter

public boolean isActiveDataCenter(String currentDataCenter)

Specified by:

isActiveDataCenter in interface MastershipElector

isMaster

public boolean isMaster()

Specified by:

isMaster in interface MastershipElector

close

public void close()

Specified by:

close in interface MastershipElector

createNewDocument

public com.allanbank.mongodb.bson.Document createNewDocument()

getActiveVersion

public String getActiveVersion()

Specified by:

getActiveVersion in interface MastershipElector

cleanupMaster

public void cleanupMaster()

Specified by:

cleanupMaster in interface MastershipElector