spectra-backend-tensorbase 0.1.0

Scale-out TensorBase storage adapter (ClickHouse-compatible protocol)
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

//! TensorBase DDL (ClickHouse-compatible dialect, BaseStorage engine).

use spectra_core::{EVENTS_TABLE, METRICS_TABLE};

/// TensorBase metrics table DDL.
pub fn metrics_ddl() -> String {
    format!(
        r"
CREATE TABLE IF NOT EXISTS {METRICS_TABLE} (
    name String,
    kind String,
    value Float64,
    labels String,
    ts String,
    correlation_id Nullable(String)
) ENGINE = BaseStorage
"
    )
}

/// TensorBase events table DDL.
pub fn events_ddl() -> String {
    format!(
        r"
CREATE TABLE IF NOT EXISTS {EVENTS_TABLE} (
    table_name String,
    fields String,
    ts String,
    correlation_id Nullable(String)
) ENGINE = BaseStorage
"
    )
}

/// Default TensorBase native protocol URL (port 9528).
pub fn default_url(host: &str) -> String {
    format!("tcp://{host}:9528")
}