wow-query/me.ahoo.wow.query.event

Package-level declarations

Types

AbstractEventStreamQueryServiceFactory

abstract class AbstractEventStreamQueryServiceFactory : EventStreamQueryServiceFactory

EventStreamQueryService

interface EventStreamQueryService : QueryService<DomainEventStream>

EventStreamQueryServiceFactory

fun interface EventStreamQueryServiceFactory

NoOpEventStreamQueryService

class NoOpEventStreamQueryService(val namedAggregate: NamedAggregate) : EventStreamQueryService

NoOpEventStreamQueryServiceFactory

object NoOpEventStreamQueryServiceFactory : EventStreamQueryServiceFactory

RoutingEventStreamQueryServiceFactory

class RoutingEventStreamQueryServiceFactory(defaultEventStreamQueryServiceFactory: EventStreamQueryServiceFactory, routes: Map<NamedAggregate, EventStreamQueryServiceFactory>) : EventStreamQueryServiceFactory

Functions

fun Condition.count(queryService: EventStreamQueryService): Mono<Long>

fun IListQuery.dynamicQuery(queryService: EventStreamQueryService): Flux<DynamicDocument>

fun IPagedQuery.dynamicQuery(queryService: EventStreamQueryService): Mono<PagedList<DynamicDocument>>

fun ISingleQuery.dynamicQuery(queryService: EventStreamQueryService): Mono<DynamicDocument>

fun IListQuery.query(queryService: EventStreamQueryService): Flux<DomainEventStream>

fun IPagedQuery.query(queryService: EventStreamQueryService): Mono<PagedList<DomainEventStream>>

fun ISingleQuery.query(queryService: EventStreamQueryService): Mono<DomainEventStream>