Class ClusterCommand

java.lang.Object

eu.cloudnetservice.node.impl.command.sub.ClusterCommand

@Singleton
public final class ClusterCommand
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
private final eu.cloudnetservice.driver.provider.ClusterNodeProvider	clusterNodeProvider
private final eu.cloudnetservice.node.config.Configuration	configuration
static final eu.cloudnetservice.utils.base.column.RowedFormatter<eu.cloudnetservice.node.cluster.NodeServer>	FORMATTER
private static final org.slf4j.Logger	LOGGER
private final eu.cloudnetservice.node.cluster.NodeServerProvider	nodeServerProvider
private final eu.cloudnetservice.node.service.CloudServiceManager	serviceProvider
private final jakarta.inject.Provider<DefaultShutdownHandler>	shutdownHandlerProvider
private final eu.cloudnetservice.driver.template.TemplateStorageProvider	templateStorageProvider
private static final DateTimeFormatter	TIME_FORMATTER

Constructor Summary

Constructors

Constructor

Description

ClusterCommand(@NonNull eu.cloudnetservice.node.config.Configuration configuration, @NonNull eu.cloudnetservice.node.service.CloudServiceManager serviceProvider, @NonNull eu.cloudnetservice.node.cluster.NodeServerProvider nodeServerProvider, @NonNull eu.cloudnetservice.driver.provider.ClusterNodeProvider clusterNodeProvider, @NonNull eu.cloudnetservice.driver.template.TemplateStorageProvider templateStorageProvider, @NonNull jakarta.inject.Provider<DefaultShutdownHandler> shutdownHandlerProvider)

Method Summary

Modifier and Type	Method	Description
void	addNodeToCluster(@NonNull eu.cloudnetservice.driver.language.I18n i18n, @NonNull eu.cloudnetservice.node.command.source.CommandSource source, @NonNull String nodeId, @NonNull eu.cloudnetservice.driver.network.HostAndPort hostAndPort)
@NonNull String	anyHostParser(@NonNull CommandInput input, @NonNull eu.cloudnetservice.driver.language.I18n i18n)
@NonNull eu.cloudnetservice.driver.network.HostAndPort	assignableHostAndPortParser(@NonNull CommandInput input, @NonNull eu.cloudnetservice.driver.language.I18n i18n)
@NonNull eu.cloudnetservice.node.cluster.NodeServer	defaultClusterNodeServerParser(@NonNull CommandInput input, @NonNull eu.cloudnetservice.driver.language.I18n i18n)
@NonNull eu.cloudnetservice.driver.network.HostAndPort	defaultHostAndPortParser(@NonNull CommandInput input, @NonNull eu.cloudnetservice.driver.language.I18n i18n)
@NonNull eu.cloudnetservice.driver.cluster.NetworkClusterNode	defaultNetworkClusterNodeParser(@NonNull CommandInput input, @NonNull eu.cloudnetservice.driver.language.I18n i18n)
private void	displayNode(@NonNull eu.cloudnetservice.node.command.source.CommandSource source, @NonNull eu.cloudnetservice.node.cluster.NodeServer node)
void	drainNode(@NonNull eu.cloudnetservice.driver.language.I18n i18n, @NonNull eu.cloudnetservice.node.command.source.CommandSource source, @NonNull eu.cloudnetservice.node.cluster.NodeServer nodeServer, boolean enabled)
void	listNode(@NonNull eu.cloudnetservice.node.command.source.CommandSource source, @NonNull eu.cloudnetservice.node.cluster.NodeServer nodeServer)
void	listNodes(@NonNull eu.cloudnetservice.node.command.source.CommandSource source)
@NonNull String	noClusterNodeParser(@NonNull CommandInput input, @NonNull eu.cloudnetservice.driver.language.I18n i18n)
private void	pushStaticService(@NonNull eu.cloudnetservice.driver.language.I18n i18n, @NonNull eu.cloudnetservice.node.command.source.CommandSource source, @NonNull Path servicePath, @NonNull String serviceName, boolean overwrite)
void	pushStaticServices(@NonNull eu.cloudnetservice.driver.language.I18n i18n, @NonNull eu.cloudnetservice.node.command.source.CommandSource source, @Nullable String service, boolean overwrite)
private void	pushTemplate(@NonNull eu.cloudnetservice.driver.language.I18n i18n, @NonNull eu.cloudnetservice.node.command.source.CommandSource source, @NonNull eu.cloudnetservice.driver.service.ServiceTemplate template)
void	pushTemplates(@NonNull eu.cloudnetservice.driver.language.I18n i18n, @NonNull eu.cloudnetservice.node.command.source.CommandSource source, @Nullable eu.cloudnetservice.driver.service.ServiceTemplate template)
void	removeNodeFromCluster(@NonNull eu.cloudnetservice.driver.language.I18n i18n, @NonNull eu.cloudnetservice.node.command.source.CommandSource source, @NonNull eu.cloudnetservice.driver.cluster.NetworkClusterNode node)
private @NonNull List<String>	resolveAllStaticServices()
void	shutdownCluster()
@NonNull String	staticServiceParser(@NonNull CommandInput input, @NonNull eu.cloudnetservice.driver.language.I18n i18n)
@NonNull List<String>	suggestAssignableHostAndPort()
@NonNull Stream<String>	suggestClusterNodeServer()
@NonNull Stream<String>	suggestNetworkClusterNode()
@NonNull List<String>	suggestNotStartedStaticServices()
void	sync(@NonNull eu.cloudnetservice.driver.language.I18n i18n, @NonNull eu.cloudnetservice.node.command.source.CommandSource source)

