whylogs-container/ai.whylabs.services.whylogs.persistent.map/MapMessageHandlerOptions

MapMessageHandlerOptions

data class MapMessageHandlerOptions<K, V>(val writeLayer: MapWriteLayer<K, V>, val retryPolicy: RetryPolicy<Throwable>? = defaultRetryPolicy) : RetryOptions

Constructors

MapMessageHandlerOptions

fun <K, V> MapMessageHandlerOptions(writeLayer: MapWriteLayer<K, V>, retryPolicy: RetryPolicy<Throwable>? = defaultRetryPolicy)

Functions

open suspend fun <T> retryIfEnabled(block: suspend () -> T): T

Properties

open override val retryPolicy: RetryPolicy<Throwable>?

val writeLayer: MapWriteLayer<K, V>