wow-core/me.ahoo.wow.projection

Package-level declarations

Types

class DefaultProjectionHandler(chain: FilterChain<DomainEventExchange<*>>, errorHandler: ErrorHandler<DomainEventExchange<*>> = LogResumeErrorHandler()) : AbstractHandler<DomainEventExchange<*>> , ProjectionHandler

Default implementation of ProjectionHandler that uses a filter chain for processing. This handler applies a series of filters to domain event exchanges and handles errors gracefully.

ProjectionDispatcher

class ProjectionDispatcher(val name: String, val parallelism: Int = MessageParallelism.DEFAULT_PARALLELISM, val domainEventBus: DomainEventBus, val stateEventBus: StateEventBus, val functionRegistrar: ProjectionFunctionRegistrar, val eventHandler: ProjectionHandler, schedulerSupplier: AggregateSchedulerSupplier = DefaultAggregateSchedulerSupplier("ProjectionDispatcher")) : AbstractEventDispatcher<Mono<*>>

Dispatcher for projections that handles domain events and coordinates projection processing. This dispatcher extends AbstractEventDispatcher to provide event-driven processing for projections that transform domain events into read models or perform side effects.

ProjectionFunctionFilter

class ProjectionFunctionFilter(serviceProvider: ServiceProvider) : DomainEventFunctionFilter

Filter for projection functions that applies to ProjectionDispatcher. This filter extends DomainEventFunctionFilter to provide filtering capabilities specific to projection processing.

ProjectionFunctionRegistrar

class ProjectionFunctionRegistrar(actual: MessageFunctionRegistrar<MessageFunction<Any, DomainEventExchange<*>, Mono<*>>> = SimpleMessageFunctionRegistrar()) : AbstractEventFunctionRegistrar

Registrar for projection functions that creates message functions from processors annotated with projection metadata.

ProjectionHandler

interface ProjectionHandler : EventHandler

Handler interface for projections that processes domain events. Implementations of this interface handle the execution of projection logic in response to domain events.