faucet-cli 1.6.0

Config-driven CLI runner for faucet-stream pipelines (YAML / JSON, Meltano-style)
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
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54

//! Subcommand implementations. Each module owns its `run(...)` entry point
//! and stays free of clap so the integration tests can drive it directly.

pub mod backfill;
#[cfg(feature = "catalog")]
pub mod catalog;
pub mod completions;
pub mod conformance;
#[cfg(feature = "contract")]
pub mod contract;
#[cfg(feature = "cli-dev")]
pub mod dev;
pub mod discover;
pub mod dlq;
pub mod doctor;
pub mod explain;
pub mod fmt;
#[cfg(feature = "catalog")]
pub mod history;
pub mod init;
pub mod install;
pub mod list;
#[cfg(feature = "masking")]
pub mod masking;
pub mod migrate;
pub mod new;
#[cfg(feature = "notify")]
pub mod notify;
pub mod plan;
pub mod preview;
pub mod replicate;
pub mod run;
#[cfg(feature = "schedule")]
pub mod schedule;
pub mod schema;
pub mod search;
#[cfg(feature = "serve")]
pub mod serve;
pub mod test;
pub mod validate;

use crate::error::CliError;

/// Render any [`CliError`] to a single line on stderr, scrubbing any resolved
/// secret values that may have reached the error chain.
pub fn report(err: &CliError) {
    use crate::secrets::registry::redact;
    eprintln!("error: {}", redact(&err.to_string()));
    let mut src = std::error::Error::source(err);
    while let Some(s) = src {
        eprintln!("  caused by: {}", redact(&s.to_string()));
        src = std::error::Error::source(s);
    }
}