Package com.illumon.iris.controller.service

Class ClientStateManager.ClientState

java.lang.Object
com.illumon.iris.controller.service.ClientStateManager.ClientState
All Implemented Interfaces:
com.fishlib.base.log.LogOutputAppendable
Enclosing class:
ClientStateManager
public static final class ClientStateManager.ClientState extends Object implements com.fishlib.base.log.LogOutputAppendable

  • Method Details

    • updateRefreshDeadline

      public void updateRefreshDeadline()

    • getRefreshDeadline

      public long getRefreshDeadline()

    • getVisibleQueries

      @NotNull public gnu.trove.set.TLongSet getVisibleQueries()

    • setVisibleQueries

      public void setVisibleQueries(gnu.trove.set.TLongSet visibleQueries)

    • beginSubscription

      public boolean beginSubscription()

    • isSubscriptionInProgress

      public boolean isSubscriptionInProgress()

    • finishSubscription

      public void finishSubscription()

    • getDelayedCommands

      public List<io.deephaven.proto.controller.SubscribeResponse> getDelayedCommands()

    • getAndResetDelayedCommands

      public List<io.deephaven.proto.controller.SubscribeResponse> getAndResetDelayedCommands()

    • maybeCreateDelayedCommands

      public void maybeCreateDelayedCommands()

    • getObserver

      public io.deephaven.shadow.core.io.grpc.stub.StreamObserver<io.deephaven.proto.controller.SubscribeResponse> getObserver()

    • setObserver

      public void setObserver(io.deephaven.shadow.core.io.grpc.stub.StreamObserver<io.deephaven.proto.controller.SubscribeResponse> responseObserver)

    • setCookie

      public void setCookie(io.deephaven.shadow.core.com.google.protobuf.ByteString cookie)

    • getCurrentCookie

      public io.deephaven.shadow.core.com.google.protobuf.ByteString getCurrentCookie()

    • getUuid

      public io.deephaven.shadow.core.com.google.protobuf.ByteString getUuid()

    • isCookieValid

      public boolean isCookieValid(io.deephaven.shadow.core.com.google.protobuf.ByteString cookie)

    • getUserContext

      public io.deephaven.enterprise.auth.UserContext getUserContext()

    • getClientId

      public io.deephaven.proto.auth.ClientId getClientId()

    • sendOrEnqueueCommand

      public void sendOrEnqueueCommand(@NotNull io.deephaven.proto.controller.SubscribeResponse event)

    • sendCommandImmediate

      public void sendCommandImmediate(@NotNull io.deephaven.proto.controller.SubscribeResponse event)

    • append

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

    • toString

      public String toString()
      Overrides:
      toString in class Object

    • safelyCompleteSubscription

      public void safelyCompleteSubscription()