clickhouse/me.ahoo.wow.clickhouse.sink/ClickHouseSinks

ClickHouseSinks

@InternalWowApi

class ClickHouseSinks

The ClickHouse Sinks of a service: sinkOf gives the ClickHouseSink of an aggregate the manifest declares, its tables in options' database, its flat view's columns from the aggregate's state schema in the Manifest's $defs (FlatColumns).

The runtime assembles them as the published streams' sinks, PublishedSinks(published, PROCESSOR) { context, stream -> sinks.sinkOf(context, stream.aggregate) }, so each is a sink subscription named clickhouse-sink.<aggregate>.

Constructors

ClickHouseSinks

constructor(client: Client, manifest: Manifest, options: ClickHouseSinkOptions = ClickHouseSinkOptions(), governed: GovernedAggregates? = null)

The Sinks over a client-v2 client; the client is the caller's to close.

Types

@InternalWowApi

object Companion

Properties

val options: ClickHouseSinkOptions

Functions

fun catalogOf(type: AggregateType): List<CatalogEntry>

The wow_catalog entries of type's tables.

fun schemaOf(type: AggregateType): ClickHouseSinkSchema

The tables and views of type.

fun sinkOf(context: String, aggregate: String): ClickHouseSink

The Sink of aggregate of context.

open override fun toString(): String