Uses of Class
at.qubic.api.network.Node

Packages that use Node

Package	Description
at.qubic.api.network

Uses of Node in at.qubic.api.network

Fields in at.qubic.api.network with type parameters of type Node

Modifier and Type	Field	Description
protected final Map<String,Node>	NodesManagementAdapter.nodes

Methods in at.qubic.api.network that return Node

Modifier and Type	Method	Description
Node	Nodes.addNode(String host)
Node	NodesManagementAdapter.addNode(String host)
Node	NodesManagementStrategy.addNode(String host)
protected Node	NodesManagementAdapter.newNode(String host, int port)
protected Node	PublicNodesStrategy.newNode(String host, int port)

Methods in at.qubic.api.network that return types with arguments of type Node

Modifier and Type	Method	Description
protected List<Node>	NodesManagementAdapter.getCurrentNodes(TickInfo ti, int offset)
reactor.core.publisher.Mono<Node>	Nodes.getNode()
reactor.core.publisher.Flux<Node>	FixNodesStrategy.getNodes(int max)
reactor.core.publisher.Flux<Node>	Nodes.getNodes(int max)
reactor.core.publisher.Flux<Node>	NodesManagementAdapter.getNodes(int max)
reactor.core.publisher.Flux<Node>	NodesManagementStrategy.getNodes(int max)
protected reactor.core.publisher.Flux<Node>	NodesManagementAdapter.getShuffledCurrentNodes(TickInfo ti, int offset)

Methods in at.qubic.api.network with parameters of type Node

Modifier and Type	Method	Description
protected void	NodesManagementAdapter.addNode(Node node)
reactor.core.publisher.Mono<? extends reactor.netty.Connection>	BasicNodeOperations.send(Node node, reactor.core.publisher.Mono<QubicRequest> requestMessage)	Send the request message but do not process a response.
reactor.core.publisher.Flux<QubicMessage>	BasicNodeOperations.sendAndReceive(Node node, reactor.core.publisher.Mono<? extends QubicRequest> request, MessageType type)	Send the request message and return the response messages after the peer exchange.
reactor.core.publisher.Flux<QubicMessage>	BasicNodeOperations.sendAndReceive(Node node, reactor.core.publisher.Mono<QubicRequest> request)	Send the request message and return the response messages after the peer exchange.
reactor.core.publisher.Mono<QubicMessage>	BasicNodeOperations.sendAndReceiveNext(Node node, reactor.core.publisher.Mono<? extends QubicRequest> request, MessageType messageType)	Send the request message and return the first response message after the peer exchange.
reactor.core.publisher.Mono<QubicMessage>	BasicNodeOperations.sendAndReceiveNext(Node node, reactor.core.publisher.Mono<QubicRequest> request)	Send the request message and return the first response message after the peer exchange.

Method parameters in at.qubic.api.network with type arguments of type Node

Modifier and Type	Method	Description
protected void	HealthCheckNetworkStatus.logStats(Collection<Node> nodes)
reactor.core.publisher.Mono<TickInfo>	HealthCheckNetworkStatus.update(Collection<Node> nodes)	Returns the latest known tick.
reactor.core.publisher.Mono<TickInfo>	NetworkStatus.update(Collection<Node> nodes)
reactor.core.publisher.Mono<TickInfo>	NoopNetworkStatus.update(Collection<Node> nodes)