Package com.gigaspaces.internal.remoting.routing.clustered

Class RemoteOperationsExecutorsCluster

java.lang.Object

com.gigaspaces.internal.remoting.routing.clustered.RemoteOperationsExecutorsCluster

public class RemoteOperationsExecutorsCluster
extends Object

Since:

9.0.0

Author:

Niv Ingberg

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	RemoteOperationsExecutorsCluster.MemberLocatorTask

Constructor Summary

Constructors

Constructor	Description
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)

Method Summary

Modifier and Type	Method	Description
void	add(RemoteOperationsExecutorProxy proxy)
void	close()
void	disconnect(RemoteOperationsExecutorProxy proxy)
RemoteOperationsExecutorProxy	find(String member, LookupType lookupType)
String	generateTimeoutErrorMessage(long initialFailureTime, RemoteOperationRequest<?> request)
void	getAllAvailableMembers(List<RemoteOperationsExecutorProxy> availableMembers)
RemoteOperationsExecutorProxy	getAvailableMember(boolean activeOnly, long timeout)
SpaceClusterInfo	getClusterInfo()
RemoteOperationsExecutorsClusterConfig	getConfig()
String	getElapsedTime(long initialFailureTime)
SpaceProxyLoadBalancingStrategy	getLoadBalancer()
org.slf4j.Logger	getLogger()
Collection<String>	getMembersNames()
String	getName()
String	getPartitionDesc()
int	getPartitionId()
long	getRemainingTime(RemoteOperationRequest<?> request, long initialFailureTime)
void	refreshConnectedMembers()
void	refreshDisconnectedMembers()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

RemoteOperationsExecutorsCluster

public RemoteOperationsExecutorsCluster(SpaceProxyImpl spaceProxy,
 String name,
 SpaceClusterInfo clusterInfo,
 int partitionId,
 Collection<String> members,
 RemoteOperationsExecutorsClusterConfig config,
 IAsyncHandlerProvider asyncHandlerProvider,
 RemoteOperationsExecutorProxyLocator proxyLocator,
 RemoteOperationsExecutorProxy defaultMember)

RemoteOperationsExecutorsCluster

public RemoteOperationsExecutorsCluster(String name,
 SpaceClusterInfo clusterInfo,
 int partitionId,
 Collection<String> members,
 RemoteOperationsExecutorsClusterConfig config,
 IAsyncHandlerProvider asyncHandlerProvider,
 RemoteOperationsExecutorProxyLocator proxyLocator,
 RemoteOperationsExecutorProxy defaultMember)

Method Details

getName

public String getName()

getLogger

public org.slf4j.Logger getLogger()

getClusterInfo

public SpaceClusterInfo getClusterInfo()

getPartitionId

public int getPartitionId()

getPartitionDesc

public String getPartitionDesc()

getMembersNames

public Collection<String> getMembersNames()

getLoadBalancer

public SpaceProxyLoadBalancingStrategy getLoadBalancer()

getConfig

public RemoteOperationsExecutorsClusterConfig getConfig()

getAvailableMember

public RemoteOperationsExecutorProxy getAvailableMember(boolean activeOnly,
 long timeout)
                                                 throws InterruptedException,
RemoteOperationRouterException

Throws:

InterruptedException

RemoteOperationRouterException

getAllAvailableMembers

public void getAllAvailableMembers(List<RemoteOperationsExecutorProxy> availableMembers)

refreshConnectedMembers

public void refreshConnectedMembers()

refreshDisconnectedMembers

public void refreshDisconnectedMembers()

find

public RemoteOperationsExecutorProxy find(String member,
 LookupType lookupType)

add

public void add(RemoteOperationsExecutorProxy proxy)

disconnect

public void disconnect(RemoteOperationsExecutorProxy proxy)

close

public void close()

getRemainingTime

public long getRemainingTime(RemoteOperationRequest<?> request,
 long initialFailureTime)

generateTimeoutErrorMessage

public String generateTimeoutErrorMessage(long initialFailureTime,
 RemoteOperationRequest<?> request)

getElapsedTime

public String getElapsedTime(long initialFailureTime)