pondrs 0.3.0

A pipeline execution library
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

//! Ident struct - a no-op identifying two datasets with each other using essentially a node.

use crate::error::PondError;

use super::traits::{DatasetEvent, DatasetRef, StepInfo, RunnableStep};
use crate::datasets::Dataset;

/// A no-op node that declares two datasets as linked in the graph
/// without performing any computation or data transfer.
pub struct Ident<'a, Input: Dataset + Send + Sync, Output: Dataset + Send + Sync> {
    pub name: &'static str,
    pub input: &'a Input,
    pub output: &'a Output,
}

impl<Input, Output> StepInfo for Ident<'_, Input, Output>
where
    Input: Dataset + Send + Sync,
    Output: Dataset + Send + Sync,
{
    fn name(&self) -> &'static str {
        self.name
    }

    fn is_leaf(&self) -> bool {
        true
    }

    fn type_string(&self) -> &'static str {
        core::any::type_name::<Self>()
    }

    fn for_each_child<'a>(&'a self, _f: &mut dyn FnMut(&'a dyn StepInfo)) {}

    fn for_each_input<'s>(&'s self, f: &mut dyn FnMut(&DatasetRef<'s>)) {
        f(&DatasetRef::from_ref(self.input));
    }

    fn for_each_output<'s>(&'s self, f: &mut dyn FnMut(&DatasetRef<'s>)) {
        f(&DatasetRef::from_ref(self.output));
    }
}

impl<Input, Output, E> RunnableStep<E> for Ident<'_, Input, Output>
where
    Input: Dataset + Send + Sync,
    Output: Dataset + Send + Sync,
    E: From<PondError>,
{
    fn call(&self, _on_event: &mut dyn FnMut(&DatasetRef<'_>, DatasetEvent)) -> Result<(), E> {
        Ok(())
    }

    fn for_each_child_step<'a>(&'a self, _f: &mut dyn FnMut(&'a dyn RunnableStep<E>)) {}

    fn as_pipeline_info(&self) -> &dyn StepInfo { self }
}