clickhouse/me.ahoo.wow.clickhouse.sink/CatalogEntry

CatalogEntry

data class CatalogEntry(val table: String, val role: String, val service: String, val context: String, val aggregate: String, val ownership: String, val tenantColumn: String, val ownerColumn: String, val spaceColumn: String, val sensitive: List<CatalogSensitive>, val references: List<CatalogReference>, val eventRevisions: Map<String, Int>, val columnsHash: String, val access: String = "")

What the Sink adds to the warehouse's own metadata of one of its tables, one row of wow_catalog (ClickHouseCatalog): who the table is of, by the Manifest and never by its name.

table, role: the table and what it is of the aggregate (state_events, state, events, state_flat).
service, context, aggregate: the aggregate's identity; ownership its ownership (OWNER or TENANT).
tenantColumn, ownerColumn, spaceColumn: the scope's columns; the owner's is empty for a tenant's resource.
sensitive: each sensitive value by its path from the column that holds it (state.customer.phone, payload.card, a flat column's name), an event's by its name and revision too.
references: each value that refers to an aggregate, by path.
eventRevisions: the revision of each event of the aggregate.
columnsHash: ClickHouseCatalog.columnsHash of the columns the Sink expects the table to have.
access: whether the aggregate's rows are read by an access policy of its own (ClickHouseCatalog.ACCESS_POLICY) or by the default rule, its scope's columns (ClickHouseCatalog.ACCESS_DEFAULT), as the service that has the policies decides; empty when the Sink was told neither, which a reader takes as a policy's.
fingerprint: a digest of all of the above, the key a row replaces an older one of the same content by.

Constructors

CatalogEntry

constructor(table: String, role: String, service: String, context: String, aggregate: String, ownership: String, tenantColumn: String, ownerColumn: String, spaceColumn: String, sensitive: List<CatalogSensitive>, references: List<CatalogReference>, eventRevisions: Map<String, Int>, columnsHash: String, access: String = "")