Package-level declarations
Types
Link copied to clipboard
interface AggregateProcessor<C : Any> : AggregateIdCapable, NamedTypedAggregate<C> , MonoMessageProcessor<C, ServerCommandExchange<*>, Mono<DomainEventStream>>
Processor for handling commands on a specific aggregate instance.
Link copied to clipboard
Factory interface for creating aggregate processors.
Link copied to clipboard
interface CommandAggregate<C : Any, S : Any> : NamedTypedAggregate<C> , AggregateProcessor<C> , Version
Represents a command aggregate that processes commands and manages state transitions.
Link copied to clipboard
Factory interface for creating command aggregate instances.
Link copied to clipboard
class CommandExpectVersionConflictException(val command: CommandMessage<*>, val expectVersion: Int, val actualVersion: Int, cause: Throwable? = null) : WowException
Link copied to clipboard
class IllegalAccessDeletedAggregateException(val aggregateId: AggregateId, errorMsg: String = "Illegal access to a deleted aggregate[") : AggregateIdCapable, WowException
Link copied to clipboard
class IllegalAccessOwnerAggregateException(val aggregateId: AggregateId, errorMsg: String = "Illegal access to a owner aggregate[") : WowException, AggregateIdCapable
Exception thrown when attempting to access an aggregate owned by another tenant or user.
Link copied to clipboard
class IllegalAccessSpaceAggregateException(val aggregateId: AggregateId, errorMsg: String = "Illegal access to a space aggregate[") : WowException, AggregateIdCapable
Link copied to clipboard
class RetryableAggregateProcessorFactory(stateAggregateFactory: StateAggregateFactory, stateAggregateRepository: StateAggregateRepository, commandAggregateFactory: CommandAggregateFactory, maxRetries: Long = RetryableAggregateProcessor.DEFAULT_MAX_RETRIES) : AggregateProcessorFactory
Factory that creates retryable aggregate processors.
Link copied to clipboard
class SimpleCommandAggregateFactory(eventStore: EventStore, messagePropagator: MessagePropagators = MessagePropagators.DEFAULT) : CommandAggregateFactory
Factory for creating SimpleCommandAggregate instances.