diff --git a/src/influx.rs b/src/influx.rs index 95e86d5..1ec8d35 100644 --- a/src/influx.rs +++ b/src/influx.rs @@ -218,6 +218,8 @@ impl InfluxWriter { self.tx.send(Some(m)) } + pub fn nanos(&self, d: DateTime) -> i64 { nanos(d) as i64 } + pub fn tx(&self) -> Sender> { self.tx.clone() }