Struct rotor_carbon::Sender

pub struct Sender<'a, C: 'a, S>(_, _) where S: ActiveStream;

The sender object, which has convenience methods to send the data

Note Sender() holds lock on the underlying buffer and doesn't send data, until sender is dropped. This is useful for sending data in single bulk.

Methods

impl<'a, C: 'a, S: ActiveStream> Sender<'a, C, S>

fn add_value<N, V = i64>(&mut self, name: N, value: V) where N: Display, V: Num + Display

Send a generic number with current timestamp

fn add_value_at<N, V = i64>(&mut self, name: N, value: V, ts: u64) where N: Display, V: Num + Display

Send a generic number with specific timestamp

Trait Implementations

impl<'a, C, S: ActiveStream> Drop for Sender<'a, C, S>

fn drop(&mut self)

A method called when the value goes out of scope.