faucet-source-singer 1.3.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
32
33
34
35

#![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::{InheritEnv, MalformedPolicy, SingerSourceConfig};
pub use discover::{StreamSelection, catalog_stream_ids, discover, select_streams};
pub use message::{SingerMessage, parse_line};
pub use stream::SingerSource;

/// The connector's static descriptor (RFC 0013): its capabilities, answered from config alone.
pub const DESCRIPTOR: faucet_core::ConnectorDescriptor =
    faucet_core::ConnectorDescriptor::new("singer", faucet_core::capabilities::plain_source);