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

InMemoryQueueWriteLayer

class InMemoryQueueWriteLayer<T> : QueueWriteLayer<T>

Constructors

InMemoryQueueWriteLayer

fun InMemoryQueueWriteLayer()

Functions

open suspend fun clear()

open suspend override fun peek(n: Int): List<T>

open suspend override fun pop(n: Int)

open suspend override fun push(t: List<T>)

open suspend override fun size(): Int

Properties

concurrentPushPop

open override val concurrentPushPop: Boolean = false

Specify whether this write layer is capable of handling pushing and popping concurrently. The queue handler will parallelize the incoming push/pop requests if this can support it. Otherwise, they will be serialized.