com.orientechnologies.orient.server.distributed.task

Interface ORemoteTask

All Known Implementing Classes:

NodeOperationTask, OAbstract2pcTask, OAbstractCommandTask, OAbstractReadRecordTask, OAbstractRecordReplicatedTask, OAbstractRemoteTask, OAbstractReplicatedTask, OAbstractSyncDatabaseTask, OCloseQueryTask, OClusterRepairInfoTask, OCompleted2pcTask, OCompleted2pcTaskV1, OCopyDatabaseChunkTask, OCreateRecordTask, ODeleteRecordTask, ODistributedLockTask, ODropDatabaseTask, OEnterpriseStatsTask, OFetchQueryPageTask, OFixCreateRecordTask, OFixUpdateRecordTask, OGossipTask, OReadRecordIfNotLatestTask, OReadRecordTask, ORepairClusterTask, ORepairRecordsTask, ORequestDatabaseConfigurationTask, ORestartServerTask, OResurrectRecordTask, ORunQueryExecutionPlanTask, OScriptTask, OSQLCommandTask, OStartReplicationTask, OStopServerTask, OSyncClusterTask, OSyncDatabaseDeltaTask, OSyncDatabaseTask, OSynchronizedTaskWrapper, OTransactionPhase1Task, OTransactionPhase2Task, OTxTask, OUnreachableServerLocalTask, OUpdateDatabaseConfigurationTask, OUpdateDatabaseStatusTask, OUpdateRecordTask, OWaitForTask, OWaitPartitionsReadyTask

public interface ORemoteTask

Remote Task interface.

Author:

Luca Garulli (l.garulli--(at)--orientdb.com)

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	ORemoteTask.RESULT_STRATEGY

Method Summary

Modifier and Type	Method and Description
void	checkIsValid(ODistributedServerManager dManager) Checks the request is still valid.
Object	execute(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database)
default void	finished()
void	fromStream(DataInput in, ORemoteTaskFactory factory)
long	getDistributedTimeout()
int	getFactoryId()
String	getName()
String	getNodeSource()
int[]	getPartitionKey()
OCommandDistributedReplicateRequest.QUORUM_TYPE	getQuorumType()
ORemoteTask.RESULT_STRATEGY	getResultStrategy()
long	getSynchronousTimeout(int iSynchNodes)
long	getTotalTimeout(int iTotalNodes)
boolean	hasResponse()
boolean	isIdempotent()
boolean	isNodeOnlineRequired()
boolean	isUsingDatabase()
default void	received(ODistributedRequest request, ODistributedDatabase distributedDatabase)
void	setNodeSource(String nodeSource)
void	toStream(DataOutput out)

Method Detail

hasResponse

boolean hasResponse()

received

default void received(ODistributedRequest request,
                      ODistributedDatabase distributedDatabase)

getName

String getName()

getQuorumType

OCommandDistributedReplicateRequest.QUORUM_TYPE getQuorumType()

execute

Object execute(ODistributedRequestId requestId,
               OServer iServer,
               ODistributedServerManager iManager,
               ODatabaseDocumentInternal database)
        throws Exception

Throws:

Exception

getPartitionKey

int[] getPartitionKey()

getDistributedTimeout

long getDistributedTimeout()

getSynchronousTimeout

long getSynchronousTimeout(int iSynchNodes)

getTotalTimeout

long getTotalTimeout(int iTotalNodes)

getResultStrategy

ORemoteTask.RESULT_STRATEGY getResultStrategy()

getNodeSource

String getNodeSource()

setNodeSource

void setNodeSource(String nodeSource)

isIdempotent

boolean isIdempotent()

isNodeOnlineRequired

boolean isNodeOnlineRequired()

isUsingDatabase

boolean isUsingDatabase()

getFactoryId

int getFactoryId()

checkIsValid

void checkIsValid(ODistributedServerManager dManager)

Checks the request is still valid.

toStream

void toStream(DataOutput out)
       throws IOException

Throws:

IOException

fromStream

void fromStream(DataInput in,
                ORemoteTaskFactory factory)
         throws IOException

Throws:

IOException

finished

default void finished()