java.lang.Object
- de.dytanic.cloudnet.driver.CloudNetDriver
- - de.dytanic.cloudnet.CloudNet

public final class CloudNet
extends CloudNetDriver

Field Summary

Fields
Modifier and Type	Field	Description
`private CloudServiceFactory`	`cloudServiceFactory`
`private ICloudServiceManager`	`cloudServiceManager`
`private IClusterNodeServerProvider`	`clusterNodeServerProvider`
`private java.util.List<java.lang.String>`	`commandLineArguments`
`private Properties`	`commandLineProperties`
`private ICommandMap`	`commandMap`
`private IConfiguration`	`config`
`private IConfigurationRegistry`	`configurationRegistry`
`private IConsole`	`console`
`private ConsoleCommandSender`	`consoleCommandSender`
`private NetworkClusterNodeInfoSnapshot`	`currentNetworkClusterNodeInfoSnapshot`
`private AbstractDatabaseProvider`	`databaseProvider`
`private DefaultInstallation`	`defaultInstallation`
`private GeneralCloudServiceProvider`	`generalCloudServiceProvider`
`private GroupConfigurationProvider`	`groupConfigurationProvider`
`private IHttpServer`	`httpServer`
`private static CloudNet`	`instance`
`private NetworkClusterNodeInfoSnapshot`	`lastNetworkClusterNodeInfoSnapshot`
`private CloudMessenger`	`messenger`
`private java.io.File`	`moduleDirectory`
`private INetworkClient`	`networkClient`
`private INetworkServer`	`networkServer`
`private ITaskScheduler`	`networkTaskScheduler`
`private NodeInfoProvider`	`nodeInfoProvider`
`private IPermissionManagement`	`permissionManagement`
`private PermissionProvider`	`permissionProvider`
`private java.util.Queue<ITask<?>>`	`processQueue`
`private QueuedConsoleLogHandler`	`queuedConsoleLogHandler`
`static boolean`	`RUNNING`
`private ServiceTaskProvider`	`serviceTaskProvider`
`static int`	`TPS`

Fields inherited from class de.dytanic.cloudnet.driver.CloudNetDriver
driverEnvironment, eventManager, logger, moduleProvider, packetQueryProvider, servicesRegistry, taskScheduler

Constructor Summary

Constructors
Constructor Description

CloudNet(java.util.List<java.lang.String> commandLineArguments, ILogger logger, IConsole console)

Method Summary

