Package com.orientechnologies.orient.distributed.context

Interface OCoordinatedDistributedOps

All Known Implementing Classes:

OCoordinatedDistributedOpsImpl

public interface OCoordinatedDistributedOps

Method Summary

Modifier and Type	Method	Description
boolean	acceptSync(ONodeId sender, ONodeId receiver, ODatabaseId dbId, OSyncId syncId)
void	addDatabaseMember(ODatabaseId dbId, List<OAddNodeInfo> nodes, long version)
void	cancelAddDatabaseMember(ODatabaseId dbId, List<OAddNodeInfo> nodes)
void	cancelDeclareDatabase(OTransactionIdPromise promise, ODatabaseId dbId, String database)
void	cancelEnstablish()
void	cancelRegisterNode()
void	cancelSetState(ODatabaseId dbId, ONodeId nodeId, long version)
Optional<OSyncState>	canSync(ONodeId sender, ONodeId receiver, ODatabaseId dbId, OSyncId syncId, boolean canSync, OSyncMode mode, Optional<OTransactionSequenceStatus> sequenceStatus)
void	completeExecution(OTransactionIdPromise promise)
void	completeSync(OSyncId syncId)
Optional<ODistributedMessage>	consensusFailure(OTransactionIdPromise promise)
Optional<ODistributedMessage>	consensusSuccess(OTransactionIdPromise promise)
void	declareDatabase(OTransactionIdPromise promise, ODatabaseId dbId, String database, Set<ONodeId> partecipants, int minimumQuorum)
ODiscoverAction	discoverNode(ONodeId node)
Set<ONodeId>	enstablish(OGroupId networkId, Set<ONodeId> candidates)
boolean	executeOnOneOnline(ODatabaseId dbId, OStateAction execute)
ODatabasesTopology	getDatabaseTopology()
Set<ONodeId>	getNetworkMembers()
ONodeStateNetwork	getNetworkState()
OSyncState	getSyncState(OSyncId syncId)
boolean	isApplied(OTransactionId txId)
void	load(ONodeStateStore storeState)
Optional<OSyncInfo>	newSync(ODatabaseId dbId)
void	nodeFailure(ONodeId node, OTransactionIdPromise promise, OAcceptResult acceptResult)
ODiscoverAction	nodeJoinStart(ONodeId node, ONodeStateNetwork state)
void	nodeSuccess(ONodeId node, OTransactionIdPromise promise)
Optional<OAcceptResult>	receive(ODistributedMessage message)
void	registerNode(ONodeId node, long version)
void	setState(ODatabaseId db, ONodeId node, ODatabaseState state, long version)
Optional<OOperationStart>	start(OCompleteAction action)
Optional<OTransactionIdPromise>	startEstablish(Set<ONodeId> nodes, OCompleteAction action)
OSyncState	startSend(ONodeId to, ONodeId from, ODatabaseId dbId, OSyncId syncId, OSyncMode mode, Optional<OTransactionSequenceStatus> sequenceStatus)
void	unregisterNode(ONodeId node, long version)
Optional<OAcceptResult>	validateAddDatabaseMember(ODatabaseId dbId, List<OAddNodeInfo> nodes, long version)
Optional<OAcceptResult>	validateDeclareDatabase(OTransactionIdPromise promise, ODatabaseId databaseId, String database, Set<ONodeId> partecipants, int minimumQuorum)
Optional<OAcceptResult>	validateEnstablish(OGroupId networkId, Set<ONodeId> candidates)
Optional<OAcceptResult>	validateRegisterNode(ONodeId node, long version)
Optional<OAcceptResult>	validateSetState(ODatabaseId dbId, ONodeId nodeId, ODatabaseState state, long version)
boolean	waitOnlineQuorum(ODatabaseId dbId, Optional<Long> timeout)

Method Details

start

Optional<OOperationStart> start(OCompleteAction action)

receive

Optional<OAcceptResult> receive(ODistributedMessage message)

nodeSuccess

void nodeSuccess(ONodeId node,
 OTransactionIdPromise promise)

nodeFailure

