using forked influxdb-rust until upstream merges a feature

Author: bogdad

Cargo.lock

@@ -11,7 +11,7 @@ rand_distr = "0.4.3"
 num-format = "0.4.3"
 metriki-core = "1.7.4"
 derive_builder = "0.12.0"
-influxdb = {version="0.5.2", features=["reqwest"], path="../../influxdb-rust/influxdb"}
+influxdb = { git = 'https://github.com/bogdad/influxdb-rust', branch = 'main' }
 tokio = { version = "1.0", default-features = false, features = ["net", "time"] }
 futures = "0.3.26"
 reqwest= "0.11.14"

Cargo.toml

@@ -18,6 +18,7 @@ services:
       - DOCKER_INFLUXDB_INIT_PASSWORD=adminadminadmin
       - DOCKER_INFLUXDB_INIT_ORG=noorg
       - DOCKER_INFLUXDB_INIT_BUCKET=grafana
+      - DOCKER_INFLUXDB_INIT_ADMIN_TOKEN=secrettokentoken
     volumes:
       - influxdb:/var/lib/influxdb
     networks:

docker/docker-compose.yml

@@ -56,7 +56,7 @@ impl InfluxDbReporter {
             username: None,
             password: None,
             auth_token: env::var("AUTH_TOKEN").ok(),
-            measurement_prefix: "sdm".to_string(),
+            measurement_prefix: "sdm_".to_string(),
             tags: HashMap::new(),
             batch_size: 60,
             event_rx: event_rx,
@@ -70,7 +70,7 @@ impl InfluxDbReporter {
         if let (Some(username), Some(password)) = (self.username.as_ref(), self.password.as_ref()) {
             client.with_auth(username, password)
         } else if let Some(auth_token) = &self.auth_token {
-            client.with_auth_token(auth_token)
+            client.with_token(auth_token)
         } else {
             client
         }