services.moleculer.strategy

Class NetworkLatencyStrategyFactory

java.lang.Object

services.moleculer.service.MoleculerComponent

services.moleculer.strategy.StrategyFactory

services.moleculer.strategy.ArrayBasedStrategyFactory

services.moleculer.strategy.NetworkLatencyStrategyFactory

public class NetworkLatencyStrategyFactory
extends ArrayBasedStrategyFactory

Factory of 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:

RoundRobinStrategyFactory, SecureRandomStrategyFactory, XorShiftRandomStrategyFactory, NanoSecRandomStrategyFactory, CpuUsageStrategyFactory

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	NetworkLatencyStrategyFactory.Samples

Field Summary

Fields

Modifier and Type	Field and Description
protected int	averageSamples Number of samples used for average calculation.
protected int	maxTries This strategy compares number of 'maxTries' random node.
protected java.lang.String	nodeID
protected int	pingPeriod Ping period time, in SECONDS.
protected long	pingTimeout Ping period time, in MILLISECONDS.
protected java.util.concurrent.ScheduledFuture<?>	pingTimer Cancelable timer of ping loop
protected java.lang.String	previousNodeID
protected java.util.concurrent.ConcurrentHashMap<java.lang.String,NetworkLatencyStrategyFactory.Samples>	responseTimes
protected java.util.concurrent.ScheduledExecutorService	scheduler
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
NetworkLatencyStrategyFactory()
NetworkLatencyStrategyFactory(boolean preferLocal)

Method Summary

Modifier and Type	Method and Description
<T extends Endpoint> Strategy<T>	create()
protected long	getAverageResponseTime(java.lang.String nextNodeID)
int	getAverageSamples()
int	getMaxTries()
int	getPingPeriod()
long	getPingTimeout()
protected void	sendNextPing()
protected void	sendPing(java.lang.String nextNodeID)
void	setAverageSamples(int averageSamples)
void	setMaxTries(int maxTries)
void	setPingPeriod(int pingPeriod)
void	setPingTimeout(long pingTimeout)
void	started(ServiceBroker broker) Initializes strategy instance.
void	stopped()

Methods inherited from class services.moleculer.strategy.ArrayBasedStrategyFactory

isPreferLocal, setPreferLocal

Methods inherited from class services.moleculer.service.MoleculerComponent

getBroker, getLogger, getName

Methods inherited from class java.lang.Object

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

Field Detail

maxTries

protected int maxTries

This strategy compares number of 'maxTries' random node.

pingPeriod

protected int pingPeriod

Ping period time, in SECONDS.

pingTimeout

protected long pingTimeout

Ping period time, in MILLISECONDS.

averageSamples

protected int averageSamples

Number of samples used for average calculation.

scheduler

protected java.util.concurrent.ScheduledExecutorService scheduler

transporter

protected Transporter transporter

nodeID

protected java.lang.String nodeID

responseTimes

protected final java.util.concurrent.ConcurrentHashMap<java.lang.String,NetworkLatencyStrategyFactory.Samples> responseTimes

pingTimer

protected volatile java.util.concurrent.ScheduledFuture<?> pingTimer

Cancelable timer of ping loop

previousNodeID

protected volatile java.lang.String previousNodeID

Constructor Detail

NetworkLatencyStrategyFactory

public NetworkLatencyStrategyFactory()

NetworkLatencyStrategyFactory

public NetworkLatencyStrategyFactory(boolean preferLocal)

Method Detail

started

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

Initializes strategy instance.

Overrides:

started in class MoleculerComponent

Parameters:

broker - parent ServiceBroker

Throws:

java.lang.Exception

stopped

public void stopped()

Overrides:

stopped in class MoleculerComponent

sendNextPing

protected void sendNextPing()

sendPing

protected void sendPing(java.lang.String nextNodeID)

getAverageResponseTime

protected long getAverageResponseTime(java.lang.String nextNodeID)

create

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

Specified by:

create in class StrategyFactory

getMaxTries

public int getMaxTries()

setMaxTries

public void setMaxTries(int maxTries)

getPingPeriod

public int getPingPeriod()

setPingPeriod

public void setPingPeriod(int pingPeriod)

getPingTimeout

public long getPingTimeout()

setPingTimeout

public void setPingTimeout(long pingTimeout)

getAverageSamples

public int getAverageSamples()

setAverageSamples

public void setAverageSamples(int averageSamples)