Class CpuUsageStrategyFactory

java.lang.Object

services.moleculer.service.MoleculerComponent

services.moleculer.strategy.StrategyFactory

services.moleculer.strategy.ArrayBasedStrategyFactory

services.moleculer.strategy.CpuUsageStrategyFactory

All Implemented Interfaces:

MoleculerLifecycle

public class CpuUsageStrategyFactory
extends ArrayBasedStrategyFactory

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

See Also:

• RoundRobinStrategyFactory
• SecureRandomStrategyFactory
• XorShiftRandomStrategyFactory
• NanoSecRandomStrategyFactory
• NetworkLatencyStrategyFactory
• ShardStrategyFactory

Field Summary

Fields

Modifier and Type	Field	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 ArrayBasedStrategyFactory

preferLocal

Fields inherited from class MoleculerComponent

broker, logger, name

Constructor Summary

Constructors

Constructor	Description
CpuUsageStrategyFactory()	Constructor that calls for service based primarily on its own (CPU-based) logic.
CpuUsageStrategyFactory(boolean preferLocal)	Constructor that can be configured to use local services if possible.
CpuUsageStrategyFactory(boolean preferLocal, int sampleCount, int lowCpuUsage)

Method Summary

Modifier and Type	Method	Description
<T extends Endpoint> Strategy<T>	create()
int	getLowCpuUsage()
int	getSampleCount()
void	setLowCpuUsage(int lowCpuUsage)
void	setSampleCount(int sampleCount)
void	started(ServiceBroker broker)	Initializes strategy instance.

Methods inherited from class ArrayBasedStrategyFactory

isPreferLocal, setPreferLocal

Methods inherited from class MoleculerComponent

getBroker, getLogger, getName, stopped

Methods inherited from class Object

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

Field Details

sampleCount

protected int sampleCount

This strategy compares number of 'sampleCount' random node.

lowCpuUsage

protected int lowCpuUsage

lowCpuUsage ~= zero CPU usage

transporter

protected Transporter transporter

Constructor Details

CpuUsageStrategyFactory

public CpuUsageStrategyFactory()

Constructor that calls for service based primarily on its own (CPU-based) logic. Does not matter if the service is available locally.

CpuUsageStrategyFactory

public CpuUsageStrategyFactory(boolean preferLocal)

Constructor that can be configured to use local services if possible.

Parameters:

preferLocal - invoke local actions if possible

CpuUsageStrategyFactory

public CpuUsageStrategyFactory(boolean preferLocal,
 int sampleCount,
 int lowCpuUsage)

Method Details

started

public void started(ServiceBroker broker)
             throws Exception

Initializes strategy instance.

Specified by:

started in interface MoleculerLifecycle

Overrides:

started in class MoleculerComponent

Parameters:

broker - parent ServiceBroker

Throws:

Exception

create

public <T extends Endpoint> Strategy<T> create()

Specified by:

create in class StrategyFactory

getSampleCount

public int getSampleCount()

setSampleCount

public void setSampleCount(int sampleCount)

getLowCpuUsage

public int getLowCpuUsage()

setLowCpuUsage

public void setLowCpuUsage(int lowCpuUsage)