wow-core/me.ahoo.wow.modeling.matedata/CommandAggregateMetadata

CommandAggregateMetadata

data class CommandAggregateMetadata<C : Any>(val aggregateType: Class<C>, val namedAggregate: NamedAggregate, val constructorAccessor: ConstructorAccessor<C>, val mountedCommands: Set<Class<*>>, val commandFunctionRegistry: Map<Class<*>, FunctionAccessorMetadata<C, Mono<*>>>, val errorFunctionRegistry: Map<Class<*>, FunctionAccessorMetadata<C, Mono<*>>>) : NamedTypedAggregate<C> , NamedAggregateDecorator, Metadata, ProcessorInfo

Constructors

CommandAggregateMetadata

constructor(aggregateType: Class<C>, namedAggregate: NamedAggregate, constructorAccessor: ConstructorAccessor<C>, mountedCommands: Set<Class<*>>, commandFunctionRegistry: Map<Class<*>, FunctionAccessorMetadata<C, Mono<*>>>, errorFunctionRegistry: Map<Class<*>, FunctionAccessorMetadata<C, Mono<*>>>)

Properties

abstract val aggregateName: String

open override val aggregateType: Class<C>

commandFunctionRegistry

val commandFunctionRegistry: Map<Class<*>, FunctionAccessorMetadata<C, Mono<*>>>

constructorAccessor

val constructorAccessor: ConstructorAccessor<C>

abstract val contextName: String

errorFunctionRegistry

val errorFunctionRegistry: Map<Class<*>, FunctionAccessorMetadata<C, Mono<*>>>

mountedCommands

val mountedCommands: Set<Class<*>>

open override val namedAggregate: NamedAggregate

open override val processorName: String

registeredCommands

val registeredCommands: List<Class<*>>

registeredDeleteAggregate

val registeredDeleteAggregate: Boolean

registeredRecoverAggregate

val registeredRecoverAggregate: Boolean

Functions

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

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

open operator override fun equals(other: Any?): Boolean

fun NamedAggregate.generateId(): String

getContextAlias

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

open override fun hashCode(): Int

fun NamedAggregate.isLocal(): Boolean

isSameAggregateName

open fun isSameAggregateName(other: NamedAggregate): Boolean

isSameBoundedContext

open fun isSameBoundedContext(other: NamedBoundedContext): Boolean

fun NamedAggregate.materialize(): MaterializedNamedAggregate

requiredAggregateType

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

toCommandFunctionRegistry

fun toCommandFunctionRegistry(commandAggregate: CommandAggregate<C, *>): Map<Class<*>, MessageFunction<C, ServerCommandExchange<*>, Mono<DomainEventStream>>>

toErrorFunctionRegistry

fun toErrorFunctionRegistry(commandAggregate: CommandAggregate<C, *>): Map<Class<*>, MessageFunction<C, ServerCommandExchange<*>, Mono<*>>>

toEventNamedAggregate

fun NamedAggregate.toEventNamedAggregate(eventName: String): EventNamedAggregate

toNamedAggregateString

fun NamedAggregate.toNamedAggregateString(): String

open override fun toString(): String

toStringWithAlias

fun NamedAggregate.toStringWithAlias(): String