services.moleculer.strategy

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 and Description
protected NetworkLatencyStrategyFactory	factory
protected int	sampleCount This strategy compares number of 'sampleCount' random node.

Fields inherited from class services.moleculer.strategy.XorShiftRandomStrategy

rnd

Fields inherited from class services.moleculer.strategy.ArrayBasedStrategy

endpointCache, endpoints, nodeID, preferLocal

Constructor Summary

Constructors

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

Method Summary

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

Methods inherited from class services.moleculer.strategy.ArrayBasedStrategy

addEndpoint, getAllEndpoints, getEndpoint, getEndpointsByNodeID, isEmpty, remove

Methods inherited from class java.lang.Object

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

Field Detail

sampleCount

protected final int sampleCount

This strategy compares number of 'sampleCount' random node.

factory

protected final NetworkLatencyStrategyFactory factory

Constructor Detail

NetworkLatencyStrategy

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

Method Detail

next

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

Overrides:

next in class XorShiftRandomStrategy<T extends Endpoint>