Package com.orientechnologies.orient.distributed.context.coordination.message.operation

Interface OOperationContext

All Known Implementing Classes:

OrientDBDistributed

public interface OOperationContext

Method Summary

Modifier and Type	Method	Description
void	apllied(OTransactionIdPromise promise)
void	cancel(OTransactionIdPromise promise)
void	checkMissing(ONodeId requestTo)
void	confirm(OTransactionIdPromise promise)
void	declareDatabase(OTransactionIdPromise promise, ODatabaseId id, String name, Set<OAddNodeInfo> partecipants, int minimumQuorum)
void	distributedDrop(ODatabaseId dbId, OVersion version, OTransactionIdPromise promise)
void	establish(OGroupId groupId, Set<ONodeId> candidates, OTransactionIdPromise promise)
OCoordinatedDistributedOps	getOps()
void	mergeNode(ONodeId node, ONodeStateNetwork state, ONodeStateNetwork original, OTransactionIdPromise promise)
Optional<OAcceptResult>	propose(ODistributedMessage message)
void	recoordinateOperation(OTransactionIdPromise promise, OOperationMessage op)
void	registerNode(ONodeId node, OVersion version, OTransactionIdPromise promise)

Method Details

getOps

OCoordinatedDistributedOps getOps()

mergeNode

void mergeNode(ONodeId node,
 ONodeStateNetwork state,
 ONodeStateNetwork original,
 OTransactionIdPromise promise)

establish

void establish(OGroupId groupId,
 Set<ONodeId> candidates,
 OTransactionIdPromise promise)

distributedDrop

void distributedDrop(ODatabaseId dbId,
 OVersion version,
 OTransactionIdPromise promise)

declareDatabase

void declareDatabase(OTransactionIdPromise promise,
 ODatabaseId id,
 String name,
 Set<OAddNodeInfo> partecipants,
 int minimumQuorum)

registerNode

void registerNode(ONodeId node,
 OVersion version,
 OTransactionIdPromise promise)

recoordinateOperation

void recoordinateOperation(OTransactionIdPromise promise,
 OOperationMessage op)

apllied

void apllied(OTransactionIdPromise promise)

propose

Optional<OAcceptResult> propose(ODistributedMessage message)

confirm

void confirm(OTransactionIdPromise promise)

cancel

void cancel(OTransactionIdPromise promise)

checkMissing

void checkMissing(ONodeId requestTo)