Class NodeClusterNodeProvider

java.lang.Object

eu.cloudnetservice.node.impl.provider.NodeClusterNodeProvider

All Implemented Interfaces:

eu.cloudnetservice.driver.provider.ClusterNodeProvider

@Singleton
@Provides(eu.cloudnetservice.driver.provider.ClusterNodeProvider.class)
public class NodeClusterNodeProvider
extends Object
implements eu.cloudnetservice.driver.provider.ClusterNodeProvider

Field Summary

Fields

Modifier and Type	Field	Description
private final eu.cloudnetservice.node.cluster.NodeServerProvider	clusterNodeServerProvider
private final eu.cloudnetservice.node.command.CommandProvider	commandProvider
private final eu.cloudnetservice.node.config.Configuration	configuration

Constructor Summary

Constructors

Constructor

Description

NodeClusterNodeProvider(@NonNull eu.cloudnetservice.node.config.Configuration configuration, @NonNull eu.cloudnetservice.node.command.CommandProvider commandProvider, @NonNull eu.cloudnetservice.node.cluster.NodeServerProvider nodeServerProvider, @NonNull eu.cloudnetservice.driver.network.rpc.factory.RPCFactory rpcFactory, @NonNull eu.cloudnetservice.driver.network.rpc.handler.RPCHandlerRegistry handlerRegistry)

Method Summary

Modifier and Type	Method	Description
boolean	addNode(@NonNull eu.cloudnetservice.driver.cluster.NetworkClusterNode node)
@NonNull CompletableFuture<Boolean>	addNodeAsync(@NonNull eu.cloudnetservice.driver.cluster.NetworkClusterNode node)
void	addNodeSilently(@NonNull eu.cloudnetservice.driver.cluster.NetworkClusterNode node)
@Nullable eu.cloudnetservice.driver.command.CommandInfo	consoleCommand(@NonNull String name)
@NonNull CompletableFuture<eu.cloudnetservice.driver.command.CommandInfo>	consoleCommandAsync(@NonNull String name)
@NonNull Collection<eu.cloudnetservice.driver.command.CommandInfo>	consoleCommands()
@NonNull CompletableFuture<Collection<eu.cloudnetservice.driver.command.CommandInfo>>	consoleCommandsAsync()
@NonNull Collection<String>	consoleTabCompleteResults(@NonNull String commandLine)
@NonNull CompletableFuture<Collection<String>>	consoleTabCompleteResultsAsync(@NonNull String commandLine)
@Nullable eu.cloudnetservice.driver.cluster.NetworkClusterNode	node(@NonNull String uniqueId)
@NonNull CompletableFuture<eu.cloudnetservice.driver.cluster.NetworkClusterNode>	nodeAsync(@NonNull String uniqueId)
@Nullable eu.cloudnetservice.driver.cluster.NodeInfoSnapshot	nodeInfoSnapshot(@NonNull String uniqueId)
@NonNull CompletableFuture<eu.cloudnetservice.driver.cluster.NodeInfoSnapshot>	nodeInfoSnapshotAsync(@NonNull String uniqueId)
@NonNull Collection<eu.cloudnetservice.driver.cluster.NodeInfoSnapshot>	nodeInfoSnapshots()
@NonNull CompletableFuture<Collection<eu.cloudnetservice.driver.cluster.NodeInfoSnapshot>>	nodeInfoSnapshotsAsync()
@NonNull Collection<eu.cloudnetservice.driver.cluster.NetworkClusterNode>	nodes()
@NonNull CompletableFuture<Collection<eu.cloudnetservice.driver.cluster.NetworkClusterNode>>	nodesAsync()
boolean	removeNode(@NonNull String uniqueId)
@NonNull CompletableFuture<Boolean>	removeNodeAsync(@NonNull String uniqueId)
void	removeNodeSilently(@NonNull eu.cloudnetservice.driver.cluster.NetworkClusterNode node)
@NonNull Collection<String>	sendCommandLine(@NonNull String commandLine)
@NonNull CompletableFuture<Collection<String>>	sendCommandLineAsync(@NonNull String commandLine)

Methods inherited from class Object

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

Field Details

configuration

private final eu.cloudnetservice.node.config.Configuration configuration

commandProvider

private final eu.cloudnetservice.node.command.CommandProvider commandProvider

clusterNodeServerProvider

private final eu.cloudnetservice.node.cluster.NodeServerProvider clusterNodeServerProvider

Constructor Details

NodeClusterNodeProvider

@Inject
public NodeClusterNodeProvider(@NonNull
 @NonNull eu.cloudnetservice.node.config.Configuration configuration,
 @NonNull
 @NonNull eu.cloudnetservice.node.command.CommandProvider commandProvider,
 @NonNull
 @NonNull eu.cloudnetservice.node.cluster.NodeServerProvider nodeServerProvider,
 @NonNull
 @NonNull eu.cloudnetservice.driver.network.rpc.factory.RPCFactory rpcFactory,
 @NonNull
 @NonNull eu.cloudnetservice.driver.network.rpc.handler.RPCHandlerRegistry handlerRegistry)

Method Details

consoleCommands

@NonNull
public @NonNull Collection<eu.cloudnetservice.driver.command.CommandInfo> consoleCommands()

Specified by:

consoleCommands in interface eu.cloudnetservice.driver.provider.ClusterNodeProvider

nodes

@NonNull
public @NonNull Collection<eu.cloudnetservice.driver.cluster.NetworkClusterNode> nodes()

Specified by:

nodes in interface eu.cloudnetservice.driver.provider.ClusterNodeProvider

