sqlx4k-postgres-pgmq/io.github.smyrgeorge.sqlx4k.postgres.pgmq.impl.extensions

Package-level declarations

Functions

context(db: QueryExecutor)
suspend fun archive(queue: String, id: Long): Result<Boolean>

context(db: QueryExecutor)
suspend fun archive(queue: String, ids: List<Long>): Result<List<Long>>

context(db: QueryExecutor)
suspend fun bindTopic(pattern: String, queueName: String): Result<Unit>

context(db: QueryExecutor)
suspend fun delete(queue: String, id: Long): Result<Boolean>

context(db: QueryExecutor)
suspend fun delete(queue: String, ids: List<Long>): Result<List<Long>>

context(db: QueryExecutor)
suspend fun pop(queue: String, quantity: Int = 1): Result<List<Message>>

context(db: QueryExecutor)
suspend fun read(queue: String, quantity: Int = 1, vt: Duration = 30.seconds): Result<List<Message>>

context(db: QueryExecutor)
suspend fun send(queue: String, message: String, headers: Map<String, String> = emptyMap(), delay: Duration = 0.seconds): Result<Long>

context(db: QueryExecutor)
suspend fun send(queue: String, messages: List<String>, headers: Map<String, String> = emptyMap(), delay: Duration = 0.seconds): Result<List<Long>>

context(db: QueryExecutor)
suspend fun sendTopic(routingKey: String, message: String, headers: Map<String, String> = emptyMap(), delay: Duration = 0.seconds): Result<Long>

context(db: QueryExecutor)
suspend fun setVt(queue: String, id: Long, vt: Duration): Result<Long>