flarrow-api 0.3.1

flarrow (flow + arrow) is a rust runtime/framework for building dataflow 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

use crate::prelude::*;

pub fn report_error_receiving(source: &NodeLayout, layout: impl Into<IOLayout>) -> eyre::Report {
    let layout: IOLayout = layout.into();

    eyre::Report::msg(format!(
        "Node '{}' (uuid: {}) failed to receive data from io '{}' (uuid: {})",
        source.label,
        source.uuid,
        layout.label(),
        layout.uuid()
    ))
}

pub fn report_error_sending(source: &NodeLayout, layout: impl Into<IOLayout>) -> eyre::Report {
    let layout: IOLayout = layout.into();

    eyre::Report::msg(format!(
        "Node '{}' (uuid: {}) failed to send data to io '{}' (uuid: {})",
        source.label,
        source.uuid,
        layout.label(),
        layout.uuid()
    ))
}

pub fn report_failed_conversion_from_arrow<T>(
    source: &NodeLayout,
    layout: impl Into<IOLayout>,
) -> eyre::Report {
    let layout: IOLayout = layout.into();

    eyre::Report::msg(format!(
        "Node '{}' (uuid: {}) failed to convert arrow data from input '{}' (uuid: {}) to message T: {}",
        source.label,
        source.uuid,
        layout.label(),
        layout.uuid(),
        std::any::type_name::<T>()
    ))
}

pub fn report_failed_conversion_to_arrow<T>(
    source: &NodeLayout,
    layout: impl Into<IOLayout>,
) -> eyre::Report {
    let layout: IOLayout = layout.into();

    eyre::Report::msg(format!(
        "Node '{}' (uuid: {}) failed to convert message T {} to arrow data for output '{}' (uuid: {})",
        source.label,
        source.uuid,
        std::any::type_name::<T>(),
        layout.label(),
        layout.uuid()
    ))
}

pub fn report_io_not_found(source: &NodeLayout, layout: impl Into<IOLayout>) -> eyre::Report {
    let layout: IOLayout = layout.into();

    eyre::Report::msg(format!(
        "Input '{}' (uuid: {}) not found for node '{}'. The IO you're trying to create does not match the dataflow layout created.",
        layout.label(),
        layout.uuid(),
        source.label
    ))
}