Interface IClusterNodeServer

  • All Superinterfaces:
    java.lang.AutoCloseable
    All Known Implementing Classes:
    DefaultClusterNodeServer

    public interface IClusterNodeServer
    extends java.lang.AutoCloseable
    • Method Detail

      • sendClusterChannelMessage

        void sendClusterChannelMessage​(java.lang.String channel,
                                       java.lang.String message,
                                       JsonDocument header,
                                       byte[] body)
      • sendCustomChannelMessage

        void sendCustomChannelMessage​(java.lang.String channel,
                                      java.lang.String message,
                                      JsonDocument data)
      • isConnected

        boolean isConnected()
      • saveSendPacket

        void saveSendPacket​(IPacket packet)
      • isAcceptableConnection

        boolean isAcceptableConnection​(INetworkChannel channel,
                                       java.lang.String nodeId)
      • sendCommandLine

        java.lang.String[] sendCommandLine​(java.lang.String commandLine)
      • deployTemplateInCluster

        void deployTemplateInCluster​(ServiceTemplate serviceTemplate,
                                     byte[] zipResource)
      • createCloudService

        java.util.Collection<ServiceInfoSnapshot> createCloudService​(java.lang.String nodeUniqueId,
                                                                     int amount,
                                                                     java.lang.String name,
                                                                     java.lang.String runtime,
                                                                     boolean autoDeleteOnStop,
                                                                     boolean staticService,
                                                                     java.util.Collection<ServiceRemoteInclusion> includes,
                                                                     java.util.Collection<ServiceTemplate> templates,
                                                                     java.util.Collection<ServiceDeployment> deployments,
                                                                     java.util.Collection<java.lang.String> groups,
                                                                     ProcessConfiguration processConfiguration,
                                                                     JsonDocument properties,
                                                                     java.lang.Integer port)
      • createCloudService

        default java.util.Collection<ServiceInfoSnapshot> createCloudService​(java.lang.String nodeUniqueId,
                                                                             int amount,
                                                                             java.lang.String name,
                                                                             java.lang.String runtime,
                                                                             boolean autoDeleteOnStop,
                                                                             boolean staticService,
                                                                             java.util.Collection<ServiceRemoteInclusion> includes,
                                                                             java.util.Collection<ServiceTemplate> templates,
                                                                             java.util.Collection<ServiceDeployment> deployments,
                                                                             java.util.Collection<java.lang.String> groups,
                                                                             ProcessConfiguration processConfiguration,
                                                                             java.lang.Integer port)
      • sendCommandLineToCloudService

        ServiceInfoSnapshot sendCommandLineToCloudService​(java.util.UUID uniqueId,
                                                          java.lang.String commandLine)
      • getCachedLogMessagesFromService

        java.util.Queue<java.lang.String> getCachedLogMessagesFromService​(java.util.UUID uniqueId)
      • runCommand

        void runCommand​(ServiceInfoSnapshot serviceInfoSnapshot,
                        java.lang.String command)
      • includeWaitingServiceInclusions

        void includeWaitingServiceInclusions​(java.util.UUID uniqueId)
      • includeWaitingServiceTemplates

        void includeWaitingServiceTemplates​(java.util.UUID uniqueId)
      • deployResources

        void deployResources​(java.util.UUID uniqueId,
                             boolean removeDeployments)
      • deployResources

        default void deployResources​(java.util.UUID uniqueId)