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

StateAggregate

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

State Aggregate .

Holds aggregate state and applies domain events to evolve it. State implementations require a no-argument constructor for serialization.

Author

ahoo wang

Inheritors

Properties

Link copied to clipboard
abstract override val aggregateId: AggregateId

The unique identifier of this aggregate.

Link copied to clipboard
abstract val deleted: Boolean
Link copied to clipboard
abstract val eventId: String
Link copied to clipboard
abstract val eventTime: Long
Link copied to clipboard
open val expectedNextVersion: Int

The expected version for the next event to be applied.

Link copied to clipboard
abstract val firstEventTime: Long
Link copied to clipboard
abstract val firstOperator: String
Link copied to clipboard
open val initialized: Boolean
Link copied to clipboard
Link copied to clipboard
abstract val operator: String
Link copied to clipboard
abstract val ownerId: String
Link copied to clipboard
abstract val spaceId: SpaceId
Link copied to clipboard
abstract val state: S
Link copied to clipboard
abstract val tags: AbacTags
Link copied to clipboard
abstract override val version: Int

The current version of this aggregate's state.

Functions

Link copied to clipboard
abstract fun onSourcing(eventStream: DomainEventStream): StateAggregate<S>

Ignores an event when no matching onSourcing function exists, while still advancing the aggregate version to the event version.

Link copied to clipboard
fun AggregateIdCapable.toGroupKey(parallelism: Int = DEFAULT_PARALLELISM): Int

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

Link copied to clipboard
Link copied to clipboard
fun <S : Any, D : Any> ReadOnlyStateAggregate<S>.toSmall(materialize: (S) -> D): SmallMaterializedSnapshot<D>
Link copied to clipboard
Generated by Dokka
© 2026 Copyright