Uses of Class
com.gigaspaces.internal.remoting.routing.clustered.RemoteOperationsExecutorProxy
Packages that use RemoteOperationsExecutorProxy
Package
Description
-
Uses of RemoteOperationsExecutorProxy in com.gigaspaces.internal.client.spaceproxy.router
Methods in com.gigaspaces.internal.client.spaceproxy.router with parameters of type RemoteOperationsExecutorProxyModifier and TypeMethodDescriptionprotected voidSpaceClusterRemoteOperationRouter.afterOperationExecution(RemoteOperationRequest<?> request, RemoteOperationsExecutorProxy proxy, ClusterRemoteOperationRouter.ExecutionStatus status) protected booleanSpaceClusterRemoteOperationRouter.beforeOperationExecution(RemoteOperationRequest<?> request, RemoteOperationsExecutorProxy proxy) -
Uses of RemoteOperationsExecutorProxy in com.gigaspaces.internal.remoting
Methods in com.gigaspaces.internal.remoting with parameters of type RemoteOperationsExecutorProxyModifier and TypeMethodDescriptionvoidRemoteOperationFutureListener.onOperationCompletion(RemoteOperationRequest<T> request, RemoteOperationsExecutorProxy sourceProxy) -
Uses of RemoteOperationsExecutorProxy in com.gigaspaces.internal.remoting.routing
Methods in com.gigaspaces.internal.remoting.routing that return RemoteOperationsExecutorProxyModifier and TypeMethodDescriptionRemoteOperationRouter.getAnyActiveMember()RemoteOperationRouter.getAnyAvailableCachedMember()RemoteOperationRouter.getAnyAvailableMember()AbstractRemoteOperationRouter.getCachedMember()RemoteOperationRouter.getCachedMember()Methods in com.gigaspaces.internal.remoting.routing with parameters of type RemoteOperationsExecutorProxyModifier and TypeMethodDescriptionprotected 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) Method parameters in com.gigaspaces.internal.remoting.routing with type arguments of type RemoteOperationsExecutorProxyModifier and TypeMethodDescriptionvoidRemoteOperationRouter.getAllAvailableMembers(List<RemoteOperationsExecutorProxy> availableMembers) -
Uses of RemoteOperationsExecutorProxy in com.gigaspaces.internal.remoting.routing.clustered
Methods in com.gigaspaces.internal.remoting.routing.clustered that return RemoteOperationsExecutorProxyModifier and TypeMethodDescriptionRemoteOperationsExecutorsCluster.find(String member, LookupType lookupType) SpaceProxyLoadBalancingStrategy.findActiveMember(RemoteOperationRequest<?> request, long initialFailureTime, RemoteOperationsExecutorProxy oldCandidate) SpaceProxyLoadBalancingStrategy.findActiveMemberUninterruptibly(RemoteOperationRequest<?> request, long initialFailureTime, RemoteOperationsExecutorProxy proxy) SpaceProxyLoadBalancingStrategy.findAnyAvailableMember(boolean activeOnly) ClusterRemoteOperationRouter.getAnyActiveMember()ClusterRemoteOperationRouter.getAnyAvailableCachedMember()ClusterRemoteOperationRouter.getAnyAvailableMember()RemoteOperationsExecutorsCluster.getAvailableMember(boolean activeOnly, long timeout) ClusterRemoteOperationRouter.getCachedMember()LazyLoadBalancingStrategy.getCandidate(RemoteOperationRequest<?> request) RoundRobinLoadBalancingStrategy.getCandidate(RemoteOperationRequest<?> request) abstract RemoteOperationsExecutorProxySpaceProxyLoadBalancingStrategy.getCandidate(RemoteOperationRequest<?> request) RemoteOperationsExecutorsCluster.MemberLocatorTask.getProxy()RemoteOperationsExecutorProxyLocator.locateMember(String memberName, LookupType lookupType) RemoteSpaceProxyLocator.locateMember(String memberName, LookupType lookupType) RemoteSpaceProxyLocator.locateMember(String memberName, String spaceUuid, LookupType lookupType) Methods in com.gigaspaces.internal.remoting.routing.clustered with parameters of type RemoteOperationsExecutorProxyModifier and TypeMethodDescriptionvoidRemoteOperationsExecutorsCluster.add(RemoteOperationsExecutorProxy proxy) protected voidClusterRemoteOperationRouter.afterOperationExecution(RemoteOperationRequest<?> request, RemoteOperationsExecutorProxy proxy, ClusterRemoteOperationRouter.ExecutionStatus status) protected booleanClusterRemoteOperationRouter.beforeOperationExecution(RemoteOperationRequest<?> request, RemoteOperationsExecutorProxy proxy) voidRemoteOperationsExecutorsCluster.disconnect(RemoteOperationsExecutorProxy proxy) SpaceProxyLoadBalancingStrategy.findActiveMember(RemoteOperationRequest<?> request, long initialFailureTime, RemoteOperationsExecutorProxy oldCandidate) SpaceProxyLoadBalancingStrategy.findActiveMemberUninterruptibly(RemoteOperationRequest<?> request, long initialFailureTime, RemoteOperationsExecutorProxy proxy) static booleanRemoteOperationsExecutorProxy.isAvailable(RemoteOperationsExecutorProxy proxy, boolean activeOnly) voidRoundRobinLoadBalancingStrategy.onMemberConnected(RemoteOperationsExecutorProxy connectedMember) voidSpaceProxyLoadBalancingStrategy.onMemberConnected(RemoteOperationsExecutorProxy connectedMember) protected voidLazyLoadBalancingStrategy.updateActiveProxy(RemoteOperationsExecutorProxy newActiveProxy) protected voidRoundRobinLoadBalancingStrategy.updateActiveProxy(RemoteOperationsExecutorProxy newActiveProxy) protected abstract voidSpaceProxyLoadBalancingStrategy.updateActiveProxy(RemoteOperationsExecutorProxy newActiveProxy) This method MUST be called from within a synchronized block.Method parameters in com.gigaspaces.internal.remoting.routing.clustered with type arguments of type RemoteOperationsExecutorProxyModifier and TypeMethodDescriptionvoidClusterRemoteOperationRouter.getAllAvailableMembers(List<RemoteOperationsExecutorProxy> availableMembers) voidRemoteOperationsExecutorsCluster.getAllAvailableMembers(List<RemoteOperationsExecutorProxy> availableMembers) Constructors in com.gigaspaces.internal.remoting.routing.clustered with parameters of type RemoteOperationsExecutorProxyModifierConstructorDescriptionLazyLoadBalancingStrategy(RemoteOperationsExecutorsCluster cluster, RemoteOperationsExecutorProxy defaultMember) MemberLocatorTask(String name, RemoteOperationsExecutorProxy proxy, boolean activeOnly, boolean timeBased) RemoteOperationsExecutorsCluster(SpaceProxyImpl spaceProxy, String name, SpaceClusterInfo clusterInfo, int partitionId, Collection<String> members, RemoteOperationsExecutorsClusterConfig config, IAsyncHandlerProvider asyncHandlerProvider, RemoteOperationsExecutorProxyLocator proxyLocator, RemoteOperationsExecutorProxy defaultMember) RemoteOperationsExecutorsCluster(String name, SpaceClusterInfo clusterInfo, int partitionId, Collection<String> members, RemoteOperationsExecutorsClusterConfig config, IAsyncHandlerProvider asyncHandlerProvider, RemoteOperationsExecutorProxyLocator proxyLocator, RemoteOperationsExecutorProxy defaultMember) -
Uses of RemoteOperationsExecutorProxy in com.gigaspaces.internal.remoting.routing.embedded
Fields in com.gigaspaces.internal.remoting.routing.embedded declared as RemoteOperationsExecutorProxyModifier and TypeFieldDescriptionprotected final RemoteOperationsExecutorProxyEmbeddedRemoteOperationRouter._memberProxyMethods in com.gigaspaces.internal.remoting.routing.embedded that return RemoteOperationsExecutorProxyModifier and TypeMethodDescriptionEmbeddedRemoteOperationRouter.getAnyActiveMember()EmbeddedRemoteOperationRouter.getAnyAvailableCachedMember()EmbeddedRemoteOperationRouter.getAnyAvailableMember()EmbeddedRemoteOperationRouter.getCachedMember()Method parameters in com.gigaspaces.internal.remoting.routing.embedded with type arguments of type RemoteOperationsExecutorProxyModifier and TypeMethodDescriptionvoidEmbeddedRemoteOperationRouter.getAllAvailableMembers(List<RemoteOperationsExecutorProxy> availableMembers) Constructors in com.gigaspaces.internal.remoting.routing.embedded with parameters of type RemoteOperationsExecutorProxyModifierConstructorDescriptionEmbeddedRemoteOperationRouter(RemoteOperationsExecutorProxy memberProxy, int partitionId, String name, Executor asyncExecutor) -
Uses of RemoteOperationsExecutorProxy in com.gigaspaces.internal.remoting.routing.partitioned
Methods in com.gigaspaces.internal.remoting.routing.partitioned that return RemoteOperationsExecutorProxyModifier and TypeMethodDescriptionPartitionedClusterRemoteOperationRouter.getAnyActiveMember()PartitionedClusterRemoteOperationRouter.getAnyAvailableCachedMember()PartitionedClusterRemoteOperationRouter.getAnyAvailableMember()Method parameters in com.gigaspaces.internal.remoting.routing.partitioned with type arguments of type RemoteOperationsExecutorProxyModifier and TypeMethodDescriptionvoidPartitionedClusterRemoteOperationRouter.getAllAvailableMembers(List<RemoteOperationsExecutorProxy> availableMembers)