wow-core/me.ahoo.wow.modeling.state/StateAggregate

StateAggregate

interface StateAggregate<S : Any> : ReadOnlyStateAggregate<S>

State Aggregate .

聚合状态容器
订阅领域事件，修改聚合状态
状态聚合必须具有无参构造函数，作为序列化使用

Author

ahoo wang

Inheritors

SimpleStateAggregate

Properties

abstract override val aggregateId: AggregateId

The unique identifier of this aggregate.

abstract val deleted: Boolean

abstract val eventId: String

abstract val eventTime: Long

expectedNextVersion

open val expectedNextVersion: Int

The expected version for the next event to be applied.

abstract val firstEventTime: Long

abstract val firstOperator: String

open val initialized: Boolean

isInitialVersion

open val isInitialVersion: Boolean

abstract val operator: String

abstract val ownerId: String

abstract val spaceId: SpaceId

abstract val state: S

abstract override val version: Int

The current version of this aggregate's state.

Functions

abstract fun onSourcing(eventStream: DomainEventStream): StateAggregate<S>

当聚合未找到匹配的 onSourcing 方法时，不会认为产生的故障，忽略该事件，但更新聚合版本号为该领域事件的版本号.

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

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

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

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

toStateAggregate

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