Package at.qubic.api.network

Class NodesManagementAdapter

java.lang.Object

at.qubic.api.network.NodesManagementAdapter

All Implemented Interfaces:

NodesManagementStrategy

Direct Known Subclasses:

FixNodesStrategy, PublicNodesStrategy

public abstract class NodesManagementAdapter
extends Object
implements NodesManagementStrategy

Field Summary

Fields

Modifier and Type	Field	Description
protected final int	maxTickDelay
protected final NetworkStatus	networkStatus
protected final Map<String,Node>	nodes
protected final int	port
protected final Duration	refreshInterval

Constructor Summary

Constructors

Constructor	Description
NodesManagementAdapter(NetworkStatus networkStatus)
NodesManagementAdapter(NetworkStatus networkStatus, NetworkProperties networkProperties)

Method Summary

Modifier and Type	Method	Description
protected void	addNode(Node node)
Node	addNode(String host)
reactor.core.publisher.Mono<Instant>	forceNetworkUpdate(Instant updateIfBefore)
protected List<Node>	getCurrentNodes(TickInfo ti, int offset)
reactor.core.publisher.Flux<Node>	getNodes(int max)
protected reactor.core.publisher.Flux<Node>	getShuffledCurrentNodes(TickInfo ti, int offset)
protected Node	newNode(String host, int port)
protected reactor.core.publisher.Mono<TickInfo>	updateNetworkStatus()
protected void	updateNetworkStatusAsync(TickStatus ts)

Methods inherited from class java.lang.Object

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

Field Details

port

protected final int port

maxTickDelay

protected final int maxTickDelay

refreshInterval

protected final Duration refreshInterval

nodes

protected final Map<String,Node> nodes

networkStatus

protected final NetworkStatus networkStatus

Constructor Details

NodesManagementAdapter

public NodesManagementAdapter(NetworkStatus networkStatus)

NodesManagementAdapter

public NodesManagementAdapter(NetworkStatus networkStatus,
 NetworkProperties networkProperties)

Method Details

addNode

public Node addNode(String host)

Specified by:

addNode in interface NodesManagementStrategy

addNode

protected void addNode(Node node)

getNodes

public reactor.core.publisher.Flux<Node> getNodes(int max)

Specified by:

getNodes in interface NodesManagementStrategy

newNode

protected Node newNode(String host,
 int port)

getShuffledCurrentNodes

protected reactor.core.publisher.Flux<Node> getShuffledCurrentNodes(TickInfo ti,
 int offset)

getCurrentNodes

protected List<Node> getCurrentNodes(TickInfo ti,
 int offset)

forceNetworkUpdate

public reactor.core.publisher.Mono<Instant> forceNetworkUpdate(Instant updateIfBefore)

Specified by:

forceNetworkUpdate in interface NodesManagementStrategy

updateNetworkStatus

protected reactor.core.publisher.Mono<TickInfo> updateNetworkStatus()

updateNetworkStatusAsync

protected void updateNetworkStatusAsync(TickStatus ts)