Struct tempest::pipeline::PipelineAvailable

pub struct PipelineAvailable {
    pub queue: HashMap<String, VecDeque<TaskMsg>>,
}

This stores a queue of all available messages for given Task name.

Fields

queue: HashMap<String, VecDeque<TaskMsg>>

The queue of available messages by task name

Methods

impl PipelineAvailable

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

pub fn len(&mut self, name: &String) -> usize

Returns the current queue length

pub fn pop(
    &mut self,
    name: &String,
    count: Option<usize>
) -> Option<Vec<TaskMsg>>

Pops n-count of tasks from the front of the queue

pub fn push(&mut self, name: &String, msg: TaskMsg) -> Option<usize>

Pushes a task to the end of the queue

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

Trait Implementations

impl Default for PipelineAvailable

fn default() -> PipelineAvailable

Returns the "default value" for a type.

impl Debug for PipelineAvailable

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

Formats the value using the given formatter.