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.

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

open override val aggregateName: String

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

The list of domain events in this stream

open override val commandId: String

open override val contextName: String

open override val createTime: Long

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

open override val requestId: String

The request ID that initiated this event stream

open override val size: Int

open override val spaceId: SpaceId

open override val version: Int

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, tags: AbacTags = EMPTY_ABAC_TAGS, 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