pub trait Sink<Document: Send + Serialize> { fn run(self) -> (Sender<Document>, JoinHandle<()>); }
Sink trait for storing time-series data
Start a thread for sink