Methods inherited from class Object

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

Field Details

FORMATTER

public static final eu.cloudnetservice.utils.base.column.RowedFormatter<eu.cloudnetservice.node.cluster.NodeServer> FORMATTER

LOGGER

private static final org.slf4j.Logger LOGGER

TIME_FORMATTER

private static final DateTimeFormatter TIME_FORMATTER

configuration

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

serviceProvider

private final eu.cloudnetservice.node.service.CloudServiceManager serviceProvider

nodeServerProvider

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

clusterNodeProvider

private final eu.cloudnetservice.driver.provider.ClusterNodeProvider clusterNodeProvider

templateStorageProvider

private final eu.cloudnetservice.driver.template.TemplateStorageProvider templateStorageProvider

shutdownHandlerProvider

private final jakarta.inject.Provider<DefaultShutdownHandler> shutdownHandlerProvider

Constructor Details

ClusterCommand

@Inject
public ClusterCommand(@NonNull
 @NonNull eu.cloudnetservice.node.config.Configuration configuration,
 @NonNull
 @NonNull eu.cloudnetservice.node.service.CloudServiceManager serviceProvider,
 @NonNull
 @NonNull eu.cloudnetservice.node.cluster.NodeServerProvider nodeServerProvider,
 @NonNull
 @NonNull eu.cloudnetservice.driver.provider.ClusterNodeProvider clusterNodeProvider,
 @NonNull
 @NonNull eu.cloudnetservice.driver.template.TemplateStorageProvider templateStorageProvider,
 @NonNull
 @NonNull jakarta.inject.Provider<DefaultShutdownHandler> shutdownHandlerProvider)

Method Details

defaultClusterNodeServerParser

@NonNull
public @NonNull eu.cloudnetservice.node.cluster.NodeServer defaultClusterNodeServerParser(@NonNull
 @NonNull CommandInput input,
 @NonNull @Service
 @NonNull eu.cloudnetservice.driver.language.I18n i18n)

suggestClusterNodeServer

@NonNull
public @NonNull Stream<String> suggestClusterNodeServer()

defaultNetworkClusterNodeParser

@NonNull
public @NonNull eu.cloudnetservice.driver.cluster.NetworkClusterNode defaultNetworkClusterNodeParser(@NonNull
 @NonNull CommandInput input,
 @NonNull @Service
 @NonNull eu.cloudnetservice.driver.language.I18n i18n)

suggestNetworkClusterNode

@NonNull
public @NonNull Stream<String> suggestNetworkClusterNode()

defaultHostAndPortParser

@NonNull
public @NonNull eu.cloudnetservice.driver.network.HostAndPort defaultHostAndPortParser(@NonNull
 @NonNull CommandInput input,
 @NonNull @Service
 @NonNull eu.cloudnetservice.driver.language.I18n i18n)

assignableHostAndPortParser

@NonNull
public @NonNull eu.cloudnetservice.driver.network.HostAndPort assignableHostAndPortParser(@NonNull
 @NonNull CommandInput input,
 @NonNull @Service
 @NonNull eu.cloudnetservice.driver.language.I18n i18n)

