clickhouse-dfe 0.1.2

HyperI extensions for the official ClickHouse Rust client: TCP transport, dynamic inserts, unified client
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63

// SPDX-License-Identifier: Apache-2.0
// Copyright (c) 2026 HYPERI PTY LIMITED

// Project:   clickhouse-dfe
// File:      src/dynamic/error.rs
// Purpose:   DynamicError for schema-driven inserts
// Language:  Rust
//
// License:   Apache-2.0
// Copyright: (c) 2026 HYPERI PTY LIMITED

//! Error types for dynamic (schema-driven) inserts.

/// Errors specific to dynamic schema-driven inserts.
///
/// `#[non_exhaustive]`: a caller matching on this must carry a `_` arm. The
/// variants stay constructible so a consumer can build one in its own tests.
#[derive(Debug, thiserror::Error)]
#[non_exhaustive]
pub enum DynamicError {
    /// Column type string could not be parsed.
    #[error("unsupported type '{type_str}' for column '{column}'")]
    UnsupportedType {
        /// Column the type was declared on.
        column: String,
        /// The type string as `system.columns` reported it.
        type_str: String,
    },
    /// Value could not be encoded for the target column type.
    #[error("encoding error for column '{column}': {message}")]
    EncodingError {
        /// Column the value belonged to; empty for a whole-row failure.
        column: String,
        /// What the encoder could not do.
        message: String,
    },
    /// Schema mismatch detected -- server rejected the insert. Retriable once
    /// the cached schema is invalidated.
    #[error("schema mismatch for table '{table}': {message}")]
    SchemaMismatch {
        /// Fully qualified `database.table`.
        table: String,
        /// The server's rejection text.
        message: String,
    },
    /// Schema fetch from `system.columns` failed. Retriable: a cold cache
    /// after a restart hits this on a transport blip.
    #[error("failed to fetch schema for '{table}': {source}")]
    SchemaFetch {
        /// Fully qualified `database.table`.
        table: String,
        /// The query failure, kept typed so a caller can classify it.
        #[source]
        source: clickhouse::error::Error,
    },
    /// Table has no columns (or does not exist). Retriable against a cluster
    /// that is still replicating the DDL.
    #[error("table '{table}' has no columns or does not exist")]
    EmptySchema {
        /// Fully qualified `database.table`.
        table: String,
    },
}