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

AbstractQueryGateway

abstract class AbstractQueryGateway<R : Any>(val namedAggregate: NamedAggregate, backend: QueryBackend, schemaProvider: QueryModelSchemaProvider, targetType: JavaType, filters: List<QueryFilter>, filterType: KClass<*>, policies: List<QueryPolicy>, observer: QueryObserver, val entryPolicy: QueryEntryPolicy = QueryEntryPolicy.DEFAULT) : QueryGateway<R>

Inheritors

DefaultEventStreamQueryGateway

DefaultSnapshotQueryGateway

Constructors

AbstractQueryGateway

constructor(namedAggregate: NamedAggregate, backend: QueryBackend, schemaProvider: QueryModelSchemaProvider, targetType: JavaType, filters: List<QueryFilter>, filterType: KClass<*>, policies: List<QueryPolicy>, observer: QueryObserver, entryPolicy: QueryEntryPolicy = QueryEntryPolicy.DEFAULT)

Properties

entryPolicy

override val entryPolicy: QueryEntryPolicy

The entry policy this gateway admits every query under: the one source of each entry's budget.

namedAggregate

open override val namedAggregate: NamedAggregate

Functions

aggregate

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

count

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

cursor

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

describe

open override fun describe(entry: QueryEntry, defaultListSize: Int? = null): Mono<QueryModelDescriptor>

How this model can be queried on entry (design §7): the capability descriptor of the schema this gateway admits against, under the budget entryPolicy gives entry. defaultListSize is the list size the entry's adapter applies when a list query sends none, or null.

dynamicCursor

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

dynamicList

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

dynamicPaged

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

dynamicSingle

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

list

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

paged

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

single

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