data-courier 0.1.0-beta.4

Async Rust framework for composable data pipelines
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

mod interpolate;
mod loader;
mod observability;
mod parse;
mod raw;
mod redact;
mod types;
mod validate;

pub use observability::{LogFormat, LogsConfig, MetricsConfig, ObservabilityConfig, TracingConfig};
pub use parse::parse_config;
pub use redact::{redact_secret, redact_secret_path};
pub use types::{Config, ErrorPolicyConfig, PipelineSpec, SinkSpec, SourceSpec, TransformSpec};

#[cfg(test)]
pub(crate) use redact::REDACTED_SECRET;
#[cfg(test)]
pub(crate) use redact::clear_secret_values_for_test;
#[cfg(test)]
pub(crate) use redact::register_secret_value;

// Shared lock for all config tests that mutate env vars or the global
// secret registry. A single lock prevents concurrent test threads from
// clearing each other's registered secrets.
#[cfg(test)]
pub(crate) static ENV_LOCK: std::sync::Mutex<()> = std::sync::Mutex::new(());