datasourcex-util/com.caplin.integration.datasourcex.util.store/StoreWriter

StoreWriter

interface StoreWriter<K : Any, V : Any, T>(source)

Write half of the store SPI. Implementations enlist on TxContext.transaction and must not commit the transaction themselves. Each write assigns and returns the new version from the store's commit order (a sequence, identity, or version column); the caller never supplies it.

Inheritors

Store

Functions

delete

abstract fun delete(key: K, tx: TxContext<T>): Long

Deletes key and returns the version the store assigned the removal.

load

abstract fun load(key: K, tx: TxContext<T>): Versioned<V>?

Reads key's current persisted value within tx for read-modify-write, e.g. a locking SELECT … FOR UPDATE on the transaction's connection. Override it to support MutableFlowStore.get within a transaction (the default throws); the read should see the transaction's own uncommitted writes and serialise concurrent writers.

write

abstract fun write(key: K, value: V, tx: TxContext<T>): Long

Writes value for key and returns the version the store assigned it.

writeAll

open fun writeAll(values: Map<K, V>, tx: TxContext<T>): Map<K, Long>

Writes many entries, returning the version assigned to each.