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

Interface KeepAliveWorker

All Known Subinterfaces:
Worker
public interface KeepAliveWorker
Represents a worker that is being managed by a lease handler and status servlet. Unlike the more fully featured dispatcher worker, this is intended only to track the worker not to manage the worker's process/container or other "physical" instantiation.

  • Method Summary

    Modifier and Type
    Method
    Description
    io.deephaven.enterprise.dispatcher.client.DispatcherClientConstants.PostedWorkerStatus
    getLastPostedStatus()
    Returns the last posted status for this Worker; Note it can be null if no status posted yet.
    String
    getName()
    Returns the name of this Worker.
    String
    getProcessInfoId()
    Returns the unique id of this Worker process
    long
    getTimeToLiveExpiration()
    Return the worker's TTL expiration (in millis since the epoch).
    String
    getWorkerNonce()
    Returns the nonce for registering this worker process
    boolean
    isFinished()
    Returns the isFinished status of this Worker
    boolean
    isRegistered()
    Returns true if this worker is registered.
    void
    setLastPostedStatus(io.deephaven.enterprise.dispatcher.client.DispatcherClientConstants.PostedWorkerStatus lastPostedStatus)
    Set the last posted status for this Worker
    void
    setTimeToLive(long ttl)
    Set the time to live (in millis since the epoch).

  • Method Details

    • getProcessInfoId

      String getProcessInfoId()
      Returns the unique id of this Worker process
      Returns:
      the unique id of this Worker process

    • getWorkerNonce

      String getWorkerNonce()
      Returns the nonce for registering this worker process
      Returns:
      the nonce used for registration

    • getName

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

    • isFinished

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

    • isRegistered

      boolean isRegistered()
      Returns true if this worker is registered.

    • getTimeToLiveExpiration

      long getTimeToLiveExpiration()
      Return the worker's TTL expiration (in millis since the epoch).
      Returns:
      the maximum time that the worker has renewed it's TTL

    • setTimeToLive

      void setTimeToLive(long ttl)
      Set the time to live (in millis since the epoch).

    • getLastPostedStatus

      io.deephaven.enterprise.dispatcher.client.DispatcherClientConstants.PostedWorkerStatus getLastPostedStatus()
      Returns the last posted status for this Worker; Note it can be null if no status posted yet.
      Returns:
      the last posted status for this Worker

    • setLastPostedStatus

      void setLastPostedStatus(io.deephaven.enterprise.dispatcher.client.DispatcherClientConstants.PostedWorkerStatus lastPostedStatus)
      Set the last posted status for this Worker