Struct Config

pub struct Config<TMsg> {
    pub host: String,
    pub port: u16,
    pub org: String,
    pub bucket: String,
    pub token: String,
    pub fn_input: fn(&Message<TMsg>) -> Option<Vec<LineProtocolItem>>,
}

Конфигурация cmp_influxdb

Fields

host: String

Примеры

host: String::from("influxdb"),

port: u16

Порт базы данных

org: String

Огранизация

bucket: String

Bucket

token: String

Токен

fn_input: fn(&Message<TMsg>) -> Option<Vec<LineProtocolItem>>

Функция преобразования сообщения в строки протокола InfluxDB

Примеры

Заглушка

fn_input: |_| None,

Сохранение Custom

fn_input: |msg: &Message<Custom>| {
    let value = match &msg.data {
        MsgData::Custom(data) => match data {
            Custom::ValueInstantF64(data) => {
                cmp_influxdb::ValueType::f64(*data)
            }
            _ => return None,
        },
        _ => return None,
    };
    let line = cmp_influxdb::LineProtocolItem::new(&msg.key, value, &msg.ts);
    Some(vec![line])
},

Trait Implementations

impl<TMsg: Clone> Clone for Config<TMsg>

fn clone(&self) -> Config<TMsg>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<TMsg: Debug> Debug for Config<TMsg>

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

Formats the value using the given formatter.