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

Package-level declarations

Types

AbstractEventStreamQueryBackendFactory

abstract class AbstractEventStreamQueryBackendFactory : EventStreamQueryBackendFactory

DefaultEventStreamQueryGateway

class DefaultEventStreamQueryGateway(namedAggregate: NamedAggregate, binding: QueryBackendBinding<EventStreamQueryBackend>, filters: List<QueryFilter> = emptyList(), policies: List<QueryPolicy> = emptyList(), observer: QueryObserver = QueryLogObserver()) : EventStreamQueryGateway, AbstractQueryGateway<DomainEventStream>

EventStreamQueryBackend

interface EventStreamQueryBackend : QueryBackend

EventStreamQueryBackendFactory

fun interface EventStreamQueryBackendFactory

EventStreamQueryGateway

interface EventStreamQueryGateway : QueryGateway<DomainEventStream>

NoOpEventStreamQueryBackend

class NoOpEventStreamQueryBackend(val namedAggregate: NamedAggregate) : EventStreamQueryBackend

NoOpEventStreamQueryBackendFactory

object NoOpEventStreamQueryBackendFactory : AbstractEventStreamQueryBackendFactory

RoutingEventStreamQueryBackendFactory

class RoutingEventStreamQueryBackendFactory(defaultFactory: EventStreamQueryBackendFactory, routes: Map<NamedAggregate, EventStreamQueryBackendFactory>) : EventStreamQueryBackendFactory

Functions

fun Condition.~~count~~(queryGateway: EventStreamQueryGateway): Mono<Long>

fun FilterExpression.count(queryGateway: EventStreamQueryGateway): Mono<Long>

fun ICursorQuery.dynamicQuery(queryGateway: EventStreamQueryGateway): Mono<CursorPage<ObjectNode>>

fun IListQuery.dynamicQuery(queryGateway: EventStreamQueryGateway): Flux<ObjectNode>

fun IPagedQuery.dynamicQuery(queryGateway: EventStreamQueryGateway): Mono<PagedList<ObjectNode>>

fun ISingleQuery.dynamicQuery(queryGateway: EventStreamQueryGateway): Mono<ObjectNode>

fun AggregationQuery.query(queryGateway: EventStreamQueryGateway): Flux<ObjectNode>

Executes this aggregation against persisted event-stream documents.

fun ICursorQuery.query(queryGateway: EventStreamQueryGateway): Mono<CursorPage<DomainEventStream>>

fun IListQuery.query(queryGateway: EventStreamQueryGateway): Flux<DomainEventStream>

fun IPagedQuery.query(queryGateway: EventStreamQueryGateway): Mono<PagedList<DomainEventStream>>

fun ISingleQuery.query(queryGateway: EventStreamQueryGateway): Mono<DomainEventStream>