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 MongoSink
• impl<Doc: 'static + Send + Serialize> Sink<Doc> for MsgpackSink
• impl<Doc: 'static + Send + Serialize> Sink<Doc> for JsonSink
• impl<Doc: 'static + Send + Serialize> Sink<Doc> for StdoutSink