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 TypeMethodDescriptionvoidcheckReverseSync(OTransactionSequenceStatus lastState) dump()voidlonglonggetTxContext(ODistributedRequestId requestId) voidhandleUnreachableNode(String nodeName) Unlocks all the record locked by node iNodeNamemissingTransactions(OTransactionSequenceStatus lastState) nextId()popTxContext(ODistributedRequestId requestId) voidprocessRequest(ODistributedRequest request, boolean waitForAcceptingRequests) voidreEnqueue(ODistributedRequestId requestId, String databaseName, ORemoteTask payload, int retryCount, int autoRetryDelay) voidvoidstatus()voidunlockResourcesOfServer(ODatabaseDocumentInternal database, String serverName) voidvoid
-
Method Details
-
getDatabaseName
String getDatabaseName() -
setOnline
void setOnline() -
dump
String dump() -
unlockResourcesOfServer
-
handleUnreachableNode
Unlocks all the record locked by node iNodeName- Parameters:
nodeName- node id
-
waitForOnline
void waitForOnline() -
reEnqueue
void reEnqueue(ODistributedRequestId requestId, String databaseName, ORemoteTask payload, int retryCount, int autoRetryDelay) -
processRequest
-
validate
-
status
Optional<OTransactionSequenceStatus> status() -
rollback
-
commit
-
registerTxContext
-
popTxContext
-
getTxContext
-
getManager
ODistributedServerManager getManager() -
getDatabaseInstance
ODatabaseDocumentInternal getDatabaseInstance() -
getReceivedRequests
long getReceivedRequests() -
getProcessedRequests
long getProcessedRequests() -
nextId
Optional<OTransactionIdPromise> nextId() -
nextDDLId
Optional<ORawPair<OTransactionIdPromise,OTransactionIdPromise>> nextDDLId() -
missingTransactions
-
validateStatus
-
checkReverseSync
-
fillStatus
void fillStatus()
-