Package com.illumon.iris.db.tables.remotequery

Class QueryProcessorConnectionDetails

java.lang.Object
com.illumon.iris.db.tables.remotequery.QueryProcessorConnectionDetails
All Implemented Interfaces:
com.fishlib.base.log.LogOutputAppendable, Serializable
public class QueryProcessorConnectionDetails extends Object implements com.fishlib.base.log.LogOutputAppendable, Serializable
Class for communicating from the dispatcher to the client how to connect to the worker.
See Also:

  • Field Details

  • Constructor Details

    • QueryProcessorConnectionDetails

      public QueryProcessorConnectionDetails()

  • Method Details

    • getWorkerName

      public String getWorkerName()

    • getProcessInfoId

      public String getProcessInfoId()

    • getProcessorHost

      public String getProcessorHost()

    • getEnvoyPrefix

      public String getEnvoyPrefix()

    • getCommunityGrpcUrl

      public String getCommunityGrpcUrl()

    • getCommunityStaticUrl

      public String getCommunityStaticUrl()

    • getEnterpriseWebSocketUrl

      public String getEnterpriseWebSocketUrl()

    • getProtocols

      public List<io.deephaven.enterprise.dispatcher.client.WorkerProtocol> getProtocols()

    • setWorkerName

      public QueryProcessorConnectionDetails setWorkerName(String workerName)

    • setProcessInfoId

      public QueryProcessorConnectionDetails setProcessInfoId(String processInfoId)

    • setProcessorHost

      public QueryProcessorConnectionDetails setProcessorHost(String processorHost)

    • setEnvoyPrefix

      public QueryProcessorConnectionDetails setEnvoyPrefix(String envoyPrefix)

    • setProtocols

      public QueryProcessorConnectionDetails setProtocols(List<io.deephaven.enterprise.dispatcher.client.WorkerProtocol> protocols)

    • setCommunityGrpcUrl

      public QueryProcessorConnectionDetails setCommunityGrpcUrl(String communityGrpcUrl)

    • setCommunityStaticUrl

      public QueryProcessorConnectionDetails setCommunityStaticUrl(String communityStaticUrl)

    • setEnterpriseWebSocketUrl

      public QueryProcessorConnectionDetails setEnterpriseWebSocketUrl(String enterpriseWebSocketUrl)

    • getPort

      public final OptionalInt getPort(String protocol)

    • equals

      public boolean equals(Object o)
      Overrides:
      equals in class Object

    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class Object

    • fromJson

      public static QueryProcessorConnectionDetails fromJson(String json) throws io.deephaven.shadow.jackson.com.fasterxml.jackson.core.JsonProcessingException
      Throws:
      io.deephaven.shadow.jackson.com.fasterxml.jackson.core.JsonProcessingException

    • asJson

      public String asJson() throws io.deephaven.shadow.jackson.com.fasterxml.jackson.core.JsonProcessingException
      Throws:
      io.deephaven.shadow.jackson.com.fasterxml.jackson.core.JsonProcessingException

    • toString

      public String toString()
      Overrides:
      toString in class Object

    • append

      public com.fishlib.base.log.LogOutput append(com.fishlib.base.log.LogOutput logOutput)
      Specified by:
      append in interface com.fishlib.base.log.LogOutputAppendable