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

SimpleDomainEventStream

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

Constructors

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

Properties

aggregateId

open override val aggregateId: AggregateId

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

header

open override val header: Header

open override val id: String

initialized

open val initialized: Boolean

isInitialVersion

open val isInitialVersion: Boolean

isReadOnly

open val isReadOnly: Boolean

requestId

open override val requestId: String

size

open override val size: Int

version

open override val version: Int

Functions

aggregateId

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

aggregateType

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

copy

open override fun copy(): DomainEventStream

forEach

open fun forEach(p0: Consumer<in DomainEvent<*>>)

generateId

fun NamedAggregate.generateId(): String

getContextAlias

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

ignoreSourcing

fun DomainEventStream.ignoreSourcing(): Boolean

isLocal

fun NamedAggregate.isLocal(): Boolean

isSameAggregateName

open fun isSameAggregateName(other: NamedAggregate): Boolean

isSameBoundedContext

open fun isSameBoundedContext(other: NamedBoundedContext): Boolean

iterator

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

match

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

materialize

fun NamedAggregate.materialize(): MaterializedNamedAggregate

mergeAnnotations

fun Iterable<Annotation>.mergeAnnotations(scanned: MutableList<Annotation> = mutableListOf()): List<Annotation>

requiredAggregateType

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

sortedByOrder

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

spliterator

open fun spliterator(): Spliterator<DomainEvent<*>>

toEventNamedAggregate

fun NamedAggregate.toEventNamedAggregate(eventName: String): EventNamedAggregate

toGroupKey

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

toNamedAggregateString

fun NamedAggregate.toNamedAggregateString(): String

toStateEvent

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

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

toStringWithAlias

fun NamedAggregate.toStringWithAlias(): String

withHeader

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

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

withReadOnly

open fun withReadOnly(): DomainEventStream