Struct asink::mongo::MongoSink

pub struct MongoSink { /* fields omitted */ }

Sink with MongoDB backend

Each data send to this sink will be serialized into bson::Document i.e. the data must be serialized into Document.

Methods

impl MongoSink

fn new(host: String, port: u16, db: String, collection: String) -> Self

Constructs a new MongoSink.

impl MongoSink

fn local(db: &str, collection: &str) -> Self

Connect to mongodb with default setting localhost:27017

Trait Implementations

impl Debug for MongoSink

fn fmt(&self, __arg_0: &mut Formatter) -> Result

Formats the value using the given formatter.

impl Clone for MongoSink

fn clone(&self) -> MongoSink

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

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

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

Start a thread for sink