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

Package ai.whylabs.services.whylogs.persistent.queue

Types

InMemoryQueueWriteLayer

class InMemoryQueueWriteLayer<T> : QueueWriteLayer<T>

PersistentQueue

class PersistentQueue<T>(options: QueueOptions<T>)

sealed class PopSize

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

QueueWriteLayer

interface QueueWriteLayer<T>

SqliteQueueWriteLayer

class SqliteQueueWriteLayer<T>(name: String, serializer: Serializer<T>) : SqliteManager, QueueWriteLayer<T>