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	Description
protected final int	lowCpuUsage	lowCpuUsage ~= zero CPU usage
protected final int	sampleCount	This strategy compares number of 'sampleCount' random node.
protected final Transporter	transporter

Fields inherited from class XorShiftRandomStrategy

rnd

Fields inherited from class ArrayBasedStrategy

endpointCache, endpoints, nodeID, preferLocal

Constructor Summary

Constructors

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

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.

lowCpuUsage

protected final int lowCpuUsage

lowCpuUsage ~= zero CPU usage

transporter

protected final Transporter transporter

Constructor Details

CpuUsageStrategy

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

Method Details

next

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

Overrides:

next in class XorShiftRandomStrategy<T extends Endpoint>