query/me.ahoo.wow.query.read

Package-level declarations

Types

class InProcessQueryApi @InternalWowApi constructor(engine: QueryEngine, models: ReadModels, latest: CommittedStates = CommittedStates.NONE, defaultListSize: Int = DEFAULT_LIST_SIZE, chunkSize: Int = QueryGateway.DEFAULT_STREAM_CHUNK_SIZE) : TenantQueryApi

The node's QueryApi: a thin layer over the engine's gateways and read facade, so a query asked in process is admitted, scoped, hidden, bulkheaded, budgeted and resumed as the same query over the public port is; only the rows differ, decoded as the models' classes rather than written as JSON.

QueryNotServedException

class QueryNotServedException(val type: AggregateType, val model: QueryModel) : IllegalArgumentException

This node serves no model query of type: no backend of its store queries it, as on a store whose type has no query provider or with wow.query.memory.enabled false. An IllegalArgumentException, as me.ahoo.wow.api.read.Queries documents, so code that reads a model only where it is served can tell this case from a query it got wrong.

ReadModels

@InternalWowApi

class ReadModels(models: Collection<ReadModels.Model>)

The classes of the node's aggregate models (the kernel's AggregateModels, which :query does not see): each aggregate type's state class and its events' classes by name, so the typed me.ahoo.wow.api.read.QueryApi finds a type by its state class and decodes rows as the model's classes.