JdbcStorageTable

Constructors

constructor(storage: JdbcStorage, sql: SqlStatementMaker)

open override val storage: JdbcStorage

The Storage the table belongs to.

open suspend override fun delete(key: String, partitionId: String?): Boolean

Deletes data.

open suspend override fun deleteAll()

Deletes all data previously stored in this table.

open suspend override fun deletePartition(partitionId: String)

Deletes all data previously stored in this the given partition.

open suspend override fun enumerate(partitionId: String?, afterKey: String?, limit: Int): List<String>

Enumerate keys of the records with given table and partitionId in key lexicographic order.

open suspend override fun enumerateWithData(partitionId: String?, afterKey: String?, limit: Int): List<Pair<String, ByteString>>

Enumerate the records with given table and partitionId in key lexicographic order.

open suspend override fun get(key: String, partitionId: String?): ByteString?

Gets data.

open suspend override fun insert(key: String?, data: ByteString, partitionId: String?, expiration: Instant): String

Stores new data.

open suspend override fun purgeExpired()

Reclaim storage that is taken up by the expired entries.

open suspend override fun update(key: String, data: ByteString, partitionId: String?, expiration: Instant?)

Updates data that is already stored in the engine.