Class ArrayBasedStrategy<T extends Endpoint>

java.lang.Object

services.moleculer.strategy.Strategy<T>

services.moleculer.strategy.ArrayBasedStrategy<T>

Direct Known Subclasses:

NanoSecRandomStrategy, RoundRobinStrategy, SecureRandomStrategy, XorShiftRandomStrategy

public abstract class ArrayBasedStrategy<T extends Endpoint>
extends Strategy<T>

Abstract class for Round-Robin and Random invocation strategies.

See Also:

• RoundRobinStrategy
• NanoSecRandomStrategy
• SecureRandomStrategy
• XorShiftRandomStrategy
• CpuUsageStrategy
• NetworkLatencyStrategy
• ShardStrategy

Field Summary

Fields

Modifier and Type	Field	Description
protected final io.datatree.dom.Cache<String, Endpoint[]>	endpointCache
protected Endpoint[]	endpoints
protected final String	nodeID
protected final boolean	preferLocal

Constructor Summary

Constructors

Constructor	Description
ArrayBasedStrategy(ServiceBroker broker, boolean preferLocal)

Method Summary

Modifier and Type	Method	Description
void	addEndpoint(T endpoint)
List<T>	getAllEndpoints()
T	getEndpoint(Context ctx, String nodeID)
protected Endpoint[]	getEndpointsByNodeID(String nodeID)
boolean	isEmpty()
abstract Endpoint	next(Context ctx, Endpoint[] array)
boolean	remove(String nodeID)

Methods inherited from class Object

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

Field Details

endpoints

protected Endpoint[] endpoints

endpointCache

protected final io.datatree.dom.Cache<String, Endpoint[]> endpointCache

nodeID

protected final String nodeID

preferLocal

protected final boolean preferLocal

Constructor Details

ArrayBasedStrategy

public ArrayBasedStrategy(ServiceBroker broker,
 boolean preferLocal)

Method Details

addEndpoint

public void addEndpoint(T endpoint)

Specified by:

addEndpoint in class Strategy<T extends Endpoint>

remove

public boolean remove(String nodeID)

Specified by:

remove in class Strategy<T extends Endpoint>

isEmpty

public boolean isEmpty()

Specified by:

isEmpty in class Strategy<T extends Endpoint>

getEndpoint

public T getEndpoint(Context ctx,
 String nodeID)

Specified by:

getEndpoint in class Strategy<T extends Endpoint>

getEndpointsByNodeID

protected Endpoint[] getEndpointsByNodeID(String nodeID)

next

public abstract Endpoint next(Context ctx,
 Endpoint[] array)

getAllEndpoints

public List<T> getAllEndpoints()

Specified by:

getAllEndpoints in class Strategy<T extends Endpoint>