Package-level declarations
Types
Link copied to clipboard
class AggregateSnapshotDispatcher(val name: String = "-", val namedAggregate: NamedAggregate, val messageFlux: Flux<StateEventExchange<*>>, val parallelism: Int = MessageParallelism.DEFAULT_PARALLELISM, snapshotHandler: SnapshotHandler, val scheduler: Scheduler) : AggregateDispatcher<StateEventExchange<*>> , ProcessorInfo
Dispatcher for handling snapshot operations on state events for a specific aggregate. Routes state event exchanges to the snapshot handler for processing.
Link copied to clipboard
class DefaultSnapshotHandler(chain: FilterChain<StateEventExchange<*>>, errorHandler: ErrorHandler<StateEventExchange<*>> = LogResumeErrorHandler()) : SnapshotHandler, AbstractHandler<StateEventExchange<*>>
Link copied to clipboard
class SnapshotDispatcher(val name: String, val namedAggregates: Set<NamedAggregate> = MetadataSearcher.namedAggregateType.keys.toSet(), snapshotHandler: SnapshotHandler, stateEventBus: StateEventBus, parallelism: Int = MessageParallelism.DEFAULT_PARALLELISM, schedulerSupplier: AggregateSchedulerSupplier = DefaultAggregateSchedulerSupplier(SNAPSHOT_PROCESSOR_NAME)) : MainDispatcher<StateEventExchange<*>>
Link copied to clipboard
class SnapshotFunctionFilter(snapshotStrategy: SnapshotStrategy) : ExchangeFilter<StateEventExchange<*>>
Link copied to clipboard