faucet-source-singer 1.1.0

Singer tap bridge source for the faucet-stream ecosystem (single-stream v0)
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31

#![cfg_attr(docsrs, feature(doc_cfg))]

//! # faucet-source-singer
//!
//! A bridge source that runs an external [Singer](https://www.singer.io/) tap
//! executable and adapts its message stream into faucet records — so any of the
//! hundreds of existing Singer taps can feed a faucet pipeline.
//!
//! **Tier-2 / experimental.** Using this source reintroduces a runtime
//! dependency (usually Python) for that pipeline, throughput is Singer-class
//! rather than faucet-class, and STATE-based resume granularity depends on the
//! individual tap.
//!
//! **v0 is single-stream:** exactly the stream named by
//! [`SingerSourceConfig::stream`] is emitted; RECORD messages for other streams
//! are ignored.

pub mod assemble;
pub mod config;
pub mod discover;
pub mod message;
pub mod process;
pub mod stream;

// Re-export core types so users don't need a separate faucet-core dependency.
pub use faucet_core::{FaucetError, Sink, Source};

pub use config::{MalformedPolicy, SingerSourceConfig};
pub use discover::{StreamSelection, catalog_stream_ids, discover, select_streams};
pub use message::{SingerMessage, parse_line};
pub use stream::SingerSource;