robotech 1.8.0

Backend service implementation for the RoboTech platform, providing RESTful APIs and business logic for web applications.
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22

use crate::tsdb::influxdb::influxdb_error::InfluxdbError;
use crate::tsdb::influxdb::InfluxdbConfig;
use influxdb::Client;
use reqwest::ClientBuilder;

pub fn build_influxdb_client(config: InfluxdbConfig) -> Result<Client, InfluxdbError> {
    let InfluxdbConfig {
        url,
        bucket,
        token,
        pool_max_size,
        ..
    } = config;
    let mut client = Client::new(url, bucket);
    client = client.with_token(token);
    client = client.with_http_client(
        ClientBuilder::new()
            .pool_max_idle_per_host(pool_max_size)
            .build()?,
    );
    Ok(client)
}