wow-core/me.ahoo.wow.event/SimpleDomainEventStream

SimpleDomainEventStream

data class SimpleDomainEventStream(val id: String = generateGlobalId(), val requestId: String, val header: Header = DefaultHeader.empty(), val body: List<DomainEvent<*>>) : DomainEventStream, Iterable<DomainEvent<*>>

Simple implementation of DomainEventStream.

This data class provides a concrete implementation of the DomainEventStream interface, containing a list of domain events with associated metadata.

Parameters

id

The stream ID

requestId

The request ID

header

The message header

body

The list of domain events (must not be empty)

See also

DomainEventStream

Throws

IllegalArgumentException

if the event list is empty

Constructors

SimpleDomainEventStream

constructor(id: String = generateGlobalId(), requestId: String, header: Header = DefaultHeader.empty(), body: List<DomainEvent<*>>)

Creates a new SimpleDomainEventStream

Properties

open override val aggregateId: AggregateId

The aggregate ID (derived from the first event)

open override val aggregateName: String

The aggregate name (derived from aggregateId)

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

The list of domain events in this stream

open override val commandId: String

The command ID (derived from the first event)

open override val contextName: String

The bounded context name (derived from aggregateId)

open override val createTime: Long

The creation timestamp (derived from the first event)

open override val header: Header

The message header containing metadata (default: empty header)

open override val id: String

The unique identifier of this event stream (default: generated global ID)

open val initialized: Boolean

isInitialVersion

open val isInitialVersion: Boolean

open val isReadOnly: Boolean

open override val ownerId: String

The owner ID (derived from the first event)

open override val requestId: String

The request ID that initiated this event stream

open override val size: Int

The number of events in the stream

open override val version: Int

The aggregate version (derived from the first event)

Functions

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

Creates an AggregateId for this NamedAggregate with the specified parameters.

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.

open override fun copy(): DomainEventStream

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.

fun DomainEventStream.ignoreSourcing(): Boolean

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

fun NamedAggregate.isLocal(): Boolean

Checks if the named aggregate is available locally at runtime.

isSameAggregateName

open fun isSameAggregateName(other: NamedAggregate): Boolean

isSameBoundedContext

open fun isSameBoundedContext(other: NamedBoundedContext): Boolean

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

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

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

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.

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.

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

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

toNamedAggregateString

fun NamedAggregate.toNamedAggregateString(): String

Converts this NamedAggregate to its string representation.

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.

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

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

open fun withReadOnly(): DomainEventStream