Package de.dytanic.cloudnet.cluster

Class DefaultClusterNodeServer

java.lang.Object

de.dytanic.cloudnet.cluster.DefaultNodeServer

de.dytanic.cloudnet.cluster.DefaultClusterNodeServer

All Implemented Interfaces:

IClusterNodeServer, NodeServer, de.dytanic.cloudnet.driver.api.DriverAPIUser, java.lang.AutoCloseable

public class DefaultClusterNodeServer
extends DefaultNodeServer
implements IClusterNodeServer, de.dytanic.cloudnet.driver.api.DriverAPIUser

Field Summary

Fields inherited from class de.dytanic.cloudnet.cluster.DefaultNodeServer

currentSnapshot, lastSnapshot, nodeInfo

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	DefaultClusterNodeServer(DefaultClusterNodeServerProvider provider, de.dytanic.cloudnet.driver.network.cluster.NetworkClusterNode nodeInfo)

Method Summary

Modifier and Type	Method	Description
void	close()
de.dytanic.cloudnet.driver.network.INetworkChannel	getChannel()
@NotNull de.dytanic.cloudnet.driver.provider.service.CloudServiceFactory	getCloudServiceFactory()
de.dytanic.cloudnet.driver.provider.service.SpecificCloudServiceProvider	getCloudServiceProvider(@NotNull de.dytanic.cloudnet.driver.service.ServiceInfoSnapshot serviceInfoSnapshot)
de.dytanic.cloudnet.driver.network.INetworkChannel	getNetworkChannel()
@NotNull DefaultClusterNodeServerProvider	getProvider()
boolean	isAcceptableConnection(@NotNull de.dytanic.cloudnet.driver.network.INetworkChannel channel, @NotNull java.lang.String nodeId)
boolean	isConnected()
void	saveSendPacket(@NotNull de.dytanic.cloudnet.driver.network.protocol.IPacket packet)
void	saveSendPacketSync(@NotNull de.dytanic.cloudnet.driver.network.protocol.IPacket packet)
java.lang.String[]	sendCommandLine(@NotNull java.lang.String commandLine)
void	sendCustomChannelMessage(@NotNull de.dytanic.cloudnet.driver.channel.ChannelMessage channelMessage)
void	sendCustomChannelMessage(@NotNull java.lang.String channel, @NotNull java.lang.String message, @NotNull de.dytanic.cloudnet.common.document.gson.JsonDocument data)
void	setChannel(@NotNull de.dytanic.cloudnet.driver.network.INetworkChannel channel)
void	setNodeInfoSnapshot(@NotNull de.dytanic.cloudnet.driver.network.cluster.NetworkClusterNodeInfoSnapshot nodeInfoSnapshot)

Methods inherited from class de.dytanic.cloudnet.cluster.DefaultNodeServer

getLastNodeInfoSnapshot, getNodeInfo, getNodeInfoSnapshot, isHeadNode, setNodeInfo

Methods inherited from class java.lang.Object

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

Methods inherited from interface de.dytanic.cloudnet.driver.api.DriverAPIUser

executeChunkedDriverAPIMethod, executeDriverAPIMethod, executeDriverAPIMethod, executeVoidDriverAPIMethod, executeVoidDriverAPIMethod

Methods inherited from interface de.dytanic.cloudnet.cluster.IClusterNodeServer

isAvailable

Methods inherited from interface de.dytanic.cloudnet.cluster.NodeServer

getLastNodeInfoSnapshot, getNodeInfo, getNodeInfoSnapshot, isHeadNode, setNodeInfo

Constructor Detail

DefaultClusterNodeServer

protected DefaultClusterNodeServer(DefaultClusterNodeServerProvider provider,
                                   de.dytanic.cloudnet.driver.network.cluster.NetworkClusterNode nodeInfo)

Method Detail

sendCustomChannelMessage

public void sendCustomChannelMessage(@NotNull
                                     @NotNull de.dytanic.cloudnet.driver.channel.ChannelMessage channelMessage)

Specified by:

sendCustomChannelMessage in interface IClusterNodeServer

sendCustomChannelMessage

public void sendCustomChannelMessage(@NotNull
                                     @NotNull java.lang.String channel,
                                     @NotNull
                                     @NotNull java.lang.String message,
                                     @NotNull
                                     @NotNull de.dytanic.cloudnet.common.document.gson.JsonDocument data)

Specified by:

sendCustomChannelMessage in interface IClusterNodeServer

isConnected

public boolean isConnected()

Specified by:

isConnected in interface IClusterNodeServer

saveSendPacket

public void saveSendPacket(@NotNull
                           @NotNull de.dytanic.cloudnet.driver.network.protocol.IPacket packet)

Specified by:

saveSendPacket in interface IClusterNodeServer

saveSendPacketSync

public void saveSendPacketSync(@NotNull
                               @NotNull de.dytanic.cloudnet.driver.network.protocol.IPacket packet)

Specified by:

saveSendPacketSync in interface IClusterNodeServer

isAcceptableConnection

public boolean isAcceptableConnection(@NotNull
                                      @NotNull de.dytanic.cloudnet.driver.network.INetworkChannel channel,
                                      @NotNull
                                      @NotNull java.lang.String nodeId)

Specified by:

isAcceptableConnection in interface IClusterNodeServer

sendCommandLine

public java.lang.String[] sendCommandLine(@NotNull
                                          @NotNull java.lang.String commandLine)

Specified by:

sendCommandLine in interface NodeServer

getCloudServiceFactory

@NotNull
public @NotNull de.dytanic.cloudnet.driver.provider.service.CloudServiceFactory getCloudServiceFactory()

Specified by:

getCloudServiceFactory in interface NodeServer

getCloudServiceProvider

public de.dytanic.cloudnet.driver.provider.service.SpecificCloudServiceProvider getCloudServiceProvider(@NotNull
                                                                                                        @NotNull de.dytanic.cloudnet.driver.service.ServiceInfoSnapshot serviceInfoSnapshot)

Specified by:

getCloudServiceProvider in interface NodeServer

close

public void close()
           throws java.lang.Exception

Specified by:

close in interface java.lang.AutoCloseable

Overrides:

close in class DefaultNodeServer

Throws:

java.lang.Exception

getProvider

@NotNull
public @NotNull DefaultClusterNodeServerProvider getProvider()

Specified by:

getProvider in interface IClusterNodeServer

Specified by:

getProvider in interface NodeServer

getChannel

public de.dytanic.cloudnet.driver.network.INetworkChannel getChannel()

Specified by:

getChannel in interface IClusterNodeServer

setChannel

public void setChannel(@NotNull
                       @NotNull de.dytanic.cloudnet.driver.network.INetworkChannel channel)

Specified by:

setChannel in interface IClusterNodeServer

getNetworkChannel

public de.dytanic.cloudnet.driver.network.INetworkChannel getNetworkChannel()

Specified by:

getNetworkChannel in interface de.dytanic.cloudnet.driver.api.DriverAPIUser

setNodeInfoSnapshot

public void setNodeInfoSnapshot(@NotNull
                                @NotNull de.dytanic.cloudnet.driver.network.cluster.NetworkClusterNodeInfoSnapshot nodeInfoSnapshot)

Specified by:

setNodeInfoSnapshot in interface NodeServer

Overrides:

setNodeInfoSnapshot in class DefaultNodeServer