wow-dataset-registry-starter/me.ahoo.wow.datasetregistry.starter

Package-level declarations

Types

class ClickHouseDatasetTableInspector(executor: ClickHouseExecutor, defaultDatabase: String, sources: Map<String, ClickHouseSource> = emptyMap()) : DatasetTableInspector

Drafts a dataset from a ClickHouse table, database.table or a table of its source's default database, by its system.columns (ClickHouseDatasetDrafts): in the default source (executor, defaultDatabase) or in one of the named sources.

CompilingDatasetPublicationCheck

class CompilingDatasetPublicationCheck(datasets: QueryDatasets, registered: () -> Set<MaterializedNamedAggregate>, aggregates: Set<MaterializedNamedAggregate>, factory: DatasetQueryBackendFactory?) : DatasetPublicationCheck

Proves this instance can serve a dataset before the registry publishes it: its name is not an aggregate's of its context nor a declaration file's dataset, a dataset backend serves datasets here, and the declaration compiles against its table as the Catalog will compile it.

DatasetRegistryAutoConfiguration

@AutoConfiguration(after = [QuerySchemaAutoConfiguration::class, QueryAutoConfiguration::class, ClickHouseDatasetAutoConfiguration::class])

@ConditionalOnProperty(value = ["wow.dataset-registry.enabled"], matchIfMissing = true, havingValue = "true")

@ConditionalOnBean(value = [QueryDatasets::class])

@EnableConfigurationProperties(value = [DatasetRegistryProperties::class])

class DatasetRegistryAutoConfiguration

Embeds the dataset registry (dataset platform design §4) in a Wow service: the Dataset aggregate's ports, and the projection that serves its published datasets on this instance beside those of wow.query.datasets.

DatasetRegistryErrorStatuses

object DatasetRegistryErrorStatuses

The HTTP status of each of the dataset registry's error codes.

DatasetRegistryProjection

class DatasetRegistryProjection(datasets: QueryDatasets, source: PublishedDatasetSource, interval: Duration) : SmartLifecycle

Serves the registry's published datasets on this instance (dataset platform design §4.3): it reads them now and every interval, and adds, replaces or removes them in datasets. Reading the published versions, rather than following the registry's events, lets every instance converge on them whichever one handled a command.

DatasetRegistryProperties

@ConfigurationProperties(prefix = "wow.dataset-registry")

class DatasetRegistryProperties(var enabled: Boolean = true, var refreshInterval: Duration = Duration.ofSeconds(30)) : EnabledCapable

The dataset registry's settings.

PublishedDataset

data class PublishedDataset(val name: String, val version: Int, val document: ObjectNode)

One published dataset: its name ({context}.{dataset}), its version and the declaration served.

PublishedDatasetSource

fun interface PublishedDatasetSource

Where the projection reads the published datasets from.

SnapshotPublishedDatasetSource

class SnapshotPublishedDatasetSource(snapshotQueryGateway: () -> SnapshotQueryGateway<DatasetState>) : PublishedDatasetSource

The published datasets of the registry's snapshots.