node

@Nullable
public @Nullable eu.cloudnetservice.driver.cluster.NetworkClusterNode node(@NonNull
 @NonNull String uniqueId)

Specified by:

node in interface eu.cloudnetservice.driver.provider.ClusterNodeProvider

addNode

public boolean addNode(@NonNull
 @NonNull eu.cloudnetservice.driver.cluster.NetworkClusterNode node)

Specified by:

addNode in interface eu.cloudnetservice.driver.provider.ClusterNodeProvider

removeNode

public boolean removeNode(@NonNull
 @NonNull String uniqueId)

Specified by:

removeNode in interface eu.cloudnetservice.driver.provider.ClusterNodeProvider

nodeInfoSnapshots

@NonNull
public @NonNull Collection<eu.cloudnetservice.driver.cluster.NodeInfoSnapshot> nodeInfoSnapshots()

Specified by:

nodeInfoSnapshots in interface eu.cloudnetservice.driver.provider.ClusterNodeProvider

nodeInfoSnapshot

@Nullable
public @Nullable eu.cloudnetservice.driver.cluster.NodeInfoSnapshot nodeInfoSnapshot(@NonNull
 @NonNull String uniqueId)

Specified by:

nodeInfoSnapshot in interface eu.cloudnetservice.driver.provider.ClusterNodeProvider

consoleCommandsAsync

@NonNull
public @NonNull CompletableFuture<Collection<eu.cloudnetservice.driver.command.CommandInfo>> consoleCommandsAsync()

Specified by:

consoleCommandsAsync in interface eu.cloudnetservice.driver.provider.ClusterNodeProvider

consoleCommandAsync

@NonNull
public @NonNull CompletableFuture<eu.cloudnetservice.driver.command.CommandInfo> consoleCommandAsync(@NonNull
 @NonNull String name)

Specified by:

consoleCommandAsync in interface eu.cloudnetservice.driver.provider.ClusterNodeProvider

consoleTabCompleteResultsAsync

@NonNull
public @NonNull CompletableFuture<Collection<String>> consoleTabCompleteResultsAsync(@NonNull
 @NonNull String commandLine)

Specified by:

consoleTabCompleteResultsAsync in interface eu.cloudnetservice.driver.provider.ClusterNodeProvider

sendCommandLineAsync

@NonNull
public @NonNull CompletableFuture<Collection<String>> sendCommandLineAsync(@NonNull
 @NonNull String commandLine)

Specified by:

sendCommandLineAsync in interface eu.cloudnetservice.driver.provider.ClusterNodeProvider

nodesAsync

@NonNull
public @NonNull CompletableFuture<Collection<eu.cloudnetservice.driver.cluster.NetworkClusterNode>> nodesAsync()

Specified by:

nodesAsync in interface eu.cloudnetservice.driver.provider.ClusterNodeProvider

nodeAsync

@NonNull
public @NonNull CompletableFuture<eu.cloudnetservice.driver.cluster.NetworkClusterNode> nodeAsync(@NonNull
 @NonNull String uniqueId)

Specified by:

nodeAsync in interface eu.cloudnetservice.driver.provider.ClusterNodeProvider

addNodeAsync

@NonNull
public @NonNull CompletableFuture<Boolean> addNodeAsync(@NonNull
 @NonNull eu.cloudnetservice.driver.cluster.NetworkClusterNode node)

Specified by:

addNodeAsync in interface eu.cloudnetservice.driver.provider.ClusterNodeProvider

removeNodeAsync

@NonNull
public @NonNull CompletableFuture<Boolean> removeNodeAsync(@NonNull
 @NonNull String uniqueId)

Specified by:

removeNodeAsync in interface eu.cloudnetservice.driver.provider.ClusterNodeProvider

nodeInfoSnapshotsAsync

@NonNull
public @NonNull CompletableFuture<Collection<eu.cloudnetservice.driver.cluster.NodeInfoSnapshot>> nodeInfoSnapshotsAsync()

Specified by:

nodeInfoSnapshotsAsync in interface eu.cloudnetservice.driver.provider.ClusterNodeProvider

nodeInfoSnapshotAsync

@NonNull
public @NonNull CompletableFuture<eu.cloudnetservice.driver.cluster.NodeInfoSnapshot> nodeInfoSnapshotAsync(@NonNull
 @NonNull String uniqueId)

Specified by:

nodeInfoSnapshotAsync in interface eu.cloudnetservice.driver.provider.ClusterNodeProvider

sendCommandLine

@NonNull
public @NonNull Collection<String> sendCommandLine(@NonNull
 @NonNull String commandLine)

Specified by:

sendCommandLine in interface eu.cloudnetservice.driver.provider.ClusterNodeProvider

consoleCommand

@Nullable
public @Nullable eu.cloudnetservice.driver.command.CommandInfo consoleCommand(@NonNull
 @NonNull String name)

Specified by:

consoleCommand in interface eu.cloudnetservice.driver.provider.ClusterNodeProvider

consoleTabCompleteResults

@NonNull
public @NonNull Collection<String> consoleTabCompleteResults(@NonNull
 @NonNull String commandLine)

Specified by:

consoleTabCompleteResults in interface eu.cloudnetservice.driver.provider.ClusterNodeProvider

addNodeSilently

public void addNodeSilently(@NonNull
 @NonNull eu.cloudnetservice.driver.cluster.NetworkClusterNode node)

removeNodeSilently

public void removeNodeSilently(@NonNull
 @NonNull eu.cloudnetservice.driver.cluster.NetworkClusterNode node)