Class NetworkLatencyStrategy<T extends Endpoint>

java.lang.Object

services.moleculer.strategy.Strategy<T>

services.moleculer.strategy.ArrayBasedStrategy<T>

services.moleculer.strategy.XorShiftRandomStrategy<T>

services.moleculer.strategy.NetworkLatencyStrategy<T>

public class NetworkLatencyStrategy<T extends Endpoint>
extends XorShiftRandomStrategy<T>

Lowest network latency strategy. This strategy comes from a random strategy, but preferably communicates with the "closest" nodes (nodes with the lowest response/ping time).

See Also:

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

Field Summary

Fields

Modifier and Type	Field	Description
protected final NetworkLatencyStrategyFactory	factory
protected final int	sampleCount	This strategy compares number of 'sampleCount' random node.

Fields inherited from class XorShiftRandomStrategy

rnd

Fields inherited from class ArrayBasedStrategy

endpointCache, endpoints, nodeID, preferLocal

Constructor Summary

Constructors

Constructor	Description
NetworkLatencyStrategy(ServiceBroker broker, boolean preferLocal, int sampleCount, NetworkLatencyStrategyFactory factory)

Method Summary

Modifier and Type	Method	Description
Endpoint	next(Context ctx, Endpoint[] array)

Methods inherited from class ArrayBasedStrategy

addEndpoint, getAllEndpoints, getEndpoint, getEndpointsByNodeID, isEmpty, remove

Methods inherited from class Object

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

Field Details

sampleCount

protected final int sampleCount

This strategy compares number of 'sampleCount' random node.

factory

protected final NetworkLatencyStrategyFactory factory

Constructor Details

NetworkLatencyStrategy

public NetworkLatencyStrategy(ServiceBroker broker,
 boolean preferLocal,
 int sampleCount,
 NetworkLatencyStrategyFactory factory)

Method Details

next

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

Overrides:

next in class XorShiftRandomStrategy<T extends Endpoint>