com.orientechnologies.orient.server.distributed

Interface ODistributedDatabase

All Known Implementing Classes:

ODistributedDatabaseImpl

public interface ODistributedDatabase

Generic Distributed Database interface.

Author:

Luca Garulli (l.garulli--at--orientdb.com)

Method Summary

Modifier and Type	Method and Description
void	checkNodeInConfiguration(ODistributedConfiguration cfg, String serverName)
void	checkReverseSync(OTransactionSequenceStatus lastState)
OTxMetadataHolder	commit(OTransactionId id)
String	dump()
ODatabaseDocumentInternal	getDatabaseInstance()
String	getDatabaseName()
ODistributedServerManager	getManager()
long	getProcessedRequests()
long	getReceivedRequests()
ODistributedSyncConfiguration	getSyncConfiguration()
ODistributedTxContext	getTxContext(ODistributedRequestId requestId)
void	handleUnreachableNode(String nodeName) Unlocks all the record locked by node iNodeName
List<OTransactionId>	missingTransactions(OTransactionSequenceStatus lastState)
Optional<OTransactionId>	nextId()
ODistributedTxContext	popTxContext(ODistributedRequestId requestId)
void	processRequest(ODistributedRequest request, boolean waitForAcceptingRequests)
void	reEnqueue(int senderNodeId, long msgSequence, String databaseName, ORemoteTask payload, int retryCount, int autoRetryDelay)
ODistributedTxContext	registerTxContext(ODistributedRequestId reqId, ODistributedTxContext ctx)
void	rollback(OTransactionId id)
ODistributedResponse	send2Nodes(ODistributedRequest iRequest, Collection<String> iClusterNames, Collection<String> iNodes, ODistributedRequest.EXECUTION_MODE iExecutionMode, Object localResult, OCallable<Void,ODistributedRequestId> iAfterSentCallback, OCallable<Void,ODistributedResponseManager> endCallback)
void	setLSN(String sourceNodeName, OLogSequenceNumber taskLastLSN, boolean writeLastOperation)
void	setOnline()
Optional<OTransactionSequenceStatus>	status()
void	unlockResourcesOfServer(ODatabaseDocumentInternal database, String serverName)
Optional<OTransactionId>	validate(OTransactionId id)
void	validateStatus(OTransactionSequenceStatus status)
void	waitForOnline()

Method Detail

getDatabaseName

String getDatabaseName()

send2Nodes

ODistributedResponse send2Nodes(ODistributedRequest iRequest,
                                Collection<String> iClusterNames,
                                Collection<String> iNodes,
                                ODistributedRequest.EXECUTION_MODE iExecutionMode,
                                Object localResult,
                                OCallable<Void,ODistributedRequestId> iAfterSentCallback,
                                OCallable<Void,ODistributedResponseManager> endCallback)

setOnline

void setOnline()

dump

String dump()

unlockResourcesOfServer

void unlockResourcesOfServer(ODatabaseDocumentInternal database,
                             String serverName)

handleUnreachableNode

void handleUnreachableNode(String nodeName)

Unlocks all the record locked by node iNodeName

Parameters:

nodeName - node id

getSyncConfiguration

ODistributedSyncConfiguration getSyncConfiguration()

waitForOnline

void waitForOnline()

reEnqueue

void reEnqueue(int senderNodeId,
               long msgSequence,
               String databaseName,
               ORemoteTask payload,
               int retryCount,
               int autoRetryDelay)

processRequest

void processRequest(ODistributedRequest request,
                    boolean waitForAcceptingRequests)

validate

Optional<OTransactionId> validate(OTransactionId id)

status

Optional<OTransactionSequenceStatus> status()

rollback

void rollback(OTransactionId id)

commit

OTxMetadataHolder commit(OTransactionId id)

registerTxContext

ODistributedTxContext registerTxContext(ODistributedRequestId reqId,
                                        ODistributedTxContext ctx)

popTxContext

ODistributedTxContext popTxContext(ODistributedRequestId requestId)

getTxContext

ODistributedTxContext getTxContext(ODistributedRequestId requestId)

getManager

ODistributedServerManager getManager()

getDatabaseInstance

ODatabaseDocumentInternal getDatabaseInstance()

getReceivedRequests

long getReceivedRequests()

getProcessedRequests

long getProcessedRequests()

checkNodeInConfiguration

void checkNodeInConfiguration(ODistributedConfiguration cfg,
                              String serverName)

setLSN

void setLSN(String sourceNodeName,
            OLogSequenceNumber taskLastLSN,
            boolean writeLastOperation)
     throws IOException

Throws:

IOException

nextId

Optional<OTransactionId> nextId()

missingTransactions

List<OTransactionId> missingTransactions(OTransactionSequenceStatus lastState)

validateStatus

void validateStatus(OTransactionSequenceStatus status)

checkReverseSync

void checkReverseSync(OTransactionSequenceStatus lastState)