Package io.deephaven.enterprise.remote

Interface SubscriptionOptions

@Immutable public interface SubscriptionOptions
Implementations of this interface provide parameters for a ConnectionAwareRemoteTable to maintain a subscription to a remote table.

  • Method Details

    • getMaxInboundMessageSize

      static int getMaxInboundMessageSize()
      Get the maximum inbound message size.
      Returns:
      the maximum inbound message size

    • clearOnDisconnect

      @Default default boolean clearOnDisconnect()
      If the result table should clear its rows when a disconnect occurs. Defaults to true.
      Returns:
      if the result table should clear rows on disconnection/

    • retryWindowMillis

      @Default default long retryWindowMillis()
      The width of the window in milliseconds in which to attempt to reconnect. Defaults to 60 seconds, unless changed via the ConnectionAwareRemoteTableParams.retryWindowMillis property.
      Returns:
      the reconnection window in milliseconds

    • maxRetriesWithinWindow

      @Default default long maxRetriesWithinWindow()
      The maximum number of retries to attempt within the window. Defaults to 5, unless changed via tha ConnectionAwareRemoteTableParams.maxRetries property.
      Returns:
      the maximum allowed retries in the window

    • includedColumns

      @NotNull Set<String> includedColumns()
      Get the columns to include from the upstream table. Defaults to all (null)
      Returns:
      the columns to include, or null for all of them.

    • builder

      @NotNull static SubscriptionOptions.Builder builder()
      Construct a new SubscriptionOptions.Builder to create SubscriptionOptions.
      Returns:
      a new builder.

    • check

      @Check @FinalDefault default void check()
      Ensure the state is valid.