One gateway per served dataset (wow.query.datasets, and any that joins later), admitted like an aggregate's: the same filters, policies and entry policy, the Catalog's schema and the dataset backend's storage. Built after the Catalog, so a dataset that changes is recompiled before its new gateway reads its schema.

datasetQueryObserver

@Bean(value = ["datasetQueryObserver"])

@ConditionalOnMissingBean(name = ["datasetQueryObserver"])

fun datasetQueryObserver(meterRegistry: ObjectProvider<MeterRegistry>, environment: Environment): QueryObserver

eventStreamQueryObserver

@Bean(value = ["eventStreamQueryObserver"])

@ConditionalOnMissingBean(name = ["eventStreamQueryObserver"])

fun eventStreamQueryObserver(meterRegistry: ObjectProvider<MeterRegistry>, environment: Environment): QueryObserver

queryEntryPolicy

@Bean

@ConditionalOnMissingBean

fun queryEntryPolicy(queryProperties: QueryProperties, environment: Environment): QueryEntryPolicy

querySchemaCatalog

@Bean

@ConditionalOnMissingBean

fun querySchemaCatalog(snapshotQueryBackendFactories: ObjectProvider<SnapshotQueryBackendFactory>, eventStreamQueryBackendFactories: ObjectProvider<EventStreamQueryBackendFactory>, compiler: ObjectProvider<QueryModelCompiler>, sources: ObjectProvider<QuerySchemaSource>, sensitivity: ObjectProvider<QuerySensitivityPolicy>, meterRegistry: ObjectProvider<MeterRegistry>, environment: Environment, queryProperties: QueryProperties, queryDatasets: ObjectProvider<QueryDatasets>, datasetQueryBackendFactory: ObjectProvider<DatasetQueryBackendFactory>): QuerySchemaCatalog

The Catalog: compiles every aggregate model's schema from the query schema sources, the sensitivity policy and the native facts its storage adapter reports, or with the application's QueryModelCompiler when it registers one. Gateways, point reads and the descriptor route read it.

snapshotQueryObserver

@Bean(value = ["snapshotQueryObserver"])

@ConditionalOnMissingBean(name = ["snapshotQueryObserver"])

fun snapshotQueryObserver(meterRegistry: ObjectProvider<MeterRegistry>, environment: Environment): QueryObserver

unavailableEventStreamQueryBackendFactory

@Bean

@ConditionalOnMissingBean(value = [EventStreamQueryBackendFactory::class])

fun unavailableEventStreamQueryBackendFactory(): EventStreamQueryBackendFactory

unavailableSnapshotQueryBackendFactory

@Bean

@ConditionalOnMissingBean(value = [SnapshotQueryBackendFactory::class])

fun unavailableSnapshotQueryBackendFactory(): SnapshotQueryBackendFactory