services.moleculer.strategy

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 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.ArrayBasedStrategyFactory

preferLocal

Fields inherited from class services.moleculer.service.MoleculerComponent

broker, logger, name

Constructor Summary

Constructors

Constructor and 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 and 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 services.moleculer.strategy.ArrayBasedStrategyFactory

isPreferLocal, setPreferLocal

Methods inherited from class services.moleculer.service.MoleculerComponent

getBroker, getLogger, getName, stopped

Methods inherited from class java.lang.Object

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

Field Detail

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 Detail

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 Detail

started

public void started(ServiceBroker broker)
             throws java.lang.Exception

Initializes strategy instance.

Specified by:

started in interface MoleculerLifecycle

Overrides:

started in class MoleculerComponent

Parameters:

broker - parent ServiceBroker

Throws:

java.lang.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)