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 |
---|---|
String |
OStorageRemote.incrementalBackup(String backupDirectory,
OCallable<Void,Void> started) |
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 |
ODatabaseDocumentAbstract.executeWithRetries(OCallable<Object,Integer> callback,
int maxRetry) |
static Object |
ODatabaseDocumentAbstract.executeWithRetries(OCallable<Object,Integer> callback,
int maxRetry,
int waitBetweenRetry) |
static Object |
ODatabaseDocumentAbstract.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 |
---|---|
protected void |
LiveQueryListenerImpl.execInSeparateDatabase(OCallable iCallback) |
Modifier and Type | Method and Description |
---|---|
String |
OStorage.incrementalBackup(String backupDirectory,
OCallable<Void,Void> started) |
Modifier and Type | Method and Description |
---|---|
String |
OAbstractPaginatedStorage.incrementalBackup(String backupDirectory,
OCallable<Void,Void> started) |
Modifier and Type | Method and Description |
---|---|
Object |
OSystemDatabase.execute(OCallable<Object,OResultSet> callback,
String sql,
Object... args) |
void |
OSystemDatabase.executeInDBScope(OCallable<Void,ODatabaseSession> callback) |
<T> T |
OSystemDatabase.executeWithDB(OCallable<T,ODatabaseSession> 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).
|
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.
|
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) |
ODistributedResponseManagerImpl(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 |
OHttpResponseImpl.sendStream(int iCode,
String iReason,
String iContentType,
String iFileName,
OCallable<Void,OChunkedResponse> iWriter) |
void |
OHttpGraphResponse.sendStream(int iCode,
String iReason,
String iContentType,
String iFileName,
OCallable<Void,OChunkedResponse> iWriter) |
abstract 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–2020 OrientDB. All rights reserved.