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

Interface Worker

All Superinterfaces:
com.fishlib.base.log.LogOutputAppendable
public interface Worker
extends com.fishlib.base.log.LogOutputAppendable
Instances of a Worker interface represent Java process running a RemoteQueryProcessor The Java Process could be an Operating System process, a Docker Container or some other controlled process. Workers are created and destroyed by WorkerControl objects.

Worker instances are essentially a Data Object, with getters and setters. The attributes are parameters and settings used by the WorkerControl object that manages the lifecycle of the Worker.

  • Method Details

    • getName

      String getName()
      Returns the name of this Worker.
      Returns:
      the name of this Worker

    • getId

      String getId()
      Returns the id of this Worker
      Returns:
      the id of this Worker

    • getClientConnectionPort

      int getClientConnectionPort()
      Returns the clientConnectionPort of this Worker
      Returns:
      the clientConnectionPort of this Worker

    • getUserName

      String getUserName()
      Returns the userName of this Worker
      Returns:
      the userName of this Worker

    • getClientClassDirectory

      File getClientClassDirectory()
      Returns the clientClassDirectory of this Worker
      Returns:
      the clientClassDirectory of this Worker.

    • getRemoteProcessingRequest

      RemoteProcessingRequest getRemoteProcessingRequest()
      Returns the remoteProcessingRequest of this Worker
      Returns:
      the remoteProcessingRequest of this Worker.

    • getHeapSizeMB

      int getHeapSizeMB()
      Returns the heapSizeMB of this Worker
      Returns:
      the heapSizeMB of this Worker.

    • getPort

      int getPort()
      Returns the port of this Worker
      Returns:
      the port of this Worker

    • getClientConnectionAddress

      String getClientConnectionAddress()
      Returns the client connection address this Worker, which could be a hostname, IP, FQDN, service name, endpoint, etc. Clients will connect to the the Worker via ClientConnectionAddress:Port
      Returns:
      the clientConnectionAddress of this Worker

    • setPort

      void setPort​(int port)
      Set the port for this worker
      Parameters:
      port - the port for this worker

    • getPid

      int getPid()
      Returns the pid of this Worker
      Returns:
      the pid of this Worker

    • getClientEntry

      com.fishlib.net.api.ClientEntry getClientEntry()
      Returns the clientEntry of this Worker
      Returns:
      the clientEntry of this Worker

    • setClientEntry

      void setClientEntry​(com.fishlib.net.api.ClientEntry clientEntry)
      Set the clientEntry for this worker
      Parameters:
      clientEntry - for this worker

    • isFinished

      boolean isFinished()
      Returns the isFinished status of this Worker
      Returns:
      the isFinished status of this Worker

    • getCompiledClassDirectory

      File getCompiledClassDirectory()
      Returns the compiledClassDirectory of this Worker
      Returns:
      the compiledClassDirectory of this Worker

    • getArtifactDirectory

      File getArtifactDirectory()
      Returns the artifactDirectory of this Worker
      Returns:
      the artifactDirectory of this Worker

    • getUserContext

      com.fishlib.auth.UserContext getUserContext()
      Returns the userContext of this Worker
      Returns:
      the userContext of this Worker

    • getCancelledTimeNS

      long getCancelledTimeNS()
      Returns the cancelledTimeNS of this Worker
      Returns:
      the cancelledTimeNS of this Worker

    • setCancelledTimeNS

      void setCancelledTimeNS​(long cancelledTimeNS)
      Set the cancelledTimeNS for this worker
      Parameters:
      cancelledTimeNS - the port for this worker

    • isTerminateRequestSent

      boolean isTerminateRequestSent()
      Returns the isTerminateRequestSent status of this Worker
      Returns:
      the isTerminateRequestSent status of this Worker

    • setTerminateRequestSent

      void setTerminateRequestSent​(boolean terminateRequestSent)
      Set the terminateRequestSent for this worker
      Parameters:
      terminateRequestSent - status for this worker

    • isJvmDestroySent

      boolean isJvmDestroySent()
      Returns the isJvmDestroySent status of this Worker
      Returns:
      the isJvmDestroySent status of this Worker

    • setJvmDestroySent

      void setJvmDestroySent​(boolean jvmDestroySent)
      Sets the jvmDestroySent status of this Worker
      Parameters:
      jvmDestroySent - status of this Worker

    • getProcessEventLogLogger

      ProcessEventLogFormat1Logger getProcessEventLogLogger()
      Returns the processEventLogLogger of this Worker
      Returns:
      the processEventLogLogger of this Worker

    • getDispatcherHostName

      String getDispatcherHostName()
      Returns the dispatcherHostName of this Worker
      Returns:
      the dispatcherHostName of this Worker

    • getWebsocketPort

      int getWebsocketPort()
      Returns the port that this worker is listening on for incoming websocket connections
      Returns:
      the port that this worker is listening on for incoming websocket connections

    • getLatestErrorMessages

      List<String> getLatestErrorMessages()
      Returns the last few lines captured from the worker's syserr.
      Returns:
      the last few lines from the worker's syserr