All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`private java.util.Map<java.lang.String,java.util.Map<java.lang.String,JsonDocument>>`	`allocateDatabaseData()`
`boolean`	`competeWithCluster(ServiceTask serviceTask)`
`NetworkClusterNodeInfoSnapshot`	`createClusterNodeInfoSnapshot()`
`void`	`deployTemplateInCluster(ServiceTemplate serviceTemplate, byte[] resource)`
`private void`	`enableCommandCompleter()`
`private void`	`enableModules()`
`ServiceInfoSnapshot`	`getCloudServiceByNameOrUniqueId(java.lang.String argument)`
`CloudServiceFactory`	`getCloudServiceFactory()`
`ICloudServiceManager`	`getCloudServiceManager()`
`GeneralCloudServiceProvider`	`getCloudServiceProvider()`	Returns the general CloudServiceProvider
`SpecificCloudServiceProvider`	`getCloudServiceProvider(ServiceInfoSnapshot serviceInfoSnapshot)`	Returns a new service specific CloudServiceProvider
`SpecificCloudServiceProvider`	`getCloudServiceProvider(java.lang.String name)`	Returns a new service specific CloudServiceProvider
`SpecificCloudServiceProvider`	`getCloudServiceProvider(java.util.UUID uniqueId)`	Returns a new service specific CloudServiceProvider
`IClusterNodeServerProvider`	`getClusterNodeServerProvider()`
`java.util.List<java.lang.String>`	`getCommandLineArguments()`
`Properties`	`getCommandLineProperties()`
`ICommandMap`	`getCommandMap()`
`IConfiguration`	`getConfig()`
`IConfigurationRegistry`	`getConfigurationRegistry()`
`IConsole`	`getConsole()`
`ConsoleCommandSender`	`getConsoleCommandSender()`
`NetworkClusterNodeInfoSnapshot`	`getCurrentNetworkClusterNodeInfoSnapshot()`
`AbstractDatabaseProvider`	`getDatabaseProvider()`
`GroupConfigurationProvider`	`getGroupConfigurationProvider()`
`IHttpServer`	`getHttpServer()`
`static CloudNet`	`getInstance()`
`NetworkClusterNodeInfoSnapshot`	`getLastNetworkClusterNodeInfoSnapshot()`
`java.util.Collection<ServiceTemplate>`	`getLocalTemplateStorageTemplates()`
`ITask<java.util.Collection<ServiceTemplate>>`	`getLocalTemplateStorageTemplatesAsync()`
`CloudMessenger`	`getMessenger()`
`java.io.File`	`getModuleDirectory()`
`INetworkClient`	`getNetworkClient()`
`INetworkServer`	`getNetworkServer()`
`ITaskScheduler`	`getNetworkTaskScheduler()`
`NodeInfoProvider`	`getNodeInfoProvider()`
`IPermissionManagement`	`getPermissionManagement()`
`PermissionProvider`	`getPermissionProvider()`
`QueuedConsoleLogHandler`	`getQueuedConsoleLogHandler()`
`ServiceTaskProvider`	`getServiceTaskProvider()`
`java.util.Collection<ServiceTemplate>`	`getTemplateStorageTemplates(java.lang.String serviceName)`
`ITask<java.util.Collection<ServiceTemplate>>`	`getTemplateStorageTemplatesAsync(java.lang.String serviceName)`
`java.util.Collection<IClusterNodeServer>`	`getValidClusterNodeServers(ServiceTask serviceTask)`
`private void`	`initPacketRegistryListeners()`
`boolean`	`isMainThread()`
`private void`	`launchServices()`
`private void`	`loadModules()`
`private void`	`mainloop()`
`void`	`publishH2DatabaseDataToCluster(INetworkChannel channel)`
`void`	`publishNetworkClusterNodeInfoSnapshotUpdate()`
`void`	`publishPermissionGroupUpdates(java.util.Collection<IPermissionGroup> permissionGroups, NetworkUpdateType updateType)`
`private void`	`registerDefaultCommands()`
`private void`	`registerDefaultServices()`
`void`	`reload()`
`private void`	`runConsole()`
`ITask<?>`	`runTask(java.lang.Runnable runnable)`
`<T> ITask<T>`	`runTask(java.util.concurrent.Callable<T> runnable)`
`<T> ITask<T>`	`scheduleTask(java.util.concurrent.Callable<T> callable)`
`NetworkClusterNodeInfoSnapshot`	`searchLogicNode(ServiceTask serviceTask)`
`void`	`sendAll(IPacket packet)`
`void`	`sendAll(IPacket... packets)`
`ITask<java.lang.Void>`	`sendAllAsync(IPacket packet)`
`ITask<java.lang.Void>`	`sendAllAsync(IPacket... packets)`
`Pair<java.lang.Boolean,java.lang.String[]>`	`sendCommandLineAsPermissionUser(java.util.UUID uniqueId, java.lang.String commandLine)`
`ITask<Pair<java.lang.Boolean,java.lang.String[]>>`	`sendCommandLineAsPermissionUserAsync(java.util.UUID uniqueId, java.lang.String commandLine)`
`private void`	`sendNodeUpdate()`
`private void`	`setDefaultRegistryEntries()`
`private void`	`setNetworkListeners()`
`void`	`start()`
`private void`	`startModules()`
`void`	`stop()`
`private void`	`stopDeadServices()`
`private void`	`unloadAll()`
`private void`	`unloadAllModules0()`
`private void`	`unloadModule(IModuleWrapper moduleWrapper)`
`private void`	`unloadModules()`
`void`	`unregisterPacketListenersByClassLoader(java.lang.ClassLoader classLoader)`
`void`	`updateGroupConfigurationsInCluster(java.util.Collection<GroupConfiguration> groupConfigurations, NetworkUpdateType updateType)`
`private void`	`updateServiceLogs()`
`void`	`updateServiceTasksInCluster(java.util.Collection<ServiceTask> serviceTasks, NetworkUpdateType updateType)`

