com.cisco.oss.foundation.cluster.masterslave.consul

Class ConsulMastershipElector

java.lang.Object

com.cisco.oss.foundation.cluster.masterslave.consul.ConsulMastershipElector

All Implemented Interfaces:

MastershipElector

Direct Known Subclasses:

OpenstackConsulMastershipElector

public class ConsulMastershipElector
extends Object
implements MastershipElector

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

Field Summary

Fields

Modifier and Type	Field and Description
static String	ACTIVE_DATACENTER
protected String	activeVersionKey
protected com.jayway.jsonpath.Configuration	conf
protected com.cisco.oss.foundation.http.HttpClient	consulClient
protected String	jobName
protected String	mastershipKey
protected com.jayway.jsonpath.Configuration	nullableConf
protected String	sessionId
protected Thread	sessionTTlThread
protected int	ttlPeriod
protected int	ttlUpdateTime

Constructor Summary

Constructors

Constructor and Description
ConsulMastershipElector()

Method Summary

Modifier and Type	Method and Description
void	cleanupMaster()
void	close()
String	getActiveVersion()
protected String	getActiveVersionKey()
void	init(String id, String jobName)
boolean	isActiveDataCenter(String currentDataCenter)
boolean	isActiveKeyValue(String key, String currentValue)
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

ACTIVE_DATACENTER

public static final String ACTIVE_DATACENTER

See Also:

Constant Field Values

consulClient

protected com.cisco.oss.foundation.http.HttpClient consulClient

activeVersionKey

protected String activeVersionKey

sessionId

protected String sessionId

mastershipKey

protected String mastershipKey

jobName

protected String jobName

sessionTTlThread

protected Thread sessionTTlThread

ttlUpdateTime

protected int ttlUpdateTime

ttlPeriod

protected int ttlPeriod

conf

protected com.jayway.jsonpath.Configuration conf

nullableConf

protected com.jayway.jsonpath.Configuration nullableConf

Constructor Detail

ConsulMastershipElector

public ConsulMastershipElector()

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

isActiveKeyValue

public boolean isActiveKeyValue(String key,
                                String currentValue)

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

getActiveVersionKey

protected String getActiveVersionKey()

getActiveVersion

public String getActiveVersion()

Specified by:

getActiveVersion in interface MastershipElector

cleanupMaster

public void cleanupMaster()

Specified by:

cleanupMaster in interface MastershipElector