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

SqliteQueueWriteLayer

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

Constructors

SqliteQueueWriteLayer

fun <T> SqliteQueueWriteLayer(name: String, serializer: Serializer<T>)

Functions

open suspend fun clear()

open override fun close()

fun enableWAL()

Util function for enabling WAL mode. Make sure to create the database first by executing some SQL statement before this.

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

open suspend override fun pop(n: Int)

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

fun query(block: Connection.() -> Unit)

Get a hold of a Connection to execute queries. If you're going to do any write operations then you should use tx instead.

open suspend override fun size(): Int

fun tx(block: Connection.() -> Unit)

Get a Connection within a transaction. This will just commit for you and rollback in a catch block.

fun vacuum()

Properties

concurrentPushPop

open override val concurrentPushPop: Boolean = true

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.

open override val databaseUrl: String

JDBC string to pass into DriverManager.getConnection.