wow-query/me.ahoo.wow.query/AbstractQueryGateway

AbstractQueryGateway

abstract class AbstractQueryGateway<R : Any>(val namedAggregate: NamedAggregate, binding: QueryBackendBinding<QueryBackend>, targetType: JavaType, filters: List<QueryFilter>, filterType: KClass<*>, policies: List<QueryPolicy>, observer: QueryObserver) : QueryGateway<R>

Inheritors

DefaultEventStreamQueryGateway

DefaultSnapshotQueryGateway

Constructors

AbstractQueryGateway

constructor(namedAggregate: NamedAggregate, binding: QueryBackendBinding<QueryBackend>, targetType: JavaType, filters: List<QueryFilter>, filterType: KClass<*>, policies: List<QueryPolicy>, observer: QueryObserver)

Properties

open override val namedAggregate: NamedAggregate

Functions

open override fun aggregate(query: AggregationQuery): Flux<ObjectNode>

open override fun count(filter: FilterExpression): Mono<Long>

open override fun cursor(query: ICursorQuery): Mono<CursorPage<R>>

open override fun dynamicCursor(query: ICursorQuery): Mono<CursorPage<ObjectNode>>

open override fun dynamicList(query: IListQuery): Flux<ObjectNode>

open override fun dynamicPaged(query: IPagedQuery): Mono<PagedList<ObjectNode>>

open override fun dynamicSingle(query: ISingleQuery): Mono<ObjectNode>

open override fun list(query: IListQuery): Flux<R>

open override fun paged(query: IPagedQuery): Mono<PagedList<R>>

open override fun single(query: ISingleQuery): Mono<R>