whylogs-container/ai.whylabs.services.whylogs.persistent.queue/QueueOptions

QueueOptions

data class QueueOptions<T>(val queueWriteLayer: QueueWriteLayer<T>, val retryPolicy: RetryPolicy<Throwable>? = defaultRetryPolicy) : RetryOptions
Content copied to clipboard

Constructors

Link copied to clipboard
fun <T> QueueOptions(queueWriteLayer: QueueWriteLayer<T>, retryPolicy: RetryPolicy<Throwable>? = defaultRetryPolicy)
Content copied to clipboard

Functions

Link copied to clipboard
open suspend fun <T> retryIfEnabled(block: suspend () -> T): T
Content copied to clipboard

Properties

Link copied to clipboard
val queueWriteLayer: QueueWriteLayer<T>
Content copied to clipboard
Link copied to clipboard
open override val retryPolicy: RetryPolicy<Throwable>?
Content copied to clipboard