Methods inherited from class de.dytanic.cloudnet.driver.CloudNetDriver
addGroup, addGroupConfiguration, addPermanentServiceTask, addServiceDeploymentToCloudService, addServiceDeploymentToCloudServiceAsync, addServiceRemoteInclusionToCloudService, addServiceRemoteInclusionToCloudServiceAsync, addServiceTemplateToCloudService, addServiceTemplateToCloudServiceAsync, addUser, addUserAsync, containsGroup, containsGroupAsync, containsUser, containsUser, containsUserAsync, containsUserAsync, createCloudService, createCloudService, createCloudService, createCloudService, createCloudService, createCloudService, createCloudServiceAsync, createCloudServiceAsync, createCloudServiceAsync, createCloudServiceAsync, createCloudServiceAsync, createCloudServiceAsync, deleteCloudService, deleteGroup, deleteGroup, deleteUser, deleteUser, deployResources, deployResources, getCachedLogMessagesFromService, getCachedLogMessagesFromServiceAsync, getCloudService, getCloudService, getCloudServiceByGroup, getCloudServiceByName, getCloudServiceByNameAsync, getCloudServices, getCloudServices, getCloudServicesAsync, getCloudServicesAsync, getCloudServicesAsync, getCloudServicesAsync, getCloudServicesByGroupAsync, getConsoleCommand, getConsoleCommandAsync, getConsoleCommands, getConsoleCommandsAsync, getDriverEnvironment, getEventManager, getGroup, getGroupAsync, getGroupConfiguration, getGroupConfigurationAsync, getGroupConfigurations, getGroupConfigurationsAsync, getGroups, getGroupsAsync, getLogger, getModuleProvider, getNode, getNodeAsync, getNodeInfoSnapshot, getNodeInfoSnapshotAsync, getNodeInfoSnapshots, getNodeInfoSnapshotsAsync, getNodes, getNodesAsync, getPacketQueryProvider, getPermanentServiceTasks, getPermanentServiceTasksAsync, getServicesAsUniqueId, getServicesAsUniqueIdAsync, getServicesCount, getServicesCountAsync, getServicesCountByGroup, getServicesCountByGroupAsync, getServicesCountByTask, getServicesCountByTaskAsync, getServicesRegistry, getServiceTask, getServiceTaskAsync, getStartedCloudServiceInfoSnapshotsAsync, getStartedCloudServices, getTaskScheduler, getUser, getUser, getUserAsync, getUserAsync, getUserByGroup, getUserByGroupAsync, getUsers, getUsersAsync, includeWaitingServiceInclusions, includeWaitingServiceTemplates, isGroupConfigurationPresent, isGroupConfigurationPresentAsync, isServiceTaskPresent, isServiceTaskPresentAsync, killCloudService, removeGroupConfiguration, removeGroupConfiguration, removePermanentServiceTask, removePermanentServiceTask, restartCloudService, runCommand, sendCallablePacket, sendCallablePacket, sendCallablePacketWithAsDriverSyncAPI, sendCallablePacketWithAsDriverSyncAPIWithNetworkConnector, sendChannelMessage, sendChannelMessage, sendChannelMessage, sendCommandLine, sendCommandLine, sendCommandLineAsync, sendCommandLineAsync, sendCommandLineToCloudService, sendCommandLineToCloudServiceAsync, setCloudServiceLifeCycle, setGroups, setInstance, setUsers, startCloudService, stopCloudService, updateGroup, updateUser

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

TPS
```
public static final int TPS
```
See Also:

Constant Field Values

RUNNING
```
public static volatile boolean RUNNING
```

instance
```
private static CloudNet instance
```

commandMap
```
private final ICommandMap commandMap
```

moduleDirectory

private final java.io.File moduleDirectory

config
```
private final IConfiguration config
```

configurationRegistry

private final IConfigurationRegistry configurationRegistry

cloudServiceManager

private final ICloudServiceManager cloudServiceManager

clusterNodeServerProvider

private final IClusterNodeServerProvider clusterNodeServerProvider

networkTaskScheduler

private final ITaskScheduler networkTaskScheduler

commandLineArguments

private final java.util.List<java.lang.String> commandLineArguments

commandLineProperties

private final Properties commandLineProperties

console
```
private final IConsole console
```

queuedConsoleLogHandler

private final QueuedConsoleLogHandler queuedConsoleLogHandler

consoleCommandSender

private final ConsoleCommandSender consoleCommandSender

processQueue

private final java.util.Queue<ITask<?>> processQueue

