wow-core/me.ahoo.wow.eventsourcing.snapshot/Snapshot

Snapshot

interface Snapshot<S : Any> : ReadOnlyStateAggregate<S> , SnapshotTimeCapable

Represents a snapshot of a state aggregate at a specific point in time. Snapshots are used to optimize loading by providing a starting point for event replay.

Parameters

the type of the state

Inheritors

SimpleSnapshot

Properties

aggregateId

abstract override val aggregateId: AggregateId

The unique identifier of this aggregate.

deleted

abstract val deleted: Boolean

eventId

abstract val eventId: String

eventTime

abstract val eventTime: Long

expectedNextVersion

open val expectedNextVersion: Int

The expected version for the next event to be applied.

firstEventTime

abstract val firstEventTime: Long

firstOperator

abstract val firstOperator: String

initialized

open val initialized: Boolean

isInitialVersion

open val isInitialVersion: Boolean

operator

abstract val operator: String

ownerId

abstract val ownerId: String

snapshotTime

abstract val snapshotTime: Long

spaceId

abstract val spaceId: SpaceId

state

abstract val state: S

version

abstract override val version: Int

The current version of this aggregate's state.

Functions

materialize

fun <S : Any, D : Any> Snapshot<S>.materialize(materialize: (S) -> D): MaterializedSnapshot<D>

toGroupKey

fun AggregateIdCapable.toGroupKey(parallelism: Int = DEFAULT_PARALLELISM): Int

Computes a grouping key for parallel processing based on the aggregate ID.

toMedium

fun <S : Any, D : Any> ReadOnlyStateAggregate<S>.toMedium(materialize: (S) -> D): MediumMaterializedSnapshot<D>

toSmall

fun <S : Any, D : Any> ReadOnlyStateAggregate<S>.toSmall(materialize: (S) -> D): SmallMaterializedSnapshot<D>

toStateAggregate

@JvmStatic

fun <S : Any> ReadOnlyStateAggregate<S>.toStateAggregate(): StateAggregate<S>