Package-level declarations
Types
Link copied to clipboard
class AggregateSnapshotDispatcher( snapshotHandler: SnapshotHandler, val namedAggregate: NamedAggregate, val name: String = "-", val parallelism: Int = MessageParallelism.DEFAULT_PARALLELISM, val scheduler: Scheduler, val messageFlux: Flux<StateEventExchange<*>>) : AggregateMessageDispatcher<StateEventExchange<*>> , ProcessorInfo
Link copied to clipboard
class DefaultSnapshotHandler( chain: FilterChain<StateEventExchange<*>>, errorHandler: ErrorHandler<StateEventExchange<*>> = LogResumeErrorHandler()) : AbstractHandler<StateEventExchange<*>> , SnapshotHandler
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
data class SimpleSnapshot<S : Any>( val delegate: ReadOnlyStateAggregate<S>, val snapshotTime: Long = System.currentTimeMillis()) : Snapshot<S> , ReadOnlyStateAggregate<S> , Decorator<ReadOnlyStateAggregate<S>>
Link copied to clipboard
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)) : AbstractDispatcher<StateEventExchange<*>> , MessageDispatcher
Link copied to clipboard
class SnapshotFunctionFilter(snapshotStrategy: SnapshotStrategy) : ExchangeFilter<StateEventExchange<*>>
Link copied to clipboard
Link copied to clipboard
Snapshot Repository.
Link copied to clipboard
interface SnapshotStrategy
SnapshotStrategy .
Link copied to clipboard
class VersionOffsetSnapshotStrategy(versionOffset: Int = DEFAULT_VERSION_OFFSET, snapshotRepository: SnapshotRepository) : SnapshotStrategy