Package com.orientechnologies.orient.distributed.context

Interface OCoordinatedDistributedOps

All Known Implementing Classes:

OCoordinatedDistributedOpsImpl

public interface OCoordinatedDistributedOps

Method Summary

Modifier and Type	Method	Description
void	cancelEnstablish()
void	cancelRegisterPromise()
void	completeExecution(OTransactionId complete)
ODiscoverAction	discoverNode(ONodeId node)
void	enstablish(OGroupId networkId, Set<ONodeId> candidates)
void	failure(ONodeId node, OTransactionIdPromise promise, OAcceptResult acceptResult)
Set<ONodeId>	getMembers()
ONodeStateNetwork	getNetworkState()
void	load(ONodeStateStore nodeStateStore)
ODiscoverAction	nodeJoinStart(ONodeId node, ONodeStateNetwork state)
boolean	promiseRegister(ONodeId node, long version)
void	registerNode(ONodeId node, long version)
OOperationStart	start(OTransactionIdPromise promise, OCompleteAction action)
void	startEstablish(OTransactionIdPromise idPromise, Set<ONodeId> nodes, OCompleteAction action)
void	success(ONodeId node, OTransactionIdPromise promise)
void	unregisterNode(ONodeId node, long version)
Optional<OAcceptResult>	validateEnstablish(OGroupId networkId, Set<ONodeId> candidates)

Method Details

start

OOperationStart start(OTransactionIdPromise promise,
 OCompleteAction action)

success

void success(ONodeId node,
 OTransactionIdPromise promise)

failure

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

completeExecution

void completeExecution(OTransactionId complete)

discoverNode

ODiscoverAction discoverNode(ONodeId node)

nodeJoinStart

ODiscoverAction nodeJoinStart(ONodeId node,
 ONodeStateNetwork state)

promiseRegister

boolean promiseRegister(ONodeId node,
 long version)

registerNode

void registerNode(ONodeId node,
 long version)

unregisterNode

void unregisterNode(ONodeId node,
 long version)

startEstablish

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

validateEnstablish

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

enstablish

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

getMembers

Set<ONodeId> getMembers()

getNetworkState

ONodeStateNetwork getNetworkState()

load

void load(ONodeStateStore nodeStateStore)

cancelRegisterPromise

void cancelRegisterPromise()

cancelEnstablish

void cancelEnstablish()