multiio 0.2.3

A unified I/O orchestration library for CLI/server applications
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
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82

use serde::Deserialize;

/// Configuration for an entire I/O pipeline.
#[derive(Debug, Clone, Deserialize, Default)]
pub struct PipelineConfig {
    /// Input configurations
    #[serde(default)]
    pub inputs: Vec<InputConfig>,
    /// Output configurations
    #[serde(default)]
    pub outputs: Vec<OutputConfig>,
    /// Error policy: "fast_fail" or "accumulate"
    #[serde(default)]
    pub error_policy: Option<String>,
    /// Format priority order
    #[serde(default)]
    pub format_order: Option<Vec<String>>,
}

#[derive(Debug, Clone, Deserialize)]
pub struct InputConfig {
    /// Unique identifier for this input
    pub id: String,
    /// Kind of input: "stdin", "file", "http", etc.
    pub kind: String,
    /// File path (for file inputs)
    #[serde(default)]
    pub path: Option<String>,
    /// URL (for HTTP/network inputs)
    #[serde(default)]
    pub url: Option<String>,
    /// Explicit format: "json", "yaml", etc.
    #[serde(default)]
    pub format: Option<String>,
}

#[derive(Debug, Clone, Deserialize)]
pub struct OutputConfig {
    /// Unique identifier for this output
    pub id: String,
    /// Kind of output: "stdout", "stderr", "file", etc.
    pub kind: String,
    /// File path (for file outputs)
    #[serde(default)]
    pub path: Option<String>,
    /// Explicit format: "json", "yaml", etc.
    #[serde(default)]
    pub format: Option<String>,
    /// File exists policy: "overwrite", "append", "error"
    #[serde(default)]
    pub file_exists_policy: Option<String>,
}

impl PipelineConfig {
    pub fn new() -> Self {
        Self::default()
    }

    /// Add an input configuration.
    pub fn add_input(mut self, input: InputConfig) -> Self {
        self.inputs.push(input);
        self
    }

    /// Add an output configuration.
    pub fn add_output(mut self, output: OutputConfig) -> Self {
        self.outputs.push(output);
        self
    }

    /// Set the error policy.
    pub fn with_error_policy(mut self, policy: impl Into<String>) -> Self {
        self.error_policy = Some(policy.into());
        self
    }

    /// Set the format order.
    pub fn with_format_order(mut self, order: Vec<String>) -> Self {
        self.format_order = Some(order);
        self
    }
}