Crate faucet_sink_mongodb 

faucet-sink-mongodb

MongoDB sink connector for the faucet-stream ecosystem.

Inserts serde_json::Value records into a MongoDB collection, converting each JSON object to a BSON document.

Re-exports

pub use config::MongoSinkConfig;

pub use sink::MongoSink;

Modules

config

MongoDB sink configuration.

sink

MongoDB sink implementation.

Enums

FaucetError

All possible errors returned by faucet-stream.

Traits

Sink

A sink writes records to an external system.