| 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 |
|---|---|
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 |
OAbstractPaginatedStorage.scanCluster(String iClusterName,
boolean iAscendingOrder,
long iFrom,
long iTo,
OCallable<Boolean,ORecord> iCallback) |
protected long |
OAbstractPaginatedStorage.scanClusterInLock(boolean iAscendingOrder,
OPaginatedCluster cluster,
long iFrom,
long iTo,
long iLimit,
OCallable<Boolean,ORecord> iCallback) |
| Modifier and Type | Method and Description |
|---|---|
long |
OPaginatedCluster.scan(boolean ascendingOrder,
long from,
long to,
long limit,
OCallable<Boolean,ORecord> callback) |
| Modifier and Type | Method and Description |
|---|---|
Object |
OSystemDatabase.execute(OCallable<Object,Object> callback,
String serverUser,
String sql,
Object... args) |
void |
OSystemDatabase.executeInDBScope(OCallable<Void,ODatabase> callback,
String serverUser) |
| Modifier and Type | Method and Description |
|---|---|
OCallable<Void,ODistributedRequestId> |
OAsynchDistributedOperation.getAfterSendCallback() |
OCallable<Object,OPair<ODistributedRequestId,Object>> |
OAsynchDistributedOperation.getCallback() |
| Modifier and Type | Method and Description |
|---|---|
ODistributedResponse |
ODistributedDatabase.send2Nodes(ODistributedRequest iRequest,
Collection<String> iClusterNames,
Collection<String> iNodes,
ODistributedRequest.EXECUTION_MODE iExecutionMode,
Object localResult,
OCallable<Void,ODistributedRequestId> iAfterSentCallback) |
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)
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) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
ODistributedTransactionManager.executeAsyncTx(Set<String> nodes,
OTxTaskResult localResult,
Set<String> involvedClusters,
OAbstractReplicatedTask txTask,
long messageId,
String localNodeName,
OCallable<Void,ODistributedRequestId> afterSendCallback) |
<T> T |
ODistributedAbstractPlugin.executeInDistributedDatabaseLock(String databaseName,
OCallable<T,ODistributedConfiguration> iCallback)
Executes an operation protected by a distributed lock (one per database).
|
ODistributedResponse |
ODistributedDatabaseImpl.send2Nodes(ODistributedRequest iRequest,
Collection<String> iClusterNames,
Collection<String> iNodes,
ODistributedRequest.EXECUTION_MODE iExecutionMode,
Object localResult,
OCallable<Void,ODistributedRequestId> iAfterSentCallback) |
ODistributedResponse |
ODistributedAbstractPlugin.sendRequest(String iDatabaseName,
Collection<String> iClusterNames,
Collection<String> iTargetNodes,
ORemoteTask iTask,
long reqId,
ODistributedRequest.EXECUTION_MODE iExecutionMode,
Object localResult,
OCallable<Void,ODistributedRequestId> iAfterSentCallback) |
| 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 |
|---|---|
<RET> RET |
OrientBaseGraph.executeOutsideTx(OCallable<RET,OrientBaseGraph> iCallable,
String... iOperationStrings) |
Copyright © 2009–2016 Orient Technologies. All rights reserved.