vector/sinks/greptimedb/
mod.rs

1use crate::sinks::prelude::*;
2
3// sub level implementations
4mod logs;
5mod metrics;
6
7fn default_dbname() -> String {
8    greptimedb_ingester::DEFAULT_SCHEMA_NAME.to_string()
9}
10
11fn default_dbname_template() -> Template {
12    Template::try_from(default_dbname()).unwrap()
13}
14
15fn default_pipeline_template() -> Template {
16    Template::try_from("greptime_identity").unwrap()
17}
18
19#[derive(Clone, Copy, Debug, Default)]
20struct GreptimeDBDefaultBatchSettings;
21
22impl SinkBatchSettings for GreptimeDBDefaultBatchSettings {
23    const MAX_EVENTS: Option<usize> = Some(20);
24    const MAX_BYTES: Option<usize> = None;
25    const TIMEOUT_SECS: f64 = 1.0;
26}