wow-redis/me.ahoo.wow.redis.eventsourcing/RedisEventStore

RedisEventStore

class RedisEventStore(redisTemplate: ReactiveStringRedisTemplate) : AbstractEventStore

Constructors

RedisEventStore

constructor(redisTemplate: ReactiveStringRedisTemplate)

Types

object Companion

Functions

existsRequestId

open override fun existsRequestId(aggregateId: AggregateId, requestId: String): Mono<Boolean>

open override fun last(aggregateId: AggregateId): Mono<DomainEventStream>

scanAggregateId

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