kernel/me.ahoo.wow.kernel.memory/InMemorySnapshotStore

InMemorySnapshotStore

class InMemorySnapshotStore : SnapshotStore, SnapshotRebuildStore

A SnapshotStore in memory, for tests and samples. The version guard is one atomic compute per ref, and a table's claim one atomic compute per aggregate type.

Constructors

constructor()

Properties

rebuilds

open override val rebuilds: SnapshotRebuildStore

This store rewrites its snapshots in place: it is its own rebuild control plane.

Functions

claim

open suspend override fun claim(type: AggregateType, revision: Int, lower: Boolean): SnapshotTable

load

open suspend override fun load(ref: AggregateRef): SnapshotRecord?

mark

open suspend override fun mark(type: AggregateType, revision: Int, rebuilding: Boolean?, backfilled: Boolean?): SnapshotTable?

markStale

open suspend override fun markStale(ref: AggregateRef): Boolean

pending

open suspend override fun pending(type: AggregateType, revision: Int, after: AggregateRef?, limit: Int): List<AggregateRef>

rewrite

open suspend override fun rewrite(snapshot: SnapshotRecord): Boolean

save

open suspend override fun save(snapshot: SnapshotRecord): Boolean

table

open suspend override fun table(type: AggregateType): SnapshotTable?