SqliteStorageTable

Constructors

Link copied to clipboard
constructor(storage: SqliteStorage, spec: StorageTableSpec)

Properties

Link copied to clipboard
Link copied to clipboard
open override val storage: SqliteStorage

The Storage the table belongs to.

Functions

Link copied to clipboard
open suspend override fun delete(key: String, partitionId: String?): Boolean

Deletes data.

Link copied to clipboard
open suspend override fun deleteAll()

Deletes all data previously stored in this table.

Link copied to clipboard
open suspend override fun deletePartition(partitionId: String)

Deletes all data previously stored in this the given partition.

Link copied to clipboard
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.

Link copied to clipboard
open suspend override fun enumerateWithData(partitionId: String?, afterKey: String?, limit: Int): List<ERROR CLASS: Symbol not found for Pair<kotlin/String, ERROR CLASS: Symbol not found for ByteString>>

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

Link copied to clipboard
open suspend override fun get(key: String, partitionId: String?): ERROR CLASS: Symbol not found for ByteString??

Gets data.

Link copied to clipboard
abstract suspend fun insert(key: String?, data: kotlinx/io/bytestring/ByteString, partitionId: String? = null, expiration: kotlin/time/Instant = Instant.DISTANT_FUTURE): String

Stores new data.

open suspend override fun insert(key: String?, data: ERROR CLASS: Symbol not found for ByteString, partitionId: String?, expiration: ERROR CLASS: Symbol not found for Instant): String
Link copied to clipboard
open suspend override fun purgeExpired()

Reclaim storage that is taken up by the expired entries.

Link copied to clipboard
abstract suspend fun update(key: String, data: kotlinx/io/bytestring/ByteString, partitionId: String? = null, expiration: kotlin/time/Instant?? = null)

Updates data that is already stored in the engine.

open suspend override fun update(key: String, data: ERROR CLASS: Symbol not found for ByteString, partitionId: String?, expiration: ERROR CLASS: Symbol not found for Instant??)