Struct tempest::pipeline::PipelineMsgState

pub struct PipelineMsgState { /* fields omitted */ }

This stores the original message id and it's state as moves through a pipeline

Methods

impl PipelineMsgState

pub fn new(matrix: Vec<(&'static str, &'static str, bool)>) -> Self

pub fn get(&self, edge: &(String, String)) -> Option<&Vec<(usize, bool)>>

Returns a list of pending messages for a given edge

pub fn task_visit(&mut self, name: String)

Marks the task name as visited

pub fn edge_start(&mut self, edge: (String, String), size: usize)

Marks the edge as being started for processing

pub fn edge_visit(&mut self, edge: &(String, String))

Marks an edge as visted and marks the task as visited if all task ancestors have also been visted

pub fn task_dead_ends(&mut self, edge: &(String, String), pipeline: &Pipeline)

A task dead-end occurs when the output of an ancestor edge returns no messages to move into descendant tasks. This does the appropriate cleanup to mark all downstream descendants as visited for a given edge.

pub fn edge_visit_index(
    &mut self,
    edge: &(String, String),
    index: usize
) -> Option<bool>

This is called when we ack a message by its index for an edge

pub fn finished(&self) -> bool

Have all the nodes been visited in the matrix

Trait Implementations

impl Default for PipelineMsgState

fn default() -> PipelineMsgState

Returns the "default value" for a type.

impl Debug for PipelineMsgState

fn fmt(&self, f: &mut Formatter) -> Result

Formats the value using the given formatter.