spi-consumer/me.ahoo.wow.consumer/AcmeSnapshotStore

AcmeSnapshotStore

class AcmeSnapshotStore(queries: InMemoryQueryStorage) : SnapshotStore

The snapshots of one context: the version guard of SnapshotStore.save as one atomic compute per ref, each snapshot written copied to queries. It has no rebuild control plane: a snapshot of a lower state revision is left as it is.

Constructors

AcmeSnapshotStore

constructor(queries: InMemoryQueryStorage)

Functions

load

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

save

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