|
@@ -207,6 +207,8 @@ impl InfluxWriter { |
|
|
|
|
|
|
|
|
pub fn dur_nanos(&self, d: Duration) -> i64 { dur_nanos(d) as i64 } |
|
|
pub fn dur_nanos(&self, d: Duration) -> i64 { dur_nanos(d) as i64 } |
|
|
|
|
|
|
|
|
|
|
|
pub fn dur_nanos_u64(&self, d: Duration) -> u64 { dur_nanos(d).max(0) as u64 } |
|
|
|
|
|
|
|
|
pub fn tx(&self) -> Sender<Option<OwnedMeasurement>> { |
|
|
pub fn tx(&self) -> Sender<Option<OwnedMeasurement>> { |
|
|
self.tx.clone() |
|
|
self.tx.clone() |
|
|
} |
|
|
} |
|
|