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

Package-level declarations

Types

AbstractEventStreamQueryBackendFactory

abstract class AbstractEventStreamQueryBackendFactory : AbstractQueryBackendFactory<EventStreamQueryBackend> , EventStreamQueryBackendFactory

DefaultEventStreamQueryGateway

class DefaultEventStreamQueryGateway(namedAggregate: NamedAggregate, backend: EventStreamQueryBackend, schemaProvider: QueryModelSchemaProvider, filters: List<QueryFilter> = emptyList(), policies: List<QueryPolicy> = emptyList(), observer: QueryObserver = QueryLogObserver(), entryPolicy: QueryEntryPolicy = QueryEntryPolicy.DEFAULT) : EventStreamQueryGateway, AbstractQueryGateway<DomainEventStream>

EventStreamQueryBackend

interface EventStreamQueryBackend : QueryBackend

EventStreamQueryBackendFactory

fun interface EventStreamQueryBackendFactory : QueryBackendFactory<EventStreamQueryBackend>

EventStreamQueryGateway

interface EventStreamQueryGateway : QueryGateway<DomainEventStream>

RoutingEventStreamQueryBackendFactory

class RoutingEventStreamQueryBackendFactory(defaultFactory: EventStreamQueryBackendFactory, routes: Map<NamedAggregate, EventStreamQueryBackendFactory>) : RoutingQueryBackendFactory<EventStreamQueryBackend> , 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>