services.moleculer.strategy

Class CpuUsageStrategy<T extends Endpoint>

java.lang.Object

services.moleculer.strategy.Strategy<T>

services.moleculer.strategy.ArrayBasedStrategy<T>

services.moleculer.strategy.XorShiftRandomStrategy<T>

services.moleculer.strategy.CpuUsageStrategy<T>

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

Lowest CPU usage invocation strategy. This strategy comes from a random strategy, but preferably communicates with the "least loaded" nodes (nodes with the lowest CPU usage).

See Also:

RoundRobinStrategy, NanoSecRandomStrategy, XorShiftRandomStrategy, SecureRandomStrategy, NetworkLatencyStrategy, ShardStrategy

Field Summary

Fields

Modifier and Type	Field and Description
protected int	lowCpuUsage lowCpuUsage ~= zero CPU usage
protected int	sampleCount This strategy compares number of 'sampleCount' random node.
protected Transporter	transporter

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
CpuUsageStrategy(ServiceBroker broker, boolean preferLocal, int sampleCount, int lowCpuUsage, Transporter transporter)

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.

lowCpuUsage

protected final int lowCpuUsage

lowCpuUsage ~= zero CPU usage

transporter

protected final Transporter transporter

Constructor Detail

CpuUsageStrategy

public CpuUsageStrategy(ServiceBroker broker,
                        boolean preferLocal,
                        int sampleCount,
                        int lowCpuUsage,
                        Transporter transporter)

Method Detail

next

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

Overrides:

next in class XorShiftRandomStrategy<T extends Endpoint>