wow-core/me.ahoo.wow.eventsourcing.snapshot

Package-level declarations

Types

AggregateSnapshotDispatcher

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

DefaultSnapshotHandler

class DefaultSnapshotHandler(chain: FilterChain<StateEventExchange<*>>, errorHandler: ErrorHandler<StateEventExchange<*>> = LogResumeErrorHandler()) : AbstractHandler<StateEventExchange<*>> , SnapshotHandler

InMemorySnapshotRepository

class InMemorySnapshotRepository : SnapshotRepository

NoOpSnapshotRepository

object NoOpSnapshotRepository : SnapshotRepository

data class SimpleSnapshot<S : Any>(val delegate: ReadOnlyStateAggregate<S>, val snapshotTime: Long = System.currentTimeMillis()) : Snapshot<S> , ReadOnlyStateAggregate<S> , Decorator<ReadOnlyStateAggregate<S>>

SimpleSnapshotStrategy

class SimpleSnapshotStrategy(snapshotRepository: SnapshotRepository) : SnapshotStrategy

interface Snapshot<S : Any> : ReadOnlyStateAggregate<S>

SnapshotDispatcher

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

SnapshotFunctionFilter

@Order(value = 0)

class SnapshotFunctionFilter(snapshotStrategy: SnapshotStrategy) : ExchangeFilter<StateEventExchange<*>>

SnapshotHandler

interface SnapshotHandler : Handler<StateEventExchange<*>>

SnapshotRepository

interface SnapshotRepository : AggregateIdScanner

Snapshot Repository.

SnapshotStrategy

interface SnapshotStrategy

SnapshotStrategy .

VersionOffsetSnapshotStrategy

class VersionOffsetSnapshotStrategy(versionOffset: Int = DEFAULT_VERSION_OFFSET, snapshotRepository: SnapshotRepository) : SnapshotStrategy

Properties

DEFAULT_VERSION_OFFSET

const val DEFAULT_VERSION_OFFSET: Int = 5

SNAPSHOT_FUNCTION

val SNAPSHOT_FUNCTION: FunctionInfoData

Functions

fun <S : Any> Snapshot<S>.materialize(): MaterializedSnapshot<S>