wow-core/me.ahoo.wow.eventsourcing.state/StateEventData

StateEventData

data class StateEventData<S : Any>(val delegate: DomainEventStream, val state: S, val firstOperator: String = delegate.header.operator.orEmpty(), val firstEventTime: Long = delegate.createTime, val deleted: Boolean = false) : StateEvent<S> , Decorator<DomainEventStream> , DomainEventStream

Data class implementation of StateEvent that wraps a DomainEventStream with state information.

Parameters

delegate

the domain event stream being wrapped

state

the state of the aggregate

firstOperator

the first operator (default: from delegate header)

firstEventTime

the first event time (default: from delegate)

deleted

whether the aggregate is deleted (default: false)

Constructors

StateEventData

constructor(delegate: DomainEventStream, state: S, firstOperator: String = delegate.header.operator.orEmpty(), firstEventTime: Long = delegate.createTime, deleted: Boolean = false)

Properties

aggregateId

open override val aggregateId: AggregateId

The aggregate ID this event stream belongs to

aggregateName

open override val aggregateName: String

body

open override val body: List<DomainEvent<*>>

commandId

open override val commandId: String

contextName

open override val contextName: String

createTime

open override val createTime: Long

delegate

open override val delegate: DomainEventStream

deleted

open override val deleted: Boolean

eventId

open override val eventId: String

The event ID, delegated to the id property.

eventTime

open override val eventTime: Long

The time when the event occurred, delegated to createTime.

expectedNextVersion

open val expectedNextVersion: Int

firstEventTime

open override val firstEventTime: Long

firstOperator

open override val firstOperator: String

header

open override val header: Header

open override val id: String

initialized

open override val initialized: Boolean

isInitialVersion

open override val isInitialVersion: Boolean

isReadOnly

open override val isReadOnly: Boolean

operator

open override val operator: String

The operator who triggered the event, from the header.

ownerId

open override val ownerId: String

requestId

open override val requestId: String

size

open override val size: Int

The number of events in this stream

state

open override val state: S

version

open override val version: Int

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

Functions

aggregateId

fun NamedAggregate.aggregateId(id: String = generateId(), tenantId: String = TenantId.DEFAULT_TENANT_ID): DefaultAggregateId

Creates an AggregateId for this NamedAggregate with the specified parameters.

aggregateType

fun <T> NamedAggregate.aggregateType(): Class<T>?

Finds the aggregate type class associated with this named aggregate.

asAggregateMetadata

fun <C : Any, S : Any> NamedAggregate.asAggregateMetadata(): AggregateMetadata<C, S>

Converts this NamedAggregate to its corresponding AggregateMetadata.

copy

open override fun copy(): StateEvent<S>

Creates a copy of this StateEventData with a copied delegate.

generateId

fun NamedAggregate.generateId(): String

Generates a unique ID string for this NamedAggregate.

getContextAlias

fun NamedBoundedContext.getContextAlias(boundedContext: BoundedContext? = MetadataSearcher.metadata.contexts[contextName]): String

getContextAliasPrefix

fun NamedBoundedContext.getContextAliasPrefix(): String

Gets the context alias prefix for this bounded context.

ignoreSourcing

fun DomainEventStream.ignoreSourcing(): Boolean

Determines if this event stream should be ignored during event sourcing.

isLocal

fun NamedAggregate.isLocal(): Boolean

Checks if the named aggregate is available locally at runtime.

isSameAggregateName

open override fun isSameAggregateName(other: NamedAggregate): Boolean

isSameBoundedContext

open override fun isSameBoundedContext(other: NamedBoundedContext): Boolean

iterator

open operator override fun iterator(): Iterator<DomainEvent<*>>

match

fun Message<*, *>.match(function: FunctionInfo): Boolean

Checks if this message matches the given function for compensation purposes.

materialize

fun NamedAggregate.materialize(): MaterializedNamedAggregate

Materializes this NamedAggregate into a MaterializedNamedAggregate.

requiredAggregateType

fun <T> NamedAggregate.requiredAggregateType(): Class<T>

Finds the aggregate type class associated with this named aggregate, throwing an exception if not found.

sortedByOrder

fun <T : Any> Iterable<T>.sortedByOrder(): List<T>

Sorts an iterable collection based on Order annotations and dependencies.

toEventNamedAggregate

fun NamedAggregate.toEventNamedAggregate(eventName: String): EventNamedAggregate

Extension function to convert a NamedAggregate to an EventNamedAggregate.

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>

toNamedAggregateString

fun NamedAggregate.toNamedAggregateString(): String

Converts this NamedAggregate to its string representation.

toSmall

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

toStateAggregate

@JvmStatic

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

toStateEvent

fun <S : Any> DomainEventStream.toStateEvent(stateAggregate: ReadOnlyStateAggregate<S>): StateEvent<S>

Converts a DomainEventStream to a StateEvent using the state from a ReadOnlyStateAggregate.

fun <S : Any> DomainEventStream.toStateEvent(state: S, firstOperator: String = header.operator.orEmpty(), firstEventTime: Long = createTime, deleted: Boolean = false): StateEvent<S>

Converts a DomainEventStream to a StateEvent with the given state.

toStringWithAlias

fun NamedAggregate.toStringWithAlias(): String

Converts this NamedAggregate to a string representation using the context alias.

withHeader

open override fun withHeader(additionalSource: Map<String, String>): DomainEventStream

open override fun withHeader(key: String, value: String): DomainEventStream

withReadOnly

open override fun withReadOnly(): DomainEventStream