networkClient
```
private INetworkClient networkClient
```

networkServer
```
private INetworkServer networkServer
```

httpServer
```
private IHttpServer httpServer
```

permissionManagement

private IPermissionManagement permissionManagement

cloudServiceFactory

private CloudServiceFactory cloudServiceFactory

generalCloudServiceProvider

private GeneralCloudServiceProvider generalCloudServiceProvider

serviceTaskProvider

private ServiceTaskProvider serviceTaskProvider

groupConfigurationProvider

private GroupConfigurationProvider groupConfigurationProvider

permissionProvider

private PermissionProvider permissionProvider

nodeInfoProvider

private NodeInfoProvider nodeInfoProvider

messenger
```
private CloudMessenger messenger
```

defaultInstallation

private DefaultInstallation defaultInstallation

databaseProvider

private AbstractDatabaseProvider databaseProvider

lastNetworkClusterNodeInfoSnapshot

private volatile NetworkClusterNodeInfoSnapshot lastNetworkClusterNodeInfoSnapshot

currentNetworkClusterNodeInfoSnapshot

private volatile NetworkClusterNodeInfoSnapshot currentNetworkClusterNodeInfoSnapshot

Constructor Detail

CloudNet

CloudNet(java.util.List<java.lang.String> commandLineArguments,
         ILogger logger,
         IConsole console)

Method Detail

getInstance
```
public static CloudNet getInstance()
```

start
```
public void start()
           throws java.lang.Exception
```
Specified by:

start in class CloudNetDriver

Throws:

java.lang.Exception

setNetworkListeners
```
private void setNetworkListeners()
```

reload
```
public void reload()
```

stop
```
public void stop()
```
Specified by:

stop in class CloudNetDriver

getPermissionProvider
```
public PermissionProvider getPermissionProvider()
```
Specified by:

getPermissionProvider in class CloudNetDriver

getCloudServiceFactory
```
public CloudServiceFactory getCloudServiceFactory()
```
Specified by:

getCloudServiceFactory in class CloudNetDriver

getServiceTaskProvider
```
public ServiceTaskProvider getServiceTaskProvider()
```
Specified by:

getServiceTaskProvider in class CloudNetDriver

getNodeInfoProvider
```
public NodeInfoProvider getNodeInfoProvider()
```
Specified by:

getNodeInfoProvider in class CloudNetDriver

getGroupConfigurationProvider
```
public GroupConfigurationProvider getGroupConfigurationProvider()
```
Specified by:

getGroupConfigurationProvider in class CloudNetDriver

getCloudServiceProvider
```
public SpecificCloudServiceProvider getCloudServiceProvider(java.lang.String name)
```
Description copied from class: CloudNetDriver

Returns a new service specific CloudServiceProvider

Specified by:

getCloudServiceProvider in class CloudNetDriver

Parameters:

name - the name of the service

Returns:

the new instance of the SpecificCloudServiceProvider

getCloudServiceProvider
```
public SpecificCloudServiceProvider getCloudServiceProvider(java.util.UUID uniqueId)
```
Description copied from class: CloudNetDriver

Returns a new service specific CloudServiceProvider

Specified by:

getCloudServiceProvider in class CloudNetDriver

Parameters:

uniqueId - the uniqueId of the service

Returns:

the new instance of the SpecificCloudServiceProvider

getCloudServiceProvider
```
public SpecificCloudServiceProvider getCloudServiceProvider(ServiceInfoSnapshot serviceInfoSnapshot)
```
Description copied from class: CloudNetDriver

Returns a new service specific CloudServiceProvider

Specified by:

getCloudServiceProvider in class CloudNetDriver

Parameters:

serviceInfoSnapshot - the info of the service to create a provider for

Returns:

the new instance of the SpecificCloudServiceProvider

getCloudServiceProvider
```
public GeneralCloudServiceProvider getCloudServiceProvider()
```
Description copied from class: CloudNetDriver

Returns the general CloudServiceProvider

Specified by:

getCloudServiceProvider in class CloudNetDriver

Returns:

the instance of the GeneralCloudServiceProvider

getMessenger
```
public CloudMessenger getMessenger()
```
Specified by:

getMessenger in class CloudNetDriver

getCloudServiceByNameOrUniqueId

public ServiceInfoSnapshot getCloudServiceByNameOrUniqueId(java.lang.String argument)

