Class ODatabasesTopologyState
java.lang.Object
com.orientechnologies.orient.distributed.context.ODatabasesTopologyState
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionbooleanacceptSync(ONodeId sender, ONodeId receiver, ODatabaseId dbId, OSyncId syncId) voidcancelPomise(OTransactionIdPromise promise, ODatabaseId db, String name) voidcancelPomiseSetState(ODatabaseId dbId, ONodeId nodeId, long version) canSync(ONodeId sender, ONodeId receiver, ODatabaseId dbId, OSyncId syncId, boolean canSync, OSyncMode mode, Optional<OTransactionSequenceStatus> sequenceStatus) voiddeclareDatabase(OTransactionIdPromise promise, ODatabaseId db, String name, Set<ONodeId> partecipants, int minimumQuorum) voiddeclareNode(ODatabaseId db, String name, ONodeId node, ONodeRole role, ODatabaseState state) booleanexecuteOnOneOnline(ODatabaseId dbId, OStateAction execute) getDatabaseId(String databaseName) getDatabaseName(ODatabaseId dbId) getDatabaseStatus(ONodeId nodeID, ODatabaseId dbId) longgetNodeRole(ONodeId nodeId, ODatabaseId dbId) getNodeState(ODatabaseId dbId, ONodeId nodeId) getOnlineNodes(ODatabaseId dbId) getSyncState(OSyncId syncId) booleanisMain(ODatabaseId dbId, ONodeId nodeId) newSync(ODatabaseId dbId) promiseDeclare(OTransactionIdPromise promise, ODatabaseId db, String name, Set<ONodeId> partecipants, int minimumQuorum) promiseState(ODatabaseId dbId, ONodeId nodeId, ODatabaseState state, long version) voidreceiverNetworkState(List<ODatabaseStateNetwork> network) voidsetState(ODatabaseId db, ONodeId node, ODatabaseState state, long version) startSend(ONodeId to, ONodeId from, ODatabaseId dbId, OSyncId syncId, OSyncMode mode, Optional<OTransactionSequenceStatus> sequenceStatus) booleanwaitOnline(ODatabaseId dbId, ONodeId nodeId) booleanwaitOnlineOne(ODatabaseId dbId) booleanwaitOnlineQuorum(ODatabaseId dbId, Optional<Long> timeout)
-
Constructor Details
-
ODatabasesTopologyState
-
-
Method Details
-
promiseDeclare
public Optional<OAcceptResult> promiseDeclare(OTransactionIdPromise promise, ODatabaseId db, String name, Set<ONodeId> partecipants, int minimumQuorum) -
cancelPomise
-
declareDatabase
public void declareDatabase(OTransactionIdPromise promise, ODatabaseId db, String name, Set<ONodeId> partecipants, int minimumQuorum) -
declareNode
public void declareNode(ODatabaseId db, String name, ONodeId node, ONodeRole role, ODatabaseState state) -
setState
-
listDatabaseIds
-
promiseState
public Optional<OAcceptResult> promiseState(ODatabaseId dbId, ONodeId nodeId, ODatabaseState state, long version) -
getDatabaseVersion
-
getNodeState
-
cancelPomiseSetState
-
waitOnline
-
waitOnlineQuorum
public boolean waitOnlineQuorum(ODatabaseId dbId, Optional<Long> timeout) throws InterruptedException - Throws:
InterruptedException
-
waitOnlineOne
-
executeOnOneOnline
-
getOnlineNodes
-
newSync
-
canSync
public Optional<OSyncState> canSync(ONodeId sender, ONodeId receiver, ODatabaseId dbId, OSyncId syncId, boolean canSync, OSyncMode mode, Optional<OTransactionSequenceStatus> sequenceStatus) -
startSend
public OSyncState startSend(ONodeId to, ONodeId from, ODatabaseId dbId, OSyncId syncId, OSyncMode mode, Optional<OTransactionSequenceStatus> sequenceStatus) -
getSyncState
-
getDatabaseName
-
acceptSync
-
getDatabaseId
-
isMain
-
receiverNetworkState
-
getNetworkState
-
getDatabases
-
getDatabaseStatus
-
getNodeRole
-