Uses of Interface
com.gigaspaces.internal.remoting.RemoteOperationRequest
Packages that use RemoteOperationRequest
Package
Description
-
Uses of RemoteOperationRequest in com.gigaspaces.internal.client.spaceproxy.operations
Classes in com.gigaspaces.internal.client.spaceproxy.operations that implement RemoteOperationRequestModifier and TypeClassDescriptionclassclassclassclassclassclassclassclassclassclassclassclassclassclassclassclassclassclassclassclassSpaceOperationRequest<TResult extends SpaceOperationResult>classSpaceScatterGatherOperationRequest<TResult extends SpaceOperationResult>classclassclassclassclassclassMethods in com.gigaspaces.internal.client.spaceproxy.operations that return RemoteOperationRequestModifier and TypeMethodDescriptionAggregateEntriesSpaceOperationRequest.createCopy(int targetPartitionId) ChangeEntriesSpaceOperationRequest.createCopy(int targetPartitionId) CountClearEntriesSpaceOperationRequest.createCopy(int targetPartitionId) ReadTakeEntriesSpaceOperationRequest.createCopy(int targetPartitionId) ReadTakeEntriesUidsSpaceOperationRequest.createCopy(int targetPartitionId) ReadTakeEntrySpaceOperationRequest.createCopy(int targetPartitionId) RegisterEntriesListenerSpaceOperationRequest.createCopy(int targetPartitionId) SpaceOperationRequest.createCopy(int targetPartitionId) -
Uses of RemoteOperationRequest in com.gigaspaces.internal.client.spaceproxy.router
Methods in com.gigaspaces.internal.client.spaceproxy.router with parameters of type RemoteOperationRequestModifier and TypeMethodDescriptionprotected voidSpaceClusterRemoteOperationRouter.afterOperationExecution(RemoteOperationRequest<?> request, RemoteOperationsExecutorProxy proxy, ClusterRemoteOperationRouter.ExecutionStatus status) protected voidSpaceEmbeddedRemoteOperationRouter.afterOperationExecution(RemoteOperationRequest<?> request) protected booleanSpaceClusterRemoteOperationRouter.beforeOperationExecution(RemoteOperationRequest<?> request, RemoteOperationsExecutorProxy proxy) protected booleanSpaceEmbeddedRemoteOperationRouter.beforeOperationExecution(RemoteOperationRequest<?> request) <T extends SpaceOperationResult>
voidSpaceProxyRouter.execute(RemoteOperationRequest<T> request) <T extends SpaceOperationResult>
RemoteOperationFutureListener<T>SpaceProxyRouter.executeAsync(RemoteOperationRequest<T> request, AsyncFutureListener<Object> listener) voidSpaceProxyRouter.executeOneway(RemoteOperationRequest<?> request) -
Uses of RemoteOperationRequest in com.gigaspaces.internal.lrmi.stubs
Methods in com.gigaspaces.internal.lrmi.stubs with parameters of type RemoteOperationRequestModifier and TypeMethodDescription<T extends RemoteOperationResult>
TLRMISpaceImpl.executeOperation(RemoteOperationRequest<T> request) <T extends RemoteOperationResult>
TLRMISpaceImpl.executeOperationAsync(RemoteOperationRequest<T> request) voidLRMISpaceImpl.executeOperationOneway(RemoteOperationRequest<?> request) -
Uses of RemoteOperationRequest in com.gigaspaces.internal.remoting
Methods in com.gigaspaces.internal.remoting that return RemoteOperationRequestMethods in com.gigaspaces.internal.remoting with parameters of type RemoteOperationRequestModifier and TypeMethodDescription<T extends RemoteOperationResult>
TRemoteOperationsExecutor.executeOperation(RemoteOperationRequest<T> request) <T extends RemoteOperationResult>
TRemoteOperationsExecutor.executeOperationAsync(RemoteOperationRequest<T> request) voidRemoteOperationsExecutor.executeOperationOneway(RemoteOperationRequest<?> request) protected ObjectRemoteOperationFutureListener.getResult(RemoteOperationRequest<T> request) voidRemoteOperationFutureListener.onOperationCompletion(RemoteOperationRequest<T> request, RemoteOperationsExecutorProxy sourceProxy) protected booleanRemoteOperationFutureListener.onOperationResultArrival(RemoteOperationRequest<T> request) -
Uses of RemoteOperationRequest in com.gigaspaces.internal.remoting.routing
Methods in com.gigaspaces.internal.remoting.routing with parameters of type RemoteOperationRequestModifier and TypeMethodDescription<T extends RemoteOperationResult>
RemoteOperationFutureListener<T>RemoteOperationRouter.createFutureListener(RemoteOperationRequest<T> request, AsyncFutureListener<Object> listener) <T extends RemoteOperationResult>
voidRemoteOperationRouter.execute(RemoteOperationRequest<T> request) <T extends RemoteOperationResult>
voidRemoteOperationRouter.executeAsync(RemoteOperationRequest<T> request, RemoteOperationFutureListener<T> futureListener) voidRemoteOperationRouter.executeOneway(RemoteOperationRequest<?> request) protected voidAbstractRemoteOperationRouter.logAfterExecute(RemoteOperationsExecutorProxy proxy, RemoteOperationRequest<?> request, RemoteOperationResult result, boolean oneway) protected voidAbstractRemoteOperationRouter.logAfterExecuteAsync(RemoteOperationsExecutorProxy proxy, RemoteOperationRequest<?> request, RemoteOperationResult result) protected voidAbstractRemoteOperationRouter.logAsyncExecutionFailure(RemoteOperationsExecutorProxy proxy, RemoteOperationRequest<?> request, Exception exception) protected voidAbstractRemoteOperationRouter.logBeforeExecute(RemoteOperationsExecutorProxy proxy, RemoteOperationRequest<?> request, boolean oneway) protected voidAbstractRemoteOperationRouter.logBeforeExecuteAsync(RemoteOperationsExecutorProxy proxy, RemoteOperationRequest<?> request) protected voidAbstractRemoteOperationRouter.logExecutionFailure(RemoteOperationsExecutorProxy proxy, RemoteOperationRequest<?> request, Exception exception, boolean oneway) protected voidAbstractRemoteOperationRouter.logInterruptedAsyncExecution(RemoteOperationsExecutorProxy proxy, RemoteOperationRequest<?> request, Exception exception) protected voidAbstractRemoteOperationRouter.logInterruptedExecution(RemoteOperationsExecutorProxy proxy, RemoteOperationRequest<?> request, Exception exception, boolean oneway) protected voidAbstractRemoteOperationRouter.logUnexpectedAsyncExecution(RemoteOperationsExecutorProxy proxy, RemoteOperationRequest<?> request, Exception exception) -
Uses of RemoteOperationRequest in com.gigaspaces.internal.remoting.routing.clustered
Methods in com.gigaspaces.internal.remoting.routing.clustered with parameters of type RemoteOperationRequestModifier and TypeMethodDescriptionprotected voidClusterRemoteOperationRouter.afterOperationExecution(RemoteOperationRequest<?> request, RemoteOperationsExecutorProxy proxy, ClusterRemoteOperationRouter.ExecutionStatus status) protected booleanClusterRemoteOperationRouter.beforeOperationExecution(RemoteOperationRequest<?> request, RemoteOperationsExecutorProxy proxy) <T extends RemoteOperationResult>
RemoteOperationFutureListener<T>ClusterRemoteOperationRouter.createFutureListener(RemoteOperationRequest<T> request, AsyncFutureListener<Object> listener) <T extends RemoteOperationResult>
voidClusterRemoteOperationRouter.execute(RemoteOperationRequest<T> request) <T extends RemoteOperationResult>
TRemoteOperationsExecutorProxy.execute(RemoteOperationRequest<T> request) <T extends RemoteOperationResult>
voidClusterRemoteOperationRouter.executeAsync(RemoteOperationRequest<T> request, RemoteOperationFutureListener<T> futureListener) <T extends RemoteOperationResult>
voidRemoteOperationsExecutorProxy.executeAsync(RemoteOperationRequest<T> request, AsyncFutureListener<T> listener) voidClusterRemoteOperationRouter.executeOneway(RemoteOperationRequest<?> request) voidRemoteOperationsExecutorProxy.executeOneway(RemoteOperationRequest<?> request) SpaceProxyLoadBalancingStrategy.findActiveMember(RemoteOperationRequest<?> request, long initialFailureTime, RemoteOperationsExecutorProxy oldCandidate) SpaceProxyLoadBalancingStrategy.findActiveMemberUninterruptibly(RemoteOperationRequest<?> request, long initialFailureTime, RemoteOperationsExecutorProxy proxy) RemoteOperationsExecutorsCluster.generateTimeoutErrorMessage(long initialFailureTime, RemoteOperationRequest<?> request) LazyLoadBalancingStrategy.getCandidate(RemoteOperationRequest<?> request) RoundRobinLoadBalancingStrategy.getCandidate(RemoteOperationRequest<?> request) abstract RemoteOperationsExecutorProxySpaceProxyLoadBalancingStrategy.getCandidate(RemoteOperationRequest<?> request) longRemoteOperationsExecutorsCluster.getRemainingTime(RemoteOperationRequest<?> request, long initialFailureTime) protected <T extends RemoteOperationResult>
ClusterRemoteOperationRouter.ExecutionStatusClusterRemoteOperationRouter.processResult(RemoteOperationRequest<T> request, T result, Exception executionException) RemoteOperationsExecutorProxy.toLogMessage(RemoteOperationRequest<?> request) Constructors in com.gigaspaces.internal.remoting.routing.clustered with parameters of type RemoteOperationRequestModifierConstructorDescriptionAsyncOperationExecutor(RemoteOperationRequest<T> request, RemoteOperationFutureListener<T> listener) -
Uses of RemoteOperationRequest in com.gigaspaces.internal.remoting.routing.embedded
Methods in com.gigaspaces.internal.remoting.routing.embedded with parameters of type RemoteOperationRequestModifier and TypeMethodDescriptionprotected voidEmbeddedRemoteOperationRouter.afterOperationExecution(RemoteOperationRequest<?> request) protected booleanEmbeddedRemoteOperationRouter.beforeOperationExecution(RemoteOperationRequest<?> request) <T extends RemoteOperationResult>
RemoteOperationFutureListener<T>EmbeddedRemoteOperationRouter.createFutureListener(RemoteOperationRequest<T> request, AsyncFutureListener<Object> listener) <T extends RemoteOperationResult>
voidEmbeddedRemoteOperationRouter.execute(RemoteOperationRequest<T> request) <T extends RemoteOperationResult>
voidEmbeddedRemoteOperationRouter.executeAsync(RemoteOperationRequest<T> request, RemoteOperationFutureListener<T> futureListener) voidEmbeddedRemoteOperationRouter.executeOneway(RemoteOperationRequest<?> request) -
Uses of RemoteOperationRequest in com.gigaspaces.internal.remoting.routing.partitioned
Subinterfaces of RemoteOperationRequest in com.gigaspaces.internal.remoting.routing.partitionedModifier and TypeInterfaceDescriptioninterfaceScatterGatherRemoteOperationRequest<TResult extends RemoteOperationResult>Methods in com.gigaspaces.internal.remoting.routing.partitioned with parameters of type RemoteOperationRequestModifier and TypeMethodDescription<T extends RemoteOperationResult>
BroadcastOperationFutureListener<T>CoordinatorFactory.createAsyncBroadcastListener(RemoteOperationRequest<T> request, AsyncFutureListener<Object> listener, PartitionedClusterRemoteOperationRouter router) protected <T extends RemoteOperationResult>
BroadcastOperationFutureListener<T>CoordinatorFactory.createBroadcastListener(RemoteOperationRequest<T> request, AsyncFutureListener<Object> listener, PartitionedClusterRemoteOperationRouter router, boolean getResultOnCompletion) <T extends RemoteOperationResult>
RemoteOperationFutureListener<T>PartitionedClusterRemoteOperationRouter.createFutureListener(RemoteOperationRequest<T> request, AsyncFutureListener<Object> listener) <T extends RemoteOperationResult>
BroadcastOperationFutureListener<T>CoordinatorFactory.createSyncBroadcastListener(RemoteOperationRequest<T> request, PartitionedClusterRemoteOperationRouter router) <T extends RemoteOperationResult>
voidPartitionedClusterRemoteOperationRouter.execute(RemoteOperationRequest<T> request) <T extends RemoteOperationResult>
voidPartitionedClusterRemoteOperationRouter.executeAsync(RemoteOperationRequest<T> request, RemoteOperationFutureListener<T> futureListener) voidPartitionedClusterRemoteOperationRouter.executeOneway(RemoteOperationRequest<?> request) intPartitionedClusterRemoteOperationRouter.getNextDistributionPartitionId(RemoteOperationRequest<?> request) protected ObjectBroadcastOperationFutureListener.getResult(RemoteOperationRequest<T> request) protected ObjectScatterGatherOperationFutureListener.getResult(RemoteOperationRequest<T> request) protected booleanBroadcastOperationFutureListener.onOperationResultArrival(RemoteOperationRequest<T> partitionRequest) protected booleanScatterGatherOperationFutureListener.onOperationResultArrival(RemoteOperationRequest<T> request) Constructors in com.gigaspaces.internal.remoting.routing.partitioned with parameters of type RemoteOperationRequestModifierConstructorDescriptionBroadcastOperationFutureListener(RemoteOperationRequest<T> mainRequest, AsyncFutureListener<Object> listener, PartitionedClusterRemoteOperationRouter router, boolean getResultOnCompletion) -
Uses of RemoteOperationRequest in com.gigaspaces.internal.server.space
Methods in com.gigaspaces.internal.server.space with parameters of type RemoteOperationRequestModifier and TypeMethodDescription<T extends RemoteOperationResult>
TSpaceImpl.executeOperation(RemoteOperationRequest<T> request) <T extends RemoteOperationResult>
TSpaceImpl.executeOperationAsync(RemoteOperationRequest<T> request) voidSpaceImpl.executeOperationOneway(RemoteOperationRequest<?> request) -
Uses of RemoteOperationRequest in com.gigaspaces.internal.server.space.operations
Classes in com.gigaspaces.internal.server.space.operations with type parameters of type RemoteOperationRequestModifier and TypeClassDescriptionclassAbstractSpaceOperation<TResult extends RemoteOperationResult,TRequest extends RemoteOperationRequest<TResult>> Methods in com.gigaspaces.internal.server.space.operations with parameters of type RemoteOperationRequestModifier and TypeMethodDescription<T extends RemoteOperationResult>
TSpaceOperationsExecutor.executeOperation(RemoteOperationRequest<T> request, SpaceImpl space, boolean oneway)