faucet-core 1.0.0

Shared types, traits, and utilities for the faucet-stream ecosystem
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

//! Pipeline-internal observability: tracing spans and `metrics` counters/
//! histograms wired automatically around every source, sink, transform, and
//! state-store operation. See
//! `docs/superpowers/specs/2026-05-23-observability-otel-prometheus-design.md`.

mod bookmark;
pub(crate) mod decorator;
mod install;
mod labels;
mod options;
#[cfg(feature = "quality")]
mod quality;
mod state;
mod strip;
mod timer;
mod transform;

pub use bookmark::update_bookmark_lag;
pub use decorator::{InstrumentedSink, InstrumentedSource};
pub use install::{
    InstallError, InstallReport, ObservabilityConfig, PrometheusConfig, TracingConfig,
    install_observability, register_build_info,
};
pub use labels::Labels;
pub use options::RunStreamOptions;
#[cfg(feature = "quality")]
pub use quality::instrumented_apply_quality;
pub use state::InstrumentedStateStore;
pub use strip::strip_type_name;
pub use timer::DurationGuard;
pub use transform::instrumented_apply_stages;