com.gigaspaces.cluster.loadbalance
Class DummyLoadBalanceImpl

java.lang.Object
  com.gigaspaces.cluster.loadbalance.DummyLoadBalanceImpl

All Implemented Interfaces:

com.j_spaces.core.cluster.ILoadBalance, Serializable

public class DummyLoadBalanceImpl
extends Object
implements com.j_spaces.core.cluster.ILoadBalance, Serializable

Dummy Load Balance used by the JSpace cluster proxy as an indicator for one machine cluster (single proxy)

Since:

6.1

See Also:

Serialized Form

Constructor Summary

DummyLoadBalanceImpl()

Method Summary

void	clean(String className)
com.gigaspaces.cluster.loadbalance.LoadBalanceBroadcastInfo	getLoadBalanceBroadcastInfo()
com.gigaspaces.cluster.loadbalance.LoadBalanceBroadcastInfo	getLoadBalanceBroadcastInfo(com.gigaspaces.cluster.loadbalance.LoadBalanceOperation operationType)
com.gigaspaces.cluster.loadbalance.GroupMember	getMember(String member)
com.j_spaces.core.cluster.MultiTargetsScatterInfo	getMultiObjectsScatterInfo(com.gigaspaces.cluster.loadbalance.LoadBalanceOperation operation, Object subjects, boolean disableParallelScattering, int serializationType)
int	getNumberOfPartitions(com.gigaspaces.cluster.loadbalance.LoadBalanceOperation operationType)
int	getPartitionForKey(Object key, com.gigaspaces.cluster.loadbalance.LoadBalanceOperation operationType)
int	getPartitionOfMember(String memberName, com.gigaspaces.cluster.loadbalance.LoadBalanceOperation operationType)
void	init(ClusterPolicy policy, IJSpace proxy)
boolean	isFixedOwnershipLBPolicy(com.gigaspaces.cluster.loadbalance.LoadBalanceOperation operationType)
com.gigaspaces.cluster.loadbalance.GroupMember	selectMemberForOperation(com.gigaspaces.cluster.loadbalance.LoadBalanceOperation operation, Object entryObject, String underXtnMemberName, com.j_spaces.core.cluster.ScatterTarget scatterTarget, String nullHashIndexIndicator)
com.gigaspaces.cluster.loadbalance.LoadBalanceBroadcastInfo	setLoadBalanceBroadcastCondition(LoadBalancingPolicy.BroadcastCondition broadcastCondition, com.gigaspaces.cluster.loadbalance.LoadBalanceOperation operationType)
void	setLoadBalanceBroadcastInfo(com.gigaspaces.cluster.loadbalance.LoadBalanceBroadcastInfo _loadBalanceBroadcastInfo)
void	setMemberAvailability(String memberName, boolean isAlive, boolean isStandBySpace)

Methods inherited from class java.lang.Object

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

Constructor Detail

DummyLoadBalanceImpl

public DummyLoadBalanceImpl()

Method Detail

init

public void init(ClusterPolicy policy,
                 IJSpace proxy)
          throws com.j_spaces.core.cluster.ClusterException

Specified by:

init in interface com.j_spaces.core.cluster.ILoadBalance

Throws:

com.j_spaces.core.cluster.ClusterException

selectMemberForOperation

public com.gigaspaces.cluster.loadbalance.GroupMember selectMemberForOperation(com.gigaspaces.cluster.loadbalance.LoadBalanceOperation operation,
                                                                               Object entryObject,
                                                                               String underXtnMemberName,
                                                                               com.j_spaces.core.cluster.ScatterTarget scatterTarget,
                                                                               String nullHashIndexIndicator)

Specified by:

selectMemberForOperation in interface com.j_spaces.core.cluster.ILoadBalance

isFixedOwnershipLBPolicy

public boolean isFixedOwnershipLBPolicy(com.gigaspaces.cluster.loadbalance.LoadBalanceOperation operationType)

Specified by:

isFixedOwnershipLBPolicy in interface com.j_spaces.core.cluster.ILoadBalance

getMultiObjectsScatterInfo

public com.j_spaces.core.cluster.MultiTargetsScatterInfo getMultiObjectsScatterInfo(com.gigaspaces.cluster.loadbalance.LoadBalanceOperation operation,
                                                                                    Object subjects,
                                                                                    boolean disableParallelScattering,
                                                                                    int serializationType)

Specified by:

getMultiObjectsScatterInfo in interface com.j_spaces.core.cluster.ILoadBalance

getLoadBalanceBroadcastInfo

public com.gigaspaces.cluster.loadbalance.LoadBalanceBroadcastInfo getLoadBalanceBroadcastInfo(com.gigaspaces.cluster.loadbalance.LoadBalanceOperation operationType)

Specified by:

getLoadBalanceBroadcastInfo in interface com.j_spaces.core.cluster.ILoadBalance

setLoadBalanceBroadcastCondition

public com.gigaspaces.cluster.loadbalance.LoadBalanceBroadcastInfo setLoadBalanceBroadcastCondition(LoadBalancingPolicy.BroadcastCondition broadcastCondition,
                                                                                                    com.gigaspaces.cluster.loadbalance.LoadBalanceOperation operationType)

Specified by:

setLoadBalanceBroadcastCondition in interface com.j_spaces.core.cluster.ILoadBalance

getPartitionOfMember

public int getPartitionOfMember(String memberName,
                                com.gigaspaces.cluster.loadbalance.LoadBalanceOperation operationType)

Specified by:

getPartitionOfMember in interface com.j_spaces.core.cluster.ILoadBalance

getPartitionForKey

public int getPartitionForKey(Object key,
                              com.gigaspaces.cluster.loadbalance.LoadBalanceOperation operationType)

Specified by:

getPartitionForKey in interface com.j_spaces.core.cluster.ILoadBalance

getNumberOfPartitions

public int getNumberOfPartitions(com.gigaspaces.cluster.loadbalance.LoadBalanceOperation operationType)

Specified by:

getNumberOfPartitions in interface com.j_spaces.core.cluster.ILoadBalance

clean

public void clean(String className)

Specified by:

clean in interface com.j_spaces.core.cluster.ILoadBalance

setMemberAvailability

public void setMemberAvailability(String memberName,
                                  boolean isAlive,
                                  boolean isStandBySpace)

getLoadBalanceBroadcastInfo

public com.gigaspaces.cluster.loadbalance.LoadBalanceBroadcastInfo getLoadBalanceBroadcastInfo()

setLoadBalanceBroadcastInfo

public void setLoadBalanceBroadcastInfo(com.gigaspaces.cluster.loadbalance.LoadBalanceBroadcastInfo _loadBalanceBroadcastInfo)

getMember

public com.gigaspaces.cluster.loadbalance.GroupMember getMember(String member)

Specified by:

getMember in interface com.j_spaces.core.cluster.ILoadBalance