query/me.ahoo.wow.query.dataset/DatasetQueryGateways/Companion/of

of

fun of(datasets: QueryDatasets, requireServable: (QueryDataset) -> Unit = {}, create: (QueryDataset) -> DatasetQueryGateway): DatasetQueryGateways

The gateways of datasets, each created for its dataset, now and whenever one joins or changes; a dataset that is unavailable gets one that answers every query with why. requireServable refuses a dataset no gateway can be made for (no backend serves its binding, say) before it joins. A gateway is created once the change is applied, so it reads the schema of the declaration it serves: build this after the Catalog that follows the same datasets.

@JvmStatic

@JvmOverloads

@InternalWowApi

fun of(datasets: QueryDatasets, catalog: QuerySchemaCatalog, bindings: QueryBindings<QueryDataset>, filters: List<QueryFilter> = emptyList(), policies: List<QueryPolicy> = emptyList(), observer: QueryObserver = QueryObserver.NONE, entryPolicy: QueryEntryPolicy = QueryEntryPolicy.DEFAULT, bulkhead: (AggregateType) -> QueryBulkhead? = { null }, authorizer: ReadAuthorizer = ReadAuthorizer.ALLOW_ALL): DatasetQueryGateways

The gateways of datasets, each over the backend bindings gives and the schema catalog compiles for it (a Catalog built over the same datasets and bindings, see QueryBackendStorages); a dataset bindings do not serve is refused before it joins. Each dataset's queries run under the bulkhead it gives, none by default.