org.maestro.tests.cluster

Class AbstractStrategy

java.lang.Object

org.maestro.tests.cluster.AbstractStrategy

All Implemented Interfaces:

DistributionStrategy

Direct Known Subclasses:

BalancedStrategy, ExclusiveBalancedStrategy, LegacyStrategy, NonAssigningStrategy

public abstract class AbstractStrategy
extends Object
implements DistributionStrategy

A simple distribution strategy that assign roles to the available nodes on the test cluster.

Constructor Summary

Constructors

Constructor and Description
AbstractStrategy(Maestro maestro)

Method Summary

Modifier and Type	Method and Description
protected abstract PeerEndpoint	assign(String id, PeerInfo peerInfo) Assign a role to the node identified by the id and peer information
PeerSet	distribute(PeerSet peers) Given a set of peers distribute them
Set<PeerEndpoint>	endpoints() Get the endpoint for lastly distributed peer set.
protected Maestro	getMaestro()
void	reset() Reset the distribution of peers

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractStrategy

public AbstractStrategy(Maestro maestro)

Method Detail

assign

protected abstract PeerEndpoint assign(String id,
                                       PeerInfo peerInfo)

Assign a role to the node identified by the id and peer information

Parameters:

id - peer ID

peerInfo - peer information

Returns:

A PeerEndpoint for addressing the distributed node

distribute

public PeerSet distribute(PeerSet peers)

Description copied from interface: DistributionStrategy

Given a set of peers distribute them

Specified by:

distribute in interface DistributionStrategy

Parameters:

peers - the set of peers to distribute

Returns:

Implementations must return the updated set of peers

See Also:

Maestro.getPeers()

reset

public void reset()

Description copied from interface: DistributionStrategy

Reset the distribution of peers

Specified by:

reset in interface DistributionStrategy

endpoints

public Set<PeerEndpoint> endpoints()

Description copied from interface: DistributionStrategy

Get the endpoint for lastly distributed peer set. These endpoint are used to send requests to the workers (ie.: one endpoint per role, group, etc)

Specified by:

endpoints in interface DistributionStrategy

Returns:

A set of endpoints

getMaestro

protected Maestro getMaestro()