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

Constructors

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

Properties

open override val aggregateId: AggregateId

open override val aggregateName: String

open override val aggregateType: Class<S>

State Aggregation Type

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

open override val commandId: String

open override val contextName: String

open override val createTime: Long

open override val delegate: DomainEventStream

open override val deleted: Boolean = false

状态聚合是否已删除

open override val eventId: String

open override val eventTime: Long

expectedNextVersion

open val expectedNextVersion: Int

open override val firstEventTime: Long

open override val firstOperator: String

open override val header: Header

open override val id: String

open override val initialized: Boolean

isInitialVersion

open override val isInitialVersion: Boolean

open override val isReadOnly: Boolean

open override val operator: String

open override val requestId: String

open override val size: Int

open override val state: S

open override val version: Int

Functions

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

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

open override fun copy(): StateEvent<S>

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

fun NamedAggregate.generateId(): String

getContextAlias

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

fun DomainEventStream.ignoreSourcing(): Boolean

fun NamedAggregate.isLocal(): Boolean

isSameAggregateName

open override fun isSameAggregateName(other: NamedAggregate): Boolean

isSameBoundedContext

open override fun isSameBoundedContext(other: NamedBoundedContext): Boolean

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

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

fun NamedAggregate.materialize(): MaterializedNamedAggregate

mergeAnnotations

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

requiredAggregateType

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

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

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

toEventNamedAggregate

fun NamedAggregate.toEventNamedAggregate(eventName: String): EventNamedAggregate

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

toNamedAggregateString

fun NamedAggregate.toNamedAggregateString(): String

toStateAggregate

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

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

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

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

open override fun withReadOnly(): DomainEventStream