suggestAssignableHostAndPort

@NonNull
public @NonNull List<String> suggestAssignableHostAndPort()

anyHostParser

@NonNull
public @NonNull String anyHostParser(@NonNull
 @NonNull CommandInput input,
 @NonNull @Service
 @NonNull eu.cloudnetservice.driver.language.I18n i18n)

noClusterNodeParser

@NonNull
public @NonNull String noClusterNodeParser(@NonNull
 @NonNull CommandInput input,
 @NonNull @Service
 @NonNull eu.cloudnetservice.driver.language.I18n i18n)

staticServiceParser

@NonNull
public @NonNull String staticServiceParser(@NonNull
 @NonNull CommandInput input,
 @NonNull @Service
 @NonNull eu.cloudnetservice.driver.language.I18n i18n)

suggestNotStartedStaticServices

@NonNull
public @NonNull List<String> suggestNotStartedStaticServices()

shutdownCluster

public void shutdownCluster()

addNodeToCluster

public void addNodeToCluster(@NonNull @Service
 @NonNull eu.cloudnetservice.driver.language.I18n i18n,
 @NonNull
 @NonNull eu.cloudnetservice.node.command.source.CommandSource source,
 @NonNull
 @NonNull String nodeId,
 @NonNull
 @NonNull eu.cloudnetservice.driver.network.HostAndPort hostAndPort)

removeNodeFromCluster

public void removeNodeFromCluster(@NonNull @Service
 @NonNull eu.cloudnetservice.driver.language.I18n i18n,
 @NonNull
 @NonNull eu.cloudnetservice.node.command.source.CommandSource source,
 @NonNull
 @NonNull eu.cloudnetservice.driver.cluster.NetworkClusterNode node)

listNodes

public void listNodes(@NonNull
 @NonNull eu.cloudnetservice.node.command.source.CommandSource source)

listNode

public void listNode(@NonNull
 @NonNull eu.cloudnetservice.node.command.source.CommandSource source,
 @NonNull
 @NonNull eu.cloudnetservice.node.cluster.NodeServer nodeServer)

drainNode

public void drainNode(@NonNull @Service
 @NonNull eu.cloudnetservice.driver.language.I18n i18n,
 @NonNull
 @NonNull eu.cloudnetservice.node.command.source.CommandSource source,
 @NonNull
 @NonNull eu.cloudnetservice.node.cluster.NodeServer nodeServer,
 boolean enabled)

sync

public void sync(@NonNull @Service
 @NonNull eu.cloudnetservice.driver.language.I18n i18n,
 @NonNull
 @NonNull eu.cloudnetservice.node.command.source.CommandSource source)

pushTemplates

public void pushTemplates(@NonNull @Service
 @NonNull eu.cloudnetservice.driver.language.I18n i18n,
 @NonNull
 @NonNull eu.cloudnetservice.node.command.source.CommandSource source,
 @Nullable
 @Nullable eu.cloudnetservice.driver.service.ServiceTemplate template)

pushStaticServices

public void pushStaticServices(@NonNull @Service
 @NonNull eu.cloudnetservice.driver.language.I18n i18n,
 @NonNull
 @NonNull eu.cloudnetservice.node.command.source.CommandSource source,
 @Nullable
 @Nullable String service,
 boolean overwrite)

pushStaticService

private void pushStaticService(@NonNull @Service
 @NonNull eu.cloudnetservice.driver.language.I18n i18n,
 @NonNull
 @NonNull eu.cloudnetservice.node.command.source.CommandSource source,
 @NonNull
 @NonNull Path servicePath,
 @NonNull
 @NonNull String serviceName,
 boolean overwrite)

pushTemplate

private void pushTemplate(@NonNull @Service
 @NonNull eu.cloudnetservice.driver.language.I18n i18n,
 @NonNull
 @NonNull eu.cloudnetservice.node.command.source.CommandSource source,
 @NonNull
 @NonNull eu.cloudnetservice.driver.service.ServiceTemplate template)

resolveAllStaticServices

@NonNull
private @NonNull List<String> resolveAllStaticServices()

displayNode

private void displayNode(@NonNull
 @NonNull eu.cloudnetservice.node.command.source.CommandSource source,
 @NonNull
 @NonNull eu.cloudnetservice.node.cluster.NodeServer node)