Use nanosecond timestamps

2022-06-15 17:00:34 -07:00 · 2022-06-15 17:00:34 -07:00 · c474999f6a
commit c474999f6a
parent fa2542f361
1 changed files with 2 additions and 2 deletions
--- a/src/main.rs
+++ b/src/main.rs
@ -145,11 +145,11 @@ async fn handle_publish(
    let timestamp = timestamp.unwrap_or_else(|| SystemTime::now()
        .duration_since(UNIX_EPOCH)
        .unwrap()
-        .as_millis()
+        .as_nanos()
    );

    for database in databases.iter() {
-        let mut query = Timestamp::Milliseconds(timestamp)
+        let mut query = Timestamp::Nanoseconds(timestamp)
            .into_query(&database.measurement)
            .add_field(&field_name, influx_value.clone());
        for tag in mapping.tags.iter() {