Package org.mases.datadistributionmanager

Interface ISmartDataDistributionMastership

public interface ISmartDataDistributionMastership

Interface to manage undrlying mastersip manager

Method Summary

Modifier and Type	Method	Description
void	ChangeMyState(DDM_INSTANCE_STATE newState)	Change the state of this instance
void	ChangeState(long instanceId, DDM_INSTANCE_STATE newState)	Change the state of the instance with instanceId
java.util.HashMap<java.lang.Long,ClusterHealthElement>	getClusterHealth()	Health of the cluster
java.util.HashMap<java.lang.Long,DDM_INSTANCE_STATE>	getClusterState()	State of the cluster
boolean	getIamNextPrimary()	Verify if this server will be elected as next primary
long	getLocalServerId()	Get my server identifier
long	getMessageDelay()	Gets actual message delay in the cluster
DDM_INSTANCE_STATE	getMyState()	Get my DDM_INSTANCE_STATE state
java.lang.String	GetParameter(java.lang.String paramName)	Get mastership parameter
long	getPrimaryServerId()	Gets identifier of the primary server
long	getUpTime()	Gets this instance uptime
boolean	RequestIAmNextPrimary()	Request to be the next primary server
void	SetParameter(java.lang.String paramName, java.lang.String paramValue)	Set mastership parameter
OPERATION_RESULT	Start(int dwMilliseconds)	Starts the manager
OPERATION_RESULT	Stop(int dwMilliseconds)	Stops the manager

Method Detail

SetParameter

void SetParameter(java.lang.String paramName,
                  java.lang.String paramValue)

Set mastership parameter

Parameters:

paramName - Parameter to set

paramValue - Value to set

GetParameter

java.lang.String GetParameter(java.lang.String paramName)

Get mastership parameter

Parameters:

paramName - Parameter to get

Returns:

Parameter value

Start

OPERATION_RESULT Start(int dwMilliseconds)

Starts the manager

Parameters:

dwMilliseconds - Timeout in ms

Returns:

OPERATION_RESULT

Stop

OPERATION_RESULT Stop(int dwMilliseconds)

Stops the manager

Parameters:

dwMilliseconds - Timeout in ms

Returns:

OPERATION_RESULT

ChangeMyState

void ChangeMyState(DDM_INSTANCE_STATE newState)

Change the state of this instance

Parameters:

newState - The new DDM_INSTANCE_STATE state

ChangeState

void ChangeState(long instanceId,
                 DDM_INSTANCE_STATE newState)

Change the state of the instance with instanceId

Parameters:

instanceId - Instance to change state

newState - Expected DDM_INSTANCE_STATE state

RequestIAmNextPrimary

boolean RequestIAmNextPrimary()

Request to be the next primary server

Returns:

True in case of success

getIamNextPrimary

boolean getIamNextPrimary()

Verify if this server will be elected as next primary

Returns:

True if this server is the next primary

getClusterState

java.util.HashMap<java.lang.Long,DDM_INSTANCE_STATE> getClusterState()

State of the cluster

Returns:

an HashMap between server id and DDM_INSTANCE_STATE

getClusterHealth

java.util.HashMap<java.lang.Long,ClusterHealthElement> getClusterHealth()

Health of the cluster

Returns:

an HashMap between server id and ClusterHealthElement

getMyState

DDM_INSTANCE_STATE getMyState()

Get my DDM_INSTANCE_STATE state

Returns:

this DDM_INSTANCE_STATE state

getLocalServerId

long getLocalServerId()

Get my server identifier

Returns:

local identifier

getPrimaryServerId

long getPrimaryServerId()

Gets identifier of the primary server

Returns:

primary identifier

getMessageDelay

long getMessageDelay()

Gets actual message delay in the cluster

Returns:

message delay in the cluster

getUpTime

long getUpTime()

Gets this instance uptime

Returns:

the uptime