Struct tempest::pipeline::PipelineAggregate

pub struct PipelineAggregate { /* fields omitted */ }

This is a holding pen which aggregates all edge messages returned from TaskService by its index. We store all these so they can be released at one time into the next set of downstream decendant tasks

Methods

impl PipelineAggregate

pub fn new(task_names: Vec<String>) -> Self

pub fn hold(
    &mut self,
    name: &String,
    msg_id: MsgId,
    msgs: Vec<Msg>
) -> Option<bool>

Hold this msg for this task_name, msg_id, msg

pub fn remove(&mut self, name: &String, msg_id: &MsgId) -> Option<Vec<Msg>>

Returns all messages for this task_name and msg_id for processing

pub fn clean_msg_id(&mut self, msg_id: &MsgId)

pub fn stats(&mut self) -> HashMap<String, isize>

Trait Implementations

impl Default for PipelineAggregate

fn default() -> PipelineAggregate

Returns the "default value" for a type.

impl Debug for PipelineAggregate

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

Formats the value using the given formatter.