SerializedState

class SerializedState(val version: Int, val state: String, val scope: Scope = Scope.NONE, val deleted: Boolean = false, val schedules: Map<String, ScheduleRule> = emptyMap(), val first: FirstCommit? = null)

The state of an aggregate after its stream version: its state as the kernel's codec serialized it, the scope of the stream, whether it is deleted and its schedules, as the kernel committed them. A view is serialized once and decoded afresh by each reader, so no reader sees another's changes nor the live instance. This is the runtime's form, the text a snapshot stores; what a sink publishes is the :spi me.ahoo.wow.spi.state.PublishedState, a JSON tree with its schema's fingerprint, which me.ahoo.wow.runtime.sink.SinkSubscription maps this one to.

Constructors

Link copied to clipboard
constructor(version: Int, state: String, scope: Scope = Scope.NONE, deleted: Boolean = false, schedules: Map<String, ScheduleRule> = emptyMap(), first: FirstCommit? = null)

Properties

Link copied to clipboard
Link copied to clipboard

What the aggregate's first stream recorded, when the kernel knew it.

Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard

Functions

Link copied to clipboard
open override fun toString(): String