Trait asink::Sink

pub trait Sink<Document: Send + Serialize> {
    fn run(self) -> (Sender<Document>, JoinHandle<()>);
}

Sink trait for storing time-series data

Required Methods

fn run(self) -> (Sender<Document>, JoinHandle<()>)

Start a thread for sink

Implementors

impl<Doc: 'static + Send + Serialize> Sink<Doc> for JsonSink

impl<Doc: 'static + Send + Serialize> Sink<Doc> for StdoutSink

impl<Doc: 'static + Send + Serialize> Sink<Doc> for MongoSink

impl<Doc: 'static + Send + Serialize> Sink<Doc> for MsgpackSink