flusso-sinks-core 0.1.0

Sink trait, JSON rendering, and fan-out for flusso.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21

//! The sink abstraction for `flusso`.
//!
//! A *sink* is where assembled documents go. It consumes neutral values — an
//! [`IndexName`](schema_core::IndexName), a string id, and a document
//! [`GenericValue`](schema_core::GenericValue) — so it depends on neither the
//! source nor the engine; the engine is what feeds it.
//!
//! - [`Sink`] is the trait every destination implements.
//! - [`to_json`] renders a [`GenericValue`](schema_core::GenericValue) as
//!   natural JSON (numbers as numbers, maps as objects), which most sinks need.
//! - [`SinkError`] / [`Result`] are the shared error type.

mod error;
mod fan_out;
mod json;
mod sink;

pub use error::*;
pub use fan_out::*;
pub use json::to_json;
pub use sink::*;