Package com.orientechnologies.orient.server.distributed.task

Interface ORemoteTask

All Known Implementing Classes:

NodeOperationTask, OAbstractRemoteTask, OCloseQueryTask, OCopyDatabaseChunkTask, ODropDatabaseTask, OEnterpriseStatsTask, OFetchQueryPageTask, OGossipTask, ORequestDatabaseConfigurationTask, ORestartServerTask, ORunQueryExecutionPlanTask, OSQLCommandTaskFirstPhase, OSQLCommandTaskSecondPhase, OStopServerTask, OSyncClusterTask, OSyncDatabaseNewDeltaTask, OSyncDatabaseTask, OTransactionPhase1Task, OTransactionPhase2Task, OUnreachableServerLocalTask, OUpdateDatabaseConfigurationTask, OUpdateDatabaseSequenceStatusTask

public interface ORemoteTask

Remote Task interface.

Author:

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

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static enum	ORemoteTask.RESULT_STRATEGY

Method Summary

Modifier and Type	Method	Description
Object	execute(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database)
default void	finished(ODistributedDatabase distributedDatabase)
void	fromStream(DataInput in, ORemoteTaskFactory factory)
long	getDistributedTimeout()
int	getFactoryId()
String	getName()
String	getNodeSource()
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 Details

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

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()

toStream

void toStream(DataOutput out)
       throws IOException

Throws:

IOException

fromStream

void fromStream(DataInput in,
 ORemoteTaskFactory factory)
         throws IOException

Throws:

IOException

finished

default void finished(ODistributedDatabase distributedDatabase)