Struct tempest::pipeline::Pipeline

pub struct Pipeline {
    pub root: &'static str,
    pub tasks: HashMap<&'static str, Box<dyn Task>>,
    pub ancestors: HashMap<&'static str, Vec<&'static str>>,
    pub descendants: HashMap<&'static str, Vec<&'static str>>,
    pub matrix: Vec<(&'static str, &'static str, bool)>,
}

Fields

root: &'static str

The root task name of our pipeline Auto-assigned when calling .add with the first Task

tasks: HashMap<&'static str, Box<dyn Task>>

store all tasks by task name

ancestors: HashMap<&'static str, Vec<&'static str>>

store all task names upstream from Task name

descendants: HashMap<&'static str, Vec<&'static str>>

store all task names downstream from key

matrix: Vec<(&'static str, &'static str, bool)>

Master DAG matrix of all tasks. This is cloned per message id so we can keep track of message states within the pipeline

Methods

impl Pipeline

pub fn runtime(&self) -> Self

Important traits for Vec<u8>

impl Write for Vec<u8>

pub fn names(&self) -> Vec<String>

pub fn remove(&mut self, name: &str) -> Option<Box<dyn Task>>

pub fn get(&self, name: &str) -> Option<&dyn Task>

pub fn get_mut(&mut self, name: &str) -> Option<&mut dyn Task>

pub fn root(self, name: &'static str) -> Self

Set the root Task name of our pipeline

pub fn task<T: Task + 'static>(self, task: T) -> Self

Adds a Task to the pipeline

pub fn edge(self, left: &'static str, right: &'static str) -> Self

Defines an ancestor (left) Task name and descendent (right) Task name edge

pub fn build(self) -> Self

A convenience method for return self

pub fn to_graphviz(&self) -> String

Useful for debugging pipeline Task relationships Generate graphviz compatible string for http://www.webgraphviz.com/

Trait Implementations

impl Default for Pipeline

fn default() -> Pipeline

Returns the "default value" for a type.