Class DefaultLocalNodeServer

java.lang.Object

eu.cloudnetservice.node.impl.cluster.defaults.DefaultLocalNodeServer

All Implemented Interfaces:

eu.cloudnetservice.driver.base.Named, eu.cloudnetservice.node.cluster.LocalNodeServer, eu.cloudnetservice.node.cluster.NodeServer, Closeable, AutoCloseable

@Singleton
@Provides(eu.cloudnetservice.node.cluster.LocalNodeServer.class)
public class DefaultLocalNodeServer
extends Object
implements eu.cloudnetservice.node.cluster.LocalNodeServer

Field Summary

Fields

Modifier and Type	Field	Description
private final eu.cloudnetservice.driver.provider.CloudServiceFactory	cloudServiceFactory
private final eu.cloudnetservice.node.service.CloudServiceManager	cloudServiceProvider
private final eu.cloudnetservice.node.command.CommandProvider	commandProvider
private final eu.cloudnetservice.node.config.Configuration	configuration
private final long	creationMillis
private eu.cloudnetservice.driver.cluster.NodeInfoSnapshot	currentSnapshot
private boolean	draining
private final eu.cloudnetservice.driver.event.EventManager	eventManager
private Instant	lastNodeInfoUpdate
private eu.cloudnetservice.driver.cluster.NodeInfoSnapshot	lastSnapshot
private Instant	lastStateChange
private final eu.cloudnetservice.driver.module.ModuleProvider	moduleProvider
private final eu.cloudnetservice.node.cluster.NodeServerProvider	provider
private final jakarta.inject.Provider<DefaultShutdownHandler>	shutdownHandlerProvider
private eu.cloudnetservice.node.cluster.NodeServerState	state
private final eu.cloudnetservice.driver.CloudNetVersion	version

Constructor Summary

Constructors

Constructor

Description

DefaultLocalNodeServer(@NonNull eu.cloudnetservice.driver.CloudNetVersion version, @NonNull eu.cloudnetservice.driver.event.EventManager eventManager, @NonNull eu.cloudnetservice.node.cluster.NodeServerProvider provider, @NonNull eu.cloudnetservice.node.config.Configuration configuration, @NonNull eu.cloudnetservice.driver.module.ModuleProvider moduleProvider, @NonNull eu.cloudnetservice.node.command.CommandProvider commandProvider, @NonNull eu.cloudnetservice.driver.provider.CloudServiceFactory cloudServiceFactory, @NonNull eu.cloudnetservice.node.service.CloudServiceManager cloudServiceProvider, @NonNull jakarta.inject.Provider<DefaultShutdownHandler> shutdownHandlerProvider)

Method Summary

Modifier and Type	Method	Description
boolean	available()
@UnknownNullability eu.cloudnetservice.driver.network.NetworkChannel	channel()
void	channel(@Nullable eu.cloudnetservice.driver.network.NetworkChannel channel)
void	close()
@NonNull CompletableFuture<Void>	connect()
void	drain(boolean doDrain)
boolean	draining()
boolean	head()
@NonNull eu.cloudnetservice.driver.cluster.NetworkClusterNode	info()
@UnknownNullability eu.cloudnetservice.driver.cluster.NodeInfoSnapshot	lastNodeInfoSnapshot()
@NonNull Instant	lastNodeInfoUpdate()
@NonNull Instant	lastStateChange()
@NonNull String	name()
@UnknownNullability eu.cloudnetservice.driver.cluster.NodeInfoSnapshot	nodeInfoSnapshot()
@NonNull eu.cloudnetservice.node.cluster.NodeServerProvider	provider()
@NonNull Collection<String>	sendCommandLine(@NonNull String commandLine)
@NonNull eu.cloudnetservice.driver.provider.CloudServiceFactory	serviceFactory()
@Nullable eu.cloudnetservice.driver.provider.SpecificCloudServiceProvider	serviceProvider(@NonNull UUID uniqueId)
void	shutdown()
@NonNull eu.cloudnetservice.node.cluster.NodeServerState	state()
void	state(@NonNull eu.cloudnetservice.node.cluster.NodeServerState state)
void	syncClusterData(boolean force)
void	updateLocalSnapshot()
void	updateNodeInfoSnapshot(@Nullable eu.cloudnetservice.driver.cluster.NodeInfoSnapshot snapshot)

Methods inherited from class Object

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

Field Details

version

private final eu.cloudnetservice.driver.CloudNetVersion version

eventManager

private final eu.cloudnetservice.driver.event.EventManager eventManager

provider

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

configuration

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

moduleProvider

private final eu.cloudnetservice.driver.module.ModuleProvider moduleProvider

commandProvider

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

cloudServiceFactory

private final eu.cloudnetservice.driver.provider.CloudServiceFactory cloudServiceFactory

cloudServiceProvider

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

shutdownHandlerProvider

private final jakarta.inject.Provider<DefaultShutdownHandler> shutdownHandlerProvider

creationMillis

private final long creationMillis

draining

private volatile boolean draining

lastStateChange

private volatile Instant lastStateChange

state

private volatile eu.cloudnetservice.node.cluster.NodeServerState state

currentSnapshot

private volatile eu.cloudnetservice.driver.cluster.NodeInfoSnapshot currentSnapshot

lastSnapshot

private volatile eu.cloudnetservice.driver.cluster.NodeInfoSnapshot lastSnapshot

lastNodeInfoUpdate

