soil-query-core/soil.query/SubscriptionOptions

SubscriptionOptions

interface SubscriptionOptions : ActorOptions, LoggingOptions, RetryOptions

SubscriptionOptions providing settings related to the internal behavior of an Subscription.

Inheritors

Types

object Default : SubscriptionOptions

Properties

abstract val errorEquals: (Throwable, Throwable) -> Boolean?

Determines whether two errors are equal.

abstract val gcTime: Duration

The period during which the Key's return value, if not referenced anywhere, is temporarily cached in memory.

abstract val keepAliveTime: Duration

Duration to remain state as an active.

abstract val logger: LoggerFn?

Specifies the logger function.

abstract val onError: (ErrorRecord, SubscriptionModel<*>) -> Unit?

This callback function will be called if some mutation encounters an error.

abstract val retryCount: Int

The number of times to retry the operation.

retryInitialInterval

abstract val retryInitialInterval: Duration

The initial interval for retrying the operation.

retryMaxInterval

abstract val retryMaxInterval: Duration

The maximum interval for retrying the operation.

retryMultiplier

abstract val retryMultiplier: Double

The multiplier for the next interval.

retryRandomizationFactor

abstract val retryRandomizationFactor: Double

The randomization factor for the next interval.

retryRandomizer

abstract val retryRandomizer: Random

The random number generator for the next interval.

abstract val shouldRetry: (Throwable) -> Boolean

Specifies whether to retry the operation.

shouldSuppressErrorRelay

abstract val shouldSuppressErrorRelay: (ErrorRecord, SubscriptionModel<*>) -> Boolean?

Determines whether to suppress error information when relaying it using soil.query.core.ErrorRelay.

Functions

calculateBackoffInterval

fun RetryOptions.calculateBackoffInterval(attempt: Int): Duration

fun SubscriptionOptions.copy(gcTime: Duration = this.gcTime, errorEquals: (Throwable, Throwable) -> Boolean? = this.errorEquals, onError: (ErrorRecord, SubscriptionModel<*>) -> Unit? = this.onError, shouldSuppressErrorRelay: (ErrorRecord, SubscriptionModel<*>) -> Boolean? = this.shouldSuppressErrorRelay, keepAliveTime: Duration = this.keepAliveTime, logger: LoggerFn? = this.logger, shouldRetry: (Throwable) -> Boolean = this.shouldRetry, retryCount: Int = this.retryCount, retryInitialInterval: Duration = this.retryInitialInterval, retryMaxInterval: Duration = this.retryMaxInterval, retryMultiplier: Double = this.retryMultiplier, retryRandomizationFactor: Double = this.retryRandomizationFactor, retryRandomizer: Random = this.retryRandomizer): SubscriptionOptions

Copies the current SubscriptionOptions with the specified settings.

exponentialBackOff

fun <T> RetryOptions.exponentialBackOff(onRetry: RetryCallback? = null): RetryFn<T>

Generates an RetryFn for Exponential Backoff Strategy.