faucet_sink_mysql/lib.rs
1#![cfg_attr(docsrs, feature(doc_cfg))]
2
3//! # faucet-sink-mysql
4//!
5//! MySQL sink connector for the faucet-stream ecosystem.
6//!
7//! Writes `serde_json::Value` records to a MySQL table using a JSON
8//! column or dynamic column mapping.
9
10pub mod config;
11mod descriptor;
12mod rollback;
13pub mod sink;
14
15pub use faucet_core::{FaucetError, Sink};
16
17pub use config::{BinaryEncoding, MysqlColumnMapping, MysqlSinkConfig};
18pub use descriptor::DESCRIPTOR;
19pub use sink::MysqlSink;