private volatile Instant lastNodeInfoUpdate

Constructor Details

DefaultLocalNodeServer

@Inject
public DefaultLocalNodeServer(@NonNull
 @NonNull eu.cloudnetservice.driver.CloudNetVersion version,
 @NonNull
 @NonNull eu.cloudnetservice.driver.event.EventManager eventManager,
 @NonNull
 @NonNull eu.cloudnetservice.node.cluster.NodeServerProvider provider,
 @NonNull
 @NonNull eu.cloudnetservice.node.config.Configuration configuration,
 @NonNull
 @NonNull eu.cloudnetservice.driver.module.ModuleProvider moduleProvider,
 @NonNull
 @NonNull eu.cloudnetservice.node.command.CommandProvider commandProvider,
 @NonNull
 @NonNull eu.cloudnetservice.driver.provider.CloudServiceFactory cloudServiceFactory,
 @NonNull
 @NonNull eu.cloudnetservice.node.service.CloudServiceManager cloudServiceProvider,
 @NonNull
 @NonNull jakarta.inject.Provider<DefaultShutdownHandler> shutdownHandlerProvider)

Method Details

name

@NonNull
public @NonNull String name()

Specified by:

name in interface eu.cloudnetservice.driver.base.Named

head

public boolean head()

Specified by:

head in interface eu.cloudnetservice.node.cluster.NodeServer

available

public boolean available()

Specified by:

available in interface eu.cloudnetservice.node.cluster.NodeServer

shutdown

public void shutdown()

Specified by:

shutdown in interface eu.cloudnetservice.node.cluster.NodeServer

connect

@NonNull
public @NonNull CompletableFuture<Void> connect()

Specified by:

connect in interface eu.cloudnetservice.node.cluster.NodeServer

draining

public boolean draining()

Specified by:

draining in interface eu.cloudnetservice.node.cluster.NodeServer

drain

public void drain(boolean doDrain)

Specified by:

drain in interface eu.cloudnetservice.node.cluster.NodeServer

syncClusterData

public void syncClusterData(boolean force)

Specified by:

syncClusterData in interface eu.cloudnetservice.node.cluster.NodeServer

info

@NonNull
public @NonNull eu.cloudnetservice.driver.cluster.NetworkClusterNode info()

Specified by:

info in interface eu.cloudnetservice.node.cluster.NodeServer

provider

@NonNull
public @NonNull eu.cloudnetservice.node.cluster.NodeServerProvider provider()

Specified by:

provider in interface eu.cloudnetservice.node.cluster.NodeServer

state

@NonNull
public @NonNull eu.cloudnetservice.node.cluster.NodeServerState state()

Specified by:

state in interface eu.cloudnetservice.node.cluster.NodeServer

state

public void state(@NonNull
 @NonNull eu.cloudnetservice.node.cluster.NodeServerState state)

Specified by:

state in interface eu.cloudnetservice.node.cluster.NodeServer

lastStateChange

@NonNull
public @NonNull Instant lastStateChange()

Specified by:

lastStateChange in interface eu.cloudnetservice.node.cluster.NodeServer

channel

public @UnknownNullability eu.cloudnetservice.driver.network.NetworkChannel channel()

Specified by:

channel in interface eu.cloudnetservice.node.cluster.NodeServer

channel

public void channel(@Nullable
 @Nullable eu.cloudnetservice.driver.network.NetworkChannel channel)

Specified by:

channel in interface eu.cloudnetservice.node.cluster.NodeServer

nodeInfoSnapshot

public @UnknownNullability eu.cloudnetservice.driver.cluster.NodeInfoSnapshot nodeInfoSnapshot()

Specified by:

nodeInfoSnapshot in interface eu.cloudnetservice.node.cluster.NodeServer

lastNodeInfoSnapshot

public @UnknownNullability eu.cloudnetservice.driver.cluster.NodeInfoSnapshot lastNodeInfoSnapshot()

Specified by:

lastNodeInfoSnapshot in interface eu.cloudnetservice.node.cluster.NodeServer

updateNodeInfoSnapshot

public void updateNodeInfoSnapshot(@Nullable
 @Nullable eu.cloudnetservice.driver.cluster.NodeInfoSnapshot snapshot)

Specified by:

updateNodeInfoSnapshot in interface eu.cloudnetservice.node.cluster.NodeServer

lastNodeInfoUpdate

@NonNull
public @NonNull Instant lastNodeInfoUpdate()

Specified by:

lastNodeInfoUpdate in interface eu.cloudnetservice.node.cluster.NodeServer

serviceFactory

@NonNull
public @NonNull eu.cloudnetservice.driver.provider.CloudServiceFactory serviceFactory()

Specified by:

serviceFactory in interface eu.cloudnetservice.node.cluster.NodeServer

serviceProvider

@Nullable
public @Nullable eu.cloudnetservice.driver.provider.SpecificCloudServiceProvider serviceProvider(@NonNull
 @NonNull UUID uniqueId)

Specified by:

serviceProvider in interface eu.cloudnetservice.node.cluster.NodeServer

sendCommandLine

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

Specified by:

sendCommandLine in interface eu.cloudnetservice.node.cluster.NodeServer

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in interface eu.cloudnetservice.node.cluster.NodeServer

updateLocalSnapshot

public void updateLocalSnapshot()

Specified by:

updateLocalSnapshot in interface eu.cloudnetservice.node.cluster.LocalNodeServer