runtime/me.ahoo.wow.runtime.snapshot/SnapshotStoreRouter

SnapshotStoreRouter

class SnapshotStoreRouter(default: SnapshotStore, stores: Map<AggregateType, SnapshotStore>) : SnapshotStore

The snapshots of a context whose aggregate types keep them on different stores: each aggregate's snapshot is in the store stores names for its type, else in default.

Constructors

SnapshotStoreRouter

constructor(default: SnapshotStore, stores: Map<AggregateType, SnapshotStore>)

Types

Companion

@InternalWowApi

object Companion

Properties

rebuilds

open override val rebuilds: SnapshotRebuildStore?

The rebuild control plane of each type's store: a router over the stores that have one, null when none has. A type whose store has none is refused, as the node's maintenance never asks it (it rebuilds per named store).

Functions

load

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

save

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

saveAll

open suspend override fun saveAll(snapshots: List<SnapshotRecord>): List<SnapshotSaveOutcome>

Each store's snapshots with one call of its own SnapshotStore.saveAll; the outcomes in the order given.