MetadataQueries

class MetadataQueries(sqlDriver: SqlDriver) : TransacterImpl(source)

Constructors

Link copied to clipboard
constructor(sqlDriver: SqlDriver)

Functions

Link copied to clipboard
fun purgeExpires(entity_name: String, expiresAfter: Long)
Link copied to clipboard
fun purgeStale(entity_name: String, writeInstant: Long, readInstant: Long)
Link copied to clipboard
fun purgeStaleRead(entity_name: String, readInstant: Long)
Link copied to clipboard
fun purgeStaleWrite(entity_name: String, writeInstant: Long)
Link copied to clipboard
open override fun transaction(noEnclosing: Boolean, body: TransactionWithoutReturn.() -> Unit)
Link copied to clipboard
open override fun <R> transactionWithResult(noEnclosing: Boolean, bodyWithReturn: TransactionWithReturn<R>.() -> R): R
Link copied to clipboard
fun updateReadForEntities(readAt: Long, entity_name: String, entity_keys: Collection<String>)

Bulk-updates entity.read_at for entity_keys. An empty collection is a deliberate no-op: SQLite rejects IN () as a syntax error, and KeyValueStorage.updateReadAt routinely passes an empty list when a selectAll(...) Flow emits an empty result set.

Link copied to clipboard
fun upsertRead(entity_name: String, lastReadAt: Instant)
Link copied to clipboard
fun upsertWrite(entity_name: String, lastWriteAt: Instant)