Modifier and Type | Method and Description |
---|---|
protected void |
SpaceClusterRemoteOperationRouter.afterOperationExecution(RemoteOperationRequest<?> request,
RemoteOperationsExecutorProxy proxy,
ClusterRemoteOperationRouter.ExecutionStatus status) |
protected boolean |
SpaceClusterRemoteOperationRouter.beforeOperationExecution(RemoteOperationRequest<?> request,
RemoteOperationsExecutorProxy proxy) |
Modifier and Type | Method and Description |
---|---|
void |
RemoteOperationFutureListener.onOperationCompletion(RemoteOperationRequest<T> request,
RemoteOperationsExecutorProxy sourceProxy) |
Modifier and Type | Method and Description |
---|---|
RemoteOperationsExecutorProxy |
RemoteOperationRouter.getAnyActiveMember() |
RemoteOperationsExecutorProxy |
RemoteOperationRouter.getAnyAvailableMember() |
RemoteOperationsExecutorProxy |
RemoteOperationRouter.getCachedMember() |
RemoteOperationsExecutorProxy |
AbstractRemoteOperationRouter.getCachedMember() |
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractRemoteOperationRouter.logAfterExecute(RemoteOperationsExecutorProxy proxy,
RemoteOperationRequest<?> request,
RemoteOperationResult result,
boolean oneway) |
protected void |
AbstractRemoteOperationRouter.logAfterExecuteAsync(RemoteOperationsExecutorProxy proxy,
RemoteOperationRequest<?> request,
RemoteOperationResult result) |
protected void |
AbstractRemoteOperationRouter.logAsyncExecutionFailure(RemoteOperationsExecutorProxy proxy,
RemoteOperationRequest<?> request,
Exception exception) |
protected void |
AbstractRemoteOperationRouter.logBeforeExecute(RemoteOperationsExecutorProxy proxy,
RemoteOperationRequest<?> request,
boolean oneway) |
protected void |
AbstractRemoteOperationRouter.logBeforeExecuteAsync(RemoteOperationsExecutorProxy proxy,
RemoteOperationRequest<?> request) |
protected void |
AbstractRemoteOperationRouter.logExecutionFailure(RemoteOperationsExecutorProxy proxy,
RemoteOperationRequest<?> request,
Exception exception,
boolean oneway) |
protected void |
AbstractRemoteOperationRouter.logInterruptedAsyncExecution(RemoteOperationsExecutorProxy proxy,
RemoteOperationRequest<?> request,
Exception exception) |
protected void |
AbstractRemoteOperationRouter.logInterruptedExecution(RemoteOperationsExecutorProxy proxy,
RemoteOperationRequest<?> request,
Exception exception,
boolean oneway) |
protected void |
AbstractRemoteOperationRouter.logUnexpectedAsyncExecution(RemoteOperationsExecutorProxy proxy,
RemoteOperationRequest<?> request,
Exception exception) |
Modifier and Type | Method and Description |
---|---|
void |
RemoteOperationRouter.getAllAvailableMembers(List<RemoteOperationsExecutorProxy> availableMembers) |
Modifier and Type | Method and Description |
---|---|
void |
RemoteOperationsExecutorsCluster.add(RemoteOperationsExecutorProxy proxy) |
protected void |
ClusterRemoteOperationRouter.afterOperationExecution(RemoteOperationRequest<?> request,
RemoteOperationsExecutorProxy proxy,
ClusterRemoteOperationRouter.ExecutionStatus status) |
protected boolean |
ClusterRemoteOperationRouter.beforeOperationExecution(RemoteOperationRequest<?> request,
RemoteOperationsExecutorProxy proxy) |
void |
RemoteOperationsExecutorsCluster.disconnect(RemoteOperationsExecutorProxy proxy) |
RemoteOperationsExecutorProxy |
SpaceProxyLoadBalancingStrategy.findActiveMember(RemoteOperationRequest<?> request,
long initialFailureTime,
RemoteOperationsExecutorProxy oldCandidate) |
RemoteOperationsExecutorProxy |
SpaceProxyLoadBalancingStrategy.findActiveMemberUninterruptibly(RemoteOperationRequest<?> request,
long initialFailureTime,
RemoteOperationsExecutorProxy proxy) |
static boolean |
RemoteOperationsExecutorProxy.isAvailable(RemoteOperationsExecutorProxy proxy,
boolean activeOnly) |
void |
SpaceProxyLoadBalancingStrategy.onMemberConnected(RemoteOperationsExecutorProxy connectedMember) |
void |
RoundRobinLoadBalancingStrategy.onMemberConnected(RemoteOperationsExecutorProxy connectedMember) |
protected abstract void |
SpaceProxyLoadBalancingStrategy.updateActiveProxy(RemoteOperationsExecutorProxy newActiveProxy)
This method MUST be called from within a synchronized block.
|
protected void |
LazyLoadBalancingStrategy.updateActiveProxy(RemoteOperationsExecutorProxy newActiveProxy) |
protected void |
RoundRobinLoadBalancingStrategy.updateActiveProxy(RemoteOperationsExecutorProxy newActiveProxy) |
Modifier and Type | Method and Description |
---|---|
void |
RemoteOperationsExecutorsCluster.getAllAvailableMembers(List<RemoteOperationsExecutorProxy> availableMembers) |
void |
ClusterRemoteOperationRouter.getAllAvailableMembers(List<RemoteOperationsExecutorProxy> availableMembers) |
Modifier and Type | Field and Description |
---|---|
protected RemoteOperationsExecutorProxy |
EmbeddedRemoteOperationRouter._memberProxy |
Modifier and Type | Method and Description |
---|---|
RemoteOperationsExecutorProxy |
EmbeddedRemoteOperationRouter.getAnyActiveMember() |
RemoteOperationsExecutorProxy |
EmbeddedRemoteOperationRouter.getAnyAvailableMember() |
RemoteOperationsExecutorProxy |
EmbeddedRemoteOperationRouter.getCachedMember() |
Modifier and Type | Method and Description |
---|---|
void |
EmbeddedRemoteOperationRouter.getAllAvailableMembers(List<RemoteOperationsExecutorProxy> availableMembers) |
Constructor and Description |
---|
EmbeddedRemoteOperationRouter(RemoteOperationsExecutorProxy memberProxy,
int partitionId,
String name,
Executor asyncExecutor) |
Modifier and Type | Method and Description |
---|---|
RemoteOperationsExecutorProxy |
PartitionedClusterRemoteOperationRouter.getAnyActiveMember() |
RemoteOperationsExecutorProxy |
PartitionedClusterRemoteOperationRouter.getAnyAvailableCachedMember() |
RemoteOperationsExecutorProxy |
PartitionedClusterRemoteOperationRouter.getAnyAvailableMember() |
Modifier and Type | Method and Description |
---|---|
void |
PartitionedClusterRemoteOperationRouter.getAllAvailableMembers(List<RemoteOperationsExecutorProxy> availableMembers) |
Copyright © GigaSpaces.