processing_chain 0.2.2

Rust library to set up processing chains of large amounts of data.
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

use anyhow::{Ok, Result};

use processing_chain::{run_process, items::Item, processes::json_process::JsonProcess};


fn _process_item(item: &Item) -> Result<bool> {
    // define how to process a single item
    println!(
        "Processing {} {:?} -> {:?}",
        item.name, item.input_item_paths, item.output_item_paths
    );
    // ...

    Ok(true)
}


fn main() -> Result<()> {

    let proc = JsonProcess {
        name: String::from("JSON process"),
        json_items: String::from("examples/items.json"),
        ..JsonProcess::default()
    };
    let _proc = run_process(proc, _process_item)?;

    Ok(())

}