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

SimpleStateAggregate

class SimpleStateAggregate<S : Any>(val aggregateId: AggregateId, val metadata: StateAggregateMetadata<S>, val state: S, var version: Int = Version.UNINITIALIZED_VERSION, var eventId: String = "", var firstOperator: String = "", var operator: String = "", var firstEventTime: Long = 0, var eventTime: Long = 0, var deleted: Boolean = false) : StateAggregate<S> , TypedAggregate<S>

Constructors

SimpleStateAggregate

constructor(aggregateId: AggregateId, metadata: StateAggregateMetadata<S>, state: S, version: Int = Version.UNINITIALIZED_VERSION, eventId: String = "", firstOperator: String = "", operator: String = "", firstEventTime: Long = 0, eventTime: Long = 0, deleted: Boolean = false)

Types

object Companion

Properties

open override val aggregateId: AggregateId

open override val aggregateType: Class<S>

State Aggregation Type

open override var deleted: Boolean

状态聚合是否已删除

open override var eventId: String

open override var eventTime: Long

expectedNextVersion

open val expectedNextVersion: Int

open override var firstEventTime: Long

open override var firstOperator: String

open val initialized: Boolean

isInitialVersion

open val isInitialVersion: Boolean

val metadata: StateAggregateMetadata<S>

open override var operator: String

open override val state: S

open override var version: Int

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

Functions

open operator override fun equals(other: Any?): Boolean

open override fun hashCode(): Int

open override fun onSourcing(eventStream: DomainEventStream): StateAggregate<S>

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

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

toStateAggregate

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

open override fun toString(): String