wow-opentelemetry/me.ahoo.wow.opentelemetry.snapshot/TracingSnapshotRepository

TracingSnapshotRepository

class TracingSnapshotRepository(val delegate: SnapshotRepository) : SnapshotRepository, Decorator<SnapshotRepository>

Constructors

TracingSnapshotRepository

constructor(delegate: SnapshotRepository)

Properties

open override val delegate: SnapshotRepository

Functions

open override fun getVersion(aggregateId: AggregateId): Mono<Int>

open override fun <S : Any> load(aggregateId: AggregateId): Mono<Snapshot<S>>

open override fun <S : Any> save(snapshot: Snapshot<S>): Mono<Void>

scanAggregateId

open override fun scanAggregateId(namedAggregate: NamedAggregate, afterId: String, limit: Int): Flux<AggregateId>

fun SnapshotRepository.tracing(): SnapshotRepository