Struct tempest::pipeline::PipelineInflight

pub struct PipelineInflight { /* fields omitted */ }

All messages inflight (i.e. being worked on by tasks).

Methods

impl PipelineInflight

pub fn new(msg_timeout: Option<usize>) -> Self

Initialize a this struct using the max msg timeout value

pub fn size(&mut self) -> usize

pub fn get(&self, msg_id: &MsgId) -> Option<&(usize, PipelineMsgState)>

Returns the MsgInflightStatus for a given message id

pub fn get_mut(
    &mut self,
    msg_id: &MsgId
) -> Option<&mut (usize, PipelineMsgState)>

pub fn root(&mut self, msg_id: MsgId, timestamp: usize, state: PipelineMsgState)

This method is called when first we first see a message It keeps track of the timestamp (the message was read by the source so we can use it to determine timeouts later) and the initialized PipelineMsgState

pub fn ack_dead_end(
    &mut self,
    msg_id: &MsgId,
    edge: &(String, String),
    pipeline: &Pipeline
)

This method supports the use-case where an AckEdge triggers releasing an empty holding pen... We need to visit all descendant edges with a single ancestor from here since this method is always called after ack we can skip returning the PipelineInflightStatus here

pub fn ack(
    &mut self,
    msg_id: &MsgId,
    edge: &(String, String),
    index: usize
) -> PipelineInflightStatus

This method is called after a message by index, for a given edge, is acked

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

Remove a message by id

pub fn finished(&self, msg_id: &MsgId) -> bool

Mark this message state as finished

Trait Implementations

impl Default for PipelineInflight

fn default() -> PipelineInflight

Returns the "default value" for a type.

impl Debug for PipelineInflight

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

Formats the value using the given formatter.