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

SimpleSnapshot

data class SimpleSnapshot<S : Any>(val delegate: ReadOnlyStateAggregate<S>, val snapshotTime: Long = System.currentTimeMillis()) : Snapshot<S> , ReadOnlyStateAggregate<S> , Decorator<ReadOnlyStateAggregate<S>>

Constructors

constructor(delegate: ReadOnlyStateAggregate<S>, snapshotTime: Long = System.currentTimeMillis())

Properties

open override val aggregateId: AggregateId

open override val aggregateType: Class<S>

State Aggregation Type

open override val delegate: ReadOnlyStateAggregate<S>

open override val deleted: Boolean

状态聚合是否已删除

open override val eventId: String

open override val eventTime: Long

expectedNextVersion

open override val expectedNextVersion: Int

open override val firstEventTime: Long

open override val firstOperator: String

open override val initialized: Boolean

isInitialVersion

open override val isInitialVersion: Boolean

open override val operator: String

open override val snapshotTime: Long

open override val state: S

open override val version: Int

用于生成领域事件版本号.

Functions

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

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

toStateAggregate

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