Package com.orientechnologies.orient.distributed.context.topology

Class OTopologyManager

java.lang.Object

com.orientechnologies.orient.distributed.context.topology.OTopologyManager

All Implemented Interfaces:

OTopologyEvents

public class OTopologyManager
extends Object
implements OTopologyEvents

Constructor Summary

Constructors

Constructor	Description
OTopologyManager(ONodeId current, OGroupId groupId, int minimumQuorum)

Method Summary

Modifier and Type	Method	Description
void	cancelEnstablish()
void	cancelRegisterPromise()
boolean	enoughNodes()
Set<ONodeId>	finalizeEnstablish(OGroupId groupId, Set<ONodeId> candidates)
OGroupId	getGroupId()
Set<ONodeId>	getMembers()
int	getMinimumQuorum()
OTopologyStateNetwork	getNetworkState()
ONodeId	getNodeId()
int	getQuorum()
ONetworkTopologyStore	getStore()
long	getVersion()
protected boolean	hasMember(ONodeId node)
void	load(ONetworkTopologyStore nodeStateStore)
ODiscoverAction	nodeDiscovered(ONodeId node)
ODiscoverAction	nodeJoinStart(ONodeId node, OTopologyStateNetwork externState)
Optional<OAcceptResult>	promiseRegister(ONodeId toAdd, long version)
void	register(ONodeId toRegister, long version)
void	unregister(ONodeId node, long version)
Optional<OAcceptResult>	validateEnstablish(OGroupId groupId, Set<ONodeId> candidates)

Methods inherited from class java.lang.Object

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

Constructor Details

OTopologyManager

public OTopologyManager(ONodeId current,
 OGroupId groupId,
 int minimumQuorum)

Method Details

nodeDiscovered

public ODiscoverAction nodeDiscovered(ONodeId node)

Specified by:

nodeDiscovered in interface OTopologyEvents

hasMember

protected boolean hasMember(ONodeId node)

getVersion

public long getVersion()

promiseRegister

public Optional<OAcceptResult> promiseRegister(ONodeId toAdd,
 long version)

register

public void register(ONodeId toRegister,
 long version)

enoughNodes

public boolean enoughNodes()

unregister

public void unregister(ONodeId node,
 long version)

getQuorum

public int getQuorum()

getMinimumQuorum

public int getMinimumQuorum()

getMembers

public Set<ONodeId> getMembers()

finalizeEnstablish

public Set<ONodeId> finalizeEnstablish(OGroupId groupId,
 Set<ONodeId> candidates)

validateEnstablish

public Optional<OAcceptResult> validateEnstablish(OGroupId groupId,
 Set<ONodeId> candidates)

nodeJoinStart

public ODiscoverAction nodeJoinStart(ONodeId node,
 OTopologyStateNetwork externState)

getNetworkState

public OTopologyStateNetwork getNetworkState()

load

public void load(ONetworkTopologyStore nodeStateStore)

getStore

public ONetworkTopologyStore getStore()

cancelRegisterPromise

public void cancelRegisterPromise()

cancelEnstablish

public void cancelEnstablish()

getGroupId

public OGroupId getGroupId()

getNodeId

public ONodeId getNodeId()