com.gigaspaces.cluster.loadbalance

Class LoadBalancingPolicy

java.lang.Object

com.gigaspaces.cluster.loadbalance.LoadBalancingPolicy

All Implemented Interfaces:

Externalizable, Serializable

public class LoadBalancingPolicy
extends Object
implements Serializable, Externalizable

Copyright (c) 2010 GigaSpaces Technologies Ltd. All rights reserved The software source code is proprietary and confidential information of GigaSpaces. You may use the software source code solely under the terms and limitations of The license agreement granted to you by GigaSpaces.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	LoadBalancingPolicy.BroadcastCondition
static class	LoadBalancingPolicy.LoadBalancingPolicyDescription

Field Summary

Fields

Modifier and Type	Field and Description
static int	DEFAULT_BROADCAST_THREADPOOL_MAX_SIZE
static int	DEFAULT_BROADCAST_THREADPOOL_MIN_SIZE
List<String>	loadBalanceGroupMembersNames
List<SpaceURL>	loadBalanceGroupMembersURLs
boolean	m_ApplyOwnership
int	m_broadcastThreadpoolMaxSize
int	m_broadcastThreadpoolMinSize
LoadBalancingPolicy.LoadBalancingPolicyDescription	m_DefaultPolicy
boolean	m_DisableParallelScattering
String	m_GroupName
LoadBalancingPolicy.LoadBalancingPolicyDescription	m_NotifyOperationsPolicy
LoadBalancingPolicy.LoadBalancingPolicyDescription	m_ReadOperationsPolicy
LoadBalancingPolicy.LoadBalancingPolicyDescription	m_TakeOperationsPolicy
LoadBalancingPolicy.LoadBalancingPolicyDescription	m_WriteOperationsPolicy

Constructor Summary

Constructors

Constructor and Description
LoadBalancingPolicy()

Method Summary

Modifier and Type	Method and Description
List<SpaceURL>	getRecoverableTargets(String clusterName, String myMemberName, List<String> excludeTargets) Finds all the recovery targets in cluster.
void	readExternal(ObjectInput in)
String	toString()
void	writeExternal(ObjectOutput out)

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_BROADCAST_THREADPOOL_MIN_SIZE

public static final int DEFAULT_BROADCAST_THREADPOOL_MIN_SIZE

See Also:

Constant Field Values

DEFAULT_BROADCAST_THREADPOOL_MAX_SIZE

public static final int DEFAULT_BROADCAST_THREADPOOL_MAX_SIZE

See Also:

Constant Field Values

m_GroupName

public String m_GroupName

loadBalanceGroupMembersNames

public List<String> loadBalanceGroupMembersNames

loadBalanceGroupMembersURLs

public List<SpaceURL> loadBalanceGroupMembersURLs

m_ApplyOwnership

public boolean m_ApplyOwnership

m_DisableParallelScattering

public boolean m_DisableParallelScattering

m_broadcastThreadpoolMinSize

public int m_broadcastThreadpoolMinSize

m_broadcastThreadpoolMaxSize

public int m_broadcastThreadpoolMaxSize

m_WriteOperationsPolicy

public LoadBalancingPolicy.LoadBalancingPolicyDescription m_WriteOperationsPolicy

m_ReadOperationsPolicy

public LoadBalancingPolicy.LoadBalancingPolicyDescription m_ReadOperationsPolicy

m_TakeOperationsPolicy

public LoadBalancingPolicy.LoadBalancingPolicyDescription m_TakeOperationsPolicy

m_NotifyOperationsPolicy

public LoadBalancingPolicy.LoadBalancingPolicyDescription m_NotifyOperationsPolicy

m_DefaultPolicy

public LoadBalancingPolicy.LoadBalancingPolicyDescription m_DefaultPolicy

Constructor Detail

LoadBalancingPolicy

public LoadBalancingPolicy()

Method Detail

writeExternal

public void writeExternal(ObjectOutput out)
                   throws IOException

Specified by:

writeExternal in interface Externalizable

Throws:

IOException

readExternal

public void readExternal(ObjectInput in)
                  throws IOException,
                         ClassNotFoundException

Specified by:

readExternal in interface Externalizable

Throws:

IOException

ClassNotFoundException

getRecoverableTargets

public List<SpaceURL> getRecoverableTargets(String clusterName,
                                            String myMemberName,
                                            List<String> excludeTargets)

Finds all the recovery targets in cluster. If jini URLs are used, the first target will always be multicast url. only if it fails the unicast and rmi URLs will be used.

Parameters:

clusterName - the cluster to recover in.

myMemberName - the member of the cluster that needs to be recovered.

excludeTargets - targets that should be excluded from recovery

Returns:

a list of recoverable members SpaceURLs. returns empty list if recovery is disabled.

toString

public String toString()

Overrides:

toString in class Object