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	collectCount Number of samples used for average calculation.
protected java.lang.String	nodeID
protected int	pingInterval Ping period time, in SECONDS.
protected long	pingTimeout Ping timeout 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 int	sampleCount This strategy compares number of 'sampleCount' random node.
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	getCollectCount()
int	getPingInterval()
long	getPingTimeout()
int	getSampleCount()
protected void	sendNextPing()
protected void	sendPing(java.lang.String nextNodeID)
void	setCollectCount(int collectCount)
void	setPingInterval(int pingInterval)
void	setPingTimeout(long pingTimeout)
void	setSampleCount(int sampleCount)
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

sampleCount

protected int sampleCount

This strategy compares number of 'sampleCount' random node.

pingInterval

protected int pingInterval

Ping period time, in SECONDS.

pingTimeout

protected long pingTimeout

Ping timeout time, in MILLISECONDS.

collectCount

protected int collectCount

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

getSampleCount

public int getSampleCount()

setSampleCount

public void setSampleCount(int sampleCount)

getPingInterval

public int getPingInterval()

setPingInterval

public void setPingInterval(int pingInterval)

getPingTimeout

public long getPingTimeout()

setPingTimeout

public void setPingTimeout(long pingTimeout)

getCollectCount

public int getCollectCount()

setCollectCount

public void setCollectCount(int collectCount)