query/me.ahoo.wow.query.engine/CommittedStates

CommittedStates

The committed states a node reads: the latest committed state of an aggregate, as the write side keeps it (:runtime's state reads, injected here so that :query does not depend on the runtime).

Types

Companion

@InternalWowApi

object Companion

Functions

committed

abstract suspend fun committed(ref: AggregateRef): Snapshot<JsonNode>?

ref's latest committed state, or null when it has none.

open suspend fun committed(ref: AggregateRef, minVersion: Int): Snapshot<JsonNode>?

ref's latest committed state at version minVersion or later; by default the latest one as it is, which fails when it is below minVersion. The runtime's catches a lagging snapshot up and waits.