Struct DistributedCheckSection 

pub struct DistributedCheckSection {
    pub cluster: String,
    pub table: String,
    pub sharding_key: Option<String>,
    pub sharding_expr: Option<String>,
    pub endpoint: Option<String>,
}

The opt-in distributed_check: block — a startup guard verifying that the sink config, the cluster topology, and the Distributed table’s DDL agree (see ClickHouseSink::validate_distributed).

sink:
  clickhouse:
    distributed_check:
      cluster: prod
      table: analytics.events_dist   # db-qualified, or bare like `table`
      sharding_key: sensor           # expected DDL expr = xxHash64(sensor)
      # sharding_expr: "xxHash64(sensor)"  # escape hatch — exactly one
      # endpoint: "http://ch-front:8123"   # default: shard 0, replica 0

Fields

cluster: String

The cluster the Distributed table is defined over.

table: String

The Distributed table to check, optionally db.table-qualified (an unqualified name resolves like the sink table).

sharding_key: Option<String>

The sharding key column; the expected DDL expression becomes xxHash64(<sharding_key>). Exactly one of this or sharding_expr.

sharding_expr: Option<String>

Escape hatch: the full expected sharding expression, compared textually after normalization (whitespace and identifier quoting stripped) — inherently more brittle than sharding_key.

endpoint: Option<String>

Endpoint to query for system.clusters / system.tables. The Distributed table may live on a front node outside the shards: list; defaults to the first replica of shard 0.

Trait Implementations

impl Clone for DistributedCheckSection

fn clone(&self) -> DistributedCheckSection

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for DistributedCheckSection

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for DistributedCheckSection

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for DistributedCheckSection

fn eq(&self, other: &DistributedCheckSection) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for DistributedCheckSection