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

Field Summary

Fields

Modifier and Type	Field and Description
protected NetworkLatencyStrategyFactory	factory
protected int	maxTries This strategy compares number of 'maxTries' 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 maxTries, NetworkLatencyStrategyFactory factory)

Method Summary

Modifier and Type	Method and Description
Endpoint	next(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

maxTries

protected final int maxTries

This strategy compares number of 'maxTries' random node.

factory

protected final NetworkLatencyStrategyFactory factory

Constructor Detail

NetworkLatencyStrategy

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

Method Detail

next

public Endpoint next(Endpoint[] array)

Overrides:

next in class XorShiftRandomStrategy<T extends Endpoint>