Crate faucet_sink_sqlite 

faucet-sink-sqlite

SQLite sink connector for the faucet-stream ecosystem.

Writes serde_json::Value records to a SQLite table using a JSON column or dynamic column mapping.

Re-exports

pub use config::SqliteColumnMapping;

pub use config::SqliteSinkConfig;

pub use sink::SqliteSink;

Modules

config

SQLite sink configuration.

sink

SQLite sink implementation.

Enums

FaucetError

All possible errors returned by faucet-stream.

Traits

Sink

A sink writes records to an external system.