getLocalTemplateStorageTemplates
```
public java.util.Collection<ServiceTemplate> getLocalTemplateStorageTemplates()
```
Specified by:

getLocalTemplateStorageTemplates in class CloudNetDriver

getTemplateStorageTemplates

public java.util.Collection<ServiceTemplate> getTemplateStorageTemplates(java.lang.String serviceName)

Specified by:: getTemplateStorageTemplates in class CloudNetDriver

sendCommandLineAsPermissionUser

public Pair<java.lang.Boolean,java.lang.String[]> sendCommandLineAsPermissionUser(java.util.UUID uniqueId,
                                                                                        java.lang.String commandLine)

Specified by:: sendCommandLineAsPermissionUser in class CloudNetDriver

getLocalTemplateStorageTemplatesAsync
```
public ITask<java.util.Collection<ServiceTemplate>> getLocalTemplateStorageTemplatesAsync()
```
Specified by:

getLocalTemplateStorageTemplatesAsync in class CloudNetDriver

getTemplateStorageTemplatesAsync

public ITask<java.util.Collection<ServiceTemplate>> getTemplateStorageTemplatesAsync(java.lang.String serviceName)

Specified by:: getTemplateStorageTemplatesAsync in class CloudNetDriver

sendCommandLineAsPermissionUserAsync

public ITask<Pair<java.lang.Boolean,java.lang.String[]>> sendCommandLineAsPermissionUserAsync(java.util.UUID uniqueId,
                                                                                                    java.lang.String commandLine)

Specified by:: sendCommandLineAsPermissionUserAsync in class CloudNetDriver

runTask

public <T> ITask<T> runTask(java.util.concurrent.Callable<T> runnable)

runTask

public ITask<?> runTask(java.lang.Runnable runnable)

isMainThread
```
public boolean isMainThread()
```

deployTemplateInCluster

public void deployTemplateInCluster(ServiceTemplate serviceTemplate,
                                    byte[] resource)

updateServiceTasksInCluster

public void updateServiceTasksInCluster(java.util.Collection<ServiceTask> serviceTasks,
                                        NetworkUpdateType updateType)

updateGroupConfigurationsInCluster

public void updateGroupConfigurationsInCluster(java.util.Collection<GroupConfiguration> groupConfigurations,
                                               NetworkUpdateType updateType)

sendAllAsync

public ITask<java.lang.Void> sendAllAsync(IPacket packet)

sendAll

public void sendAll(IPacket packet)

sendAllAsync

public ITask<java.lang.Void> sendAllAsync(IPacket... packets)

sendAll

public void sendAll(IPacket... packets)

createClusterNodeInfoSnapshot

public NetworkClusterNodeInfoSnapshot createClusterNodeInfoSnapshot()

getValidClusterNodeServers

public java.util.Collection<IClusterNodeServer> getValidClusterNodeServers(ServiceTask serviceTask)

searchLogicNode

public NetworkClusterNodeInfoSnapshot searchLogicNode(ServiceTask serviceTask)

competeWithCluster

public boolean competeWithCluster(ServiceTask serviceTask)

unregisterPacketListenersByClassLoader

public void unregisterPacketListenersByClassLoader(java.lang.ClassLoader classLoader)

publishNetworkClusterNodeInfoSnapshotUpdate

public void publishNetworkClusterNodeInfoSnapshotUpdate()

publishPermissionGroupUpdates

public void publishPermissionGroupUpdates(java.util.Collection<IPermissionGroup> permissionGroups,
                                          NetworkUpdateType updateType)

publishH2DatabaseDataToCluster

public void publishH2DatabaseDataToCluster(INetworkChannel channel)

allocateDatabaseData

private java.util.Map<java.lang.String,java.util.Map<java.lang.String,JsonDocument>> allocateDatabaseData()

initPacketRegistryListeners

private void initPacketRegistryListeners()

mainloop
```
private void mainloop()
```

launchServices
```
private void launchServices()
```

stopDeadServices
```
private void stopDeadServices()
```

sendNodeUpdate
```
private void sendNodeUpdate()
```

updateServiceLogs
```
private void updateServiceLogs()
```

unloadAll
```
private void unloadAll()
```

unloadModules
```
private void unloadModules()
```

unloadAllModules0
```
private void unloadAllModules0()
```

