| Modifier and Type | Method and Description |
|---|---|
static <T> T[] |
OMultiValue.array(Object iValue,
Class<? extends T> iClass,
OCallable<Object,Object> iCallback) |
static Object |
OMultiValue.convert(Object iObject,
OCallable<Object,Object> iCallback) |
| Modifier and Type | Method and Description |
|---|---|
void |
OTableFormatter.writeRecords(List<? extends OIdentifiable> resultSet,
int limit,
OCallable<Object,OIdentifiable> iAfterDump) |
| Modifier and Type | Method and Description |
|---|---|
OCommandManager |
OCommandManager.registerExecutor(Class<? extends OCommandRequest> iRequest,
Class<? extends OCommandExecutor> iExecutor,
OCallable<Void,OCommandRequest> iConfigCallback) |
| Modifier and Type | Method and Description |
|---|---|
static Object |
ODatabaseDocumentTx.executeWithRetries(OCallable<Object,Integer> callback,
int maxRetry) |
static Object |
ODatabaseDocumentTx.executeWithRetries(OCallable<Object,Integer> callback,
int maxRetry,
int waitBetweenRetry) |
static Object |
ODatabaseDocumentTx.executeWithRetries(OCallable<Object,Integer> callback,
int maxRetry,
int waitBetweenRetry,
ORecord[] recordToReloadOnRetry) |
| Modifier and Type | Method and Description |
|---|---|
OCallable<Object,Map<Object,Object>> |
OFunction.getCallback() |
| Modifier and Type | Method and Description |
|---|---|
OFunction |
OFunction.setCallback(OCallable<Object,Map<Object,Object>> callback) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
OCommandExecutorSQLLiveSelect.execInSeparateDatabase(OCallable iCallback) |
static Object |
OSQLEngine.foreachRecord(OCallable<Object,OIdentifiable> iCallable,
Object iCurrent,
OCommandContext iContext) |
| Modifier and Type | Method and Description |
|---|---|
void |
OLocalPaginatedStorage.closeAndMove(OCallable<Void,String> mover) |
| Modifier and Type | Method and Description |
|---|---|
Object |
OSystemDatabase.execute(OCallable<Object,Object> callback,
String sql,
Object... args) |
void |
OSystemDatabase.executeInDBScope(OCallable<Void,ODatabase> callback) |
| Modifier and Type | Method and Description |
|---|---|
OCallable<Void,ODistributedRequestId> |
OAsynchDistributedOperation.getAfterSendCallback() |
OCallable<Object,OPair<ODistributedRequestId,Object>> |
OAsynchDistributedOperation.getCallback() |
| Modifier and Type | Method and Description |
|---|---|
<T> T |
ODistributedServerManager.executeInDistributedDatabaseLock(String databaseName,
long timeoutLocking,
OModifiableDistributedConfiguration lastCfg,
OCallable<T,OModifiableDistributedConfiguration> iCallback)
Executes an operation protected by a distributed lock (one per database).
|
boolean |
ODistributedResponseManager.executeInLock(OCallable<Boolean,ODistributedResponseManager> callback) |
ODistributedResponse |
ODistributedDatabase.send2Nodes(ODistributedRequest iRequest,
Collection<String> iClusterNames,
Collection<String> iNodes,
ODistributedRequest.EXECUTION_MODE iExecutionMode,
Object localResult,
OCallable<Void,ODistributedRequestId> iAfterSentCallback,
OCallable<Void,ODistributedResponseManager> endCallback) |
ODistributedResponse |
ODistributedDatabase.send2Nodes(ODistributedRequest iRequest,
Collection<String> iClusterNames,
Collection<String> iNodes,
ODistributedRequest.EXECUTION_MODE iExecutionMode,
Object localResult,
OCallable<Void,ODistributedRequestId> iAfterSentCallback,
OCallable<Void,ODistributedResponseManager> endCallback) |
ODistributedResponse |
ODistributedServerManager.sendRequest(String iDatabaseName,
Collection<String> iClusterNames,
Collection<String> iTargetNodeNames,
ORemoteTask iTask,
long messageId,
ODistributedRequest.EXECUTION_MODE iExecutionMode,
Object localResult,
OCallable<Void,ODistributedRequestId> iAfterSentCallback,
OCallable<Void,ODistributedResponseManager> endCallback)
Sends a distributed request against multiple servers.
|
ODistributedResponse |
ODistributedServerManager.sendRequest(String iDatabaseName,
Collection<String> iClusterNames,
Collection<String> iTargetNodeNames,
ORemoteTask iTask,
long messageId,
ODistributedRequest.EXECUTION_MODE iExecutionMode,
Object localResult,
OCallable<Void,ODistributedRequestId> iAfterSentCallback,
OCallable<Void,ODistributedResponseManager> endCallback)
Sends a distributed request against multiple servers.
|
boolean |
ODistributedDatabase.waitIsReady(OCallable<Boolean,Void> retryCallback) |
| Constructor and Description |
|---|
OAsynchDistributedOperation(String iDatabaseName,
Set<String> iClusterNames,
Collection<String> iNodes,
ORemoteTask iTask,
long iMessageId,
Object iLocalResult,
OCallable<Void,ODistributedRequestId> iAfterRequestCallback,
OCallable<Object,OPair<ODistributedRequestId,Object>> iCallback) |
OAsynchDistributedOperation(String iDatabaseName,
Set<String> iClusterNames,
Collection<String> iNodes,
ORemoteTask iTask,
long iMessageId,
Object iLocalResult,
OCallable<Void,ODistributedRequestId> iAfterRequestCallback,
OCallable<Object,OPair<ODistributedRequestId,Object>> iCallback) |
ODistributedResponseManager(ODistributedServerManager iManager,
ODistributedRequest iRequest,
Collection<String> expectedResponses,
Set<String> iNodesConcurInQuorum,
int iTotalExpectedResponses,
int iQuorum,
boolean iWaitForLocalNode,
long iSynchTimeout,
long iTotalTimeout,
boolean iGroupResponsesByResult,
OCallable<Void,ODistributedResponseManager> endCallback) |
| Modifier and Type | Method and Description |
|---|---|
void |
OHttpResponse.sendStream(int iCode,
String iReason,
String iContentType,
String iFileName,
OCallable<Void,OChunkedResponse> iWriter) |
| Modifier and Type | Method and Description |
|---|---|
void |
OServerCommandGetStaticContent.registerVirtualFolder(String iName,
OCallable<Object,String> iCallback) |
| Modifier and Type | Method and Description |
|---|---|
protected OCallable<Object,String> |
OServerPluginManager.createStaticLinkCallback(OServerPluginInfo iPluginData,
URL wwwURL) |
| Modifier and Type | Method and Description |
|---|---|
protected List<OBaseWorkload.OBaseWorkLoadContext> |
OBaseWorkload.executeOperation(ODatabaseIdentifier dbIdentifier,
OBaseWorkload.OWorkLoadResult result,
OStressTesterSettings settings,
OCallable<Void,OBaseWorkload.OBaseWorkLoadContext> callback) |
| Modifier and Type | Method and Description |
|---|---|
<RET> RET |
OrientBaseGraph.executeOutsideTx(OCallable<RET,OrientBaseGraph> iCallable,
String... iOperationStrings) |
Copyright © 2009–2025 OrientDB. All rights reserved.