InProcessQueryApi

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.

Constructors

Link copied to clipboard
constructor(engine: QueryEngine, models: ReadModels, latest: CommittedStates = CommittedStates.NONE, defaultListSize: Int = DEFAULT_LIST_SIZE, chunkSize: Int = QueryGateway.DEFAULT_STREAM_CHUNK_SIZE)

Types

Link copied to clipboard
object Companion

Functions

Link copied to clipboard
open override fun of(caller: Caller): Queries
Link copied to clipboard
open override fun tenant(tenantId: String): SubscriptionQueries

The queries of a subscription handler of a commit of tenantId: trusted code whose authenticated scope pins tenantId, so it reads that whole tenant and no other, and SubscriptionQueries.trusted for the rest. A type whose tenant is fixed to another one shows such queries nothing.

Link copied to clipboard
open override fun trusted(): TrustedQueries