unloadModule

private void unloadModule(IModuleWrapper moduleWrapper)

registerDefaultCommands

private void registerDefaultCommands()

scheduleTask

public <T> ITask<T> scheduleTask(java.util.concurrent.Callable<T> callable)

enableModules
```
private void enableModules()
```

loadModules
```
private void loadModules()
```

startModules
```
private void startModules()
```

enableCommandCompleter
```
private void enableCommandCompleter()
```

setDefaultRegistryEntries

private void setDefaultRegistryEntries()

registerDefaultServices

private void registerDefaultServices()

runConsole
```
private void runConsole()
```

getCommandMap
```
public ICommandMap getCommandMap()
```

getModuleDirectory

public java.io.File getModuleDirectory()

getConfig
```
public IConfiguration getConfig()
```

getConfigurationRegistry

public IConfigurationRegistry getConfigurationRegistry()

getCloudServiceManager

public ICloudServiceManager getCloudServiceManager()

getClusterNodeServerProvider

public IClusterNodeServerProvider getClusterNodeServerProvider()

getNetworkTaskScheduler

public ITaskScheduler getNetworkTaskScheduler()

getCommandLineArguments

public java.util.List<java.lang.String> getCommandLineArguments()

getCommandLineProperties

public Properties getCommandLineProperties()

getConsole
```
public IConsole getConsole()
```

getQueuedConsoleLogHandler

public QueuedConsoleLogHandler getQueuedConsoleLogHandler()

getConsoleCommandSender

public ConsoleCommandSender getConsoleCommandSender()

getNetworkClient
```
public INetworkClient getNetworkClient()
```
Specified by:

getNetworkClient in class CloudNetDriver

getNetworkServer

public INetworkServer getNetworkServer()

getHttpServer
```
public IHttpServer getHttpServer()
```

getPermissionManagement

public IPermissionManagement getPermissionManagement()

getDatabaseProvider

public AbstractDatabaseProvider getDatabaseProvider()

getLastNetworkClusterNodeInfoSnapshot

public NetworkClusterNodeInfoSnapshot getLastNetworkClusterNodeInfoSnapshot()

getCurrentNetworkClusterNodeInfoSnapshot

public NetworkClusterNodeInfoSnapshot getCurrentNetworkClusterNodeInfoSnapshot()

Class CloudNet

Field Summary

Fields inherited from class de.dytanic.cloudnet.driver.CloudNetDriver

Constructor Summary

Method Summary

Methods inherited from class de.dytanic.cloudnet.driver.CloudNetDriver

Methods inherited from class java.lang.Object

Field Detail

TPS

RUNNING

instance

commandMap

moduleDirectory

config

configurationRegistry

cloudServiceManager

clusterNodeServerProvider

networkTaskScheduler

commandLineArguments

commandLineProperties

console

queuedConsoleLogHandler

consoleCommandSender

processQueue

networkClient

networkServer

httpServer

permissionManagement

cloudServiceFactory

generalCloudServiceProvider

serviceTaskProvider

groupConfigurationProvider

permissionProvider

nodeInfoProvider

messenger

defaultInstallation

databaseProvider

lastNetworkClusterNodeInfoSnapshot

currentNetworkClusterNodeInfoSnapshot

Constructor Detail

CloudNet

Method Detail

getInstance

start

setNetworkListeners

reload

stop

getPermissionProvider

getCloudServiceFactory

getServiceTaskProvider

getNodeInfoProvider

getGroupConfigurationProvider

getCloudServiceProvider

getCloudServiceProvider

getCloudServiceProvider

getCloudServiceProvider

getMessenger

getCloudServiceByNameOrUniqueId

getLocalTemplateStorageTemplates

getTemplateStorageTemplates

sendCommandLineAsPermissionUser

getLocalTemplateStorageTemplatesAsync

getTemplateStorageTemplatesAsync

sendCommandLineAsPermissionUserAsync

runTask

runTask

isMainThread

deployTemplateInCluster

updateServiceTasksInCluster

updateGroupConfigurationsInCluster

sendAllAsync

sendAll

sendAllAsync

sendAll

createClusterNodeInfoSnapshot

getValidClusterNodeServers

searchLogicNode

competeWithCluster

unregisterPacketListenersByClassLoader

publishNetworkClusterNodeInfoSnapshotUpdate