void nodeFailure(ONodeId node,
 OTransactionIdPromise promise,
 OAcceptResult acceptResult)

consensusFailure

Optional<ODistributedMessage> consensusFailure(OTransactionIdPromise promise)

consensusSuccess

Optional<ODistributedMessage> consensusSuccess(OTransactionIdPromise promise)

completeExecution

void completeExecution(OTransactionIdPromise promise)

discoverNode

ODiscoverAction discoverNode(ONodeId node)

nodeJoinStart

ODiscoverAction nodeJoinStart(ONodeId node,
 ONodeStateNetwork state)

validateRegisterNode

Optional<OAcceptResult> validateRegisterNode(ONodeId node,
 long version)

registerNode

void registerNode(ONodeId node,
 long version)

unregisterNode

void unregisterNode(ONodeId node,
 long version)

cancelRegisterNode

void cancelRegisterNode()

startEstablish

Optional<OTransactionIdPromise> startEstablish(Set<ONodeId> nodes,
 OCompleteAction action)

validateEnstablish

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

enstablish

Set<ONodeId> enstablish(OGroupId networkId,
 Set<ONodeId> candidates)

cancelEnstablish

void cancelEnstablish()

validateDeclareDatabase

Optional<OAcceptResult> validateDeclareDatabase(OTransactionIdPromise promise,
 ODatabaseId databaseId,
 String database,
 Set<ONodeId> partecipants,
 int minimumQuorum)

declareDatabase

void declareDatabase(OTransactionIdPromise promise,
 ODatabaseId dbId,
 String database,
 Set<ONodeId> partecipants,
 int minimumQuorum)

cancelDeclareDatabase

void cancelDeclareDatabase(OTransactionIdPromise promise,
 ODatabaseId dbId,
 String database)

validateAddDatabaseMember

Optional<OAcceptResult> validateAddDatabaseMember(ODatabaseId dbId,
 List<OAddNodeInfo> nodes,
 long version)

addDatabaseMember

void addDatabaseMember(ODatabaseId dbId,
 List<OAddNodeInfo> nodes,
 long version)

cancelAddDatabaseMember

void cancelAddDatabaseMember(ODatabaseId dbId,
 List<OAddNodeInfo> nodes)

validateSetState

Optional<OAcceptResult> validateSetState(ODatabaseId dbId,
 ONodeId nodeId,
 ODatabaseState state,
 long version)

setState

void setState(ODatabaseId db,
 ONodeId node,
 ODatabaseState state,
 long version)

cancelSetState

void cancelSetState(ODatabaseId dbId,
 ONodeId nodeId,
 long version)

newSync

Optional<OSyncInfo> newSync(ODatabaseId dbId)

acceptSync

boolean acceptSync(ONodeId sender,
 ONodeId receiver,
 ODatabaseId dbId,
 OSyncId syncId)

canSync

Optional<OSyncState> canSync(ONodeId sender,
 ONodeId receiver,
 ODatabaseId dbId,
 OSyncId syncId,
 boolean canSync,
 OSyncMode mode,
 Optional<OTransactionSequenceStatus> sequenceStatus)

startSend

OSyncState startSend(ONodeId to,
 ONodeId from,
 ODatabaseId dbId,
 OSyncId syncId,
 OSyncMode mode,
 Optional<OTransactionSequenceStatus> sequenceStatus)

getSyncState

OSyncState getSyncState(OSyncId syncId)

getDatabaseTopology

ODatabasesTopology getDatabaseTopology()

getNetworkMembers

Set<ONodeId> getNetworkMembers()

getNetworkState

ONodeStateNetwork getNetworkState()

load

void load(ONodeStateStore storeState)

executeOnOneOnline

boolean executeOnOneOnline(ODatabaseId dbId,
 OStateAction execute)

waitOnlineQuorum

boolean waitOnlineQuorum(ODatabaseId dbId,
 Optional<Long> timeout)
                  throws InterruptedException

Throws:

InterruptedException

isApplied

boolean isApplied(OTransactionId txId)

completeSync

void completeSync(OSyncId syncId)