Package 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	Description
void	checkReverseSync(OTransactionSequenceStatus lastState)
OTxMetadataHolder	commit(OTransactionIdPromise id)
String	dump()
void	fillStatus()
ODatabaseDocumentInternal	getDatabaseInstance()
String	getDatabaseName()
ODistributedServerManager	getManager()
long	getProcessedRequests()
long	getReceivedRequests()
ODistributedTxContext	getTxContext(ODistributedRequestId requestId)
void	handleUnreachableNode(String nodeName)	Unlocks all the record locked by node iNodeName
List<OTransactionId>	missingTransactions(OTransactionSequenceStatus lastState)
Optional<ORawPair<OTransactionIdPromise,OTransactionIdPromise>>	nextDDLId()
Optional<OTransactionIdPromise>	nextId()
ODistributedTxContext	popTxContext(ODistributedRequestId requestId)
void	processRequest(ODistributedRequest request, boolean waitForAcceptingRequests)
void	reEnqueue(ODistributedRequestId requestId, String databaseName, ORemoteTask payload, int retryCount, int autoRetryDelay)
ODistributedTxContext	registerTxContext(ODistributedRequestId reqId, ODistributedTxContext ctx)
void	rollback(OTransactionIdPromise id)
void	setOnline()
Optional<OTransactionSequenceStatus>	status()
void	unlockResourcesOfServer(ODatabaseDocumentInternal database, String serverName)
ValidationResult	validate(OTransactionIdPromise id)
void	validateStatus(OTransactionSequenceStatus status)
void	waitForOnline()

Method Details

getDatabaseName

String getDatabaseName()

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

waitForOnline

void waitForOnline()

reEnqueue

void reEnqueue(ODistributedRequestId requestId,
 String databaseName,
 ORemoteTask payload,
 int retryCount,
 int autoRetryDelay)

processRequest

void processRequest(ODistributedRequest request,
 boolean waitForAcceptingRequests)

validate

ValidationResult validate(OTransactionIdPromise id)

status

Optional<OTransactionSequenceStatus> status()

rollback

void rollback(OTransactionIdPromise id)

commit

OTxMetadataHolder commit(OTransactionIdPromise 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()

nextId

Optional<OTransactionIdPromise> nextId()

nextDDLId

Optional<ORawPair<OTransactionIdPromise,OTransactionIdPromise>> nextDDLId()

missingTransactions

List<OTransactionId> missingTransactions(OTransactionSequenceStatus lastState)

validateStatus

void validateStatus(OTransactionSequenceStatus status)

checkReverseSync

void checkReverseSync(OTransactionSequenceStatus lastState)

fillStatus

void fillStatus()