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 Details

    • OTopologyManager

      public OTopologyManager(ONodeId current, 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 boolean 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 void finalizeEnstablish(OGroupId groupId, Set<ONodeId> candidates)

    • validateEnstablish

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

    • nodeJoinStart

      public ODiscoverAction nodeJoinStart(ONodeId node, ONodeStateNetwork externState)

    • getNetworkState

      public ONodeStateNetwork getNetworkState()

    • load

      public void load(ONodeStateStore nodeStateStore)

    • cancelRegisterPromise

      public void cancelRegisterPromise()

    • cancelEnstablish

      public void cancelEnstablish()