Struct StreamGraph 

pub struct StreamGraph {
    pub chain_length: usize,
    pub max_inputs: usize,
    pub record_domain_size: u64,
    pub q1: Buffer<u64>,
    pub q2: Buffer<u64>,
    pub q3: Buffer<u64>,
    pub ingested: Counter,
    pub emitted: Counter,
}

Bounded linear stream owner.

Fields

chain_length: usize

Number of stages in the linear chain.

max_inputs: usize

Maximum records admitted at the source.

record_domain_size: u64

Exclusive upper bound of record values.

q1: Buffer<u64>

First FIFO edge owner.

q2: Buffer<u64>

Second FIFO edge owner.

q3: Buffer<u64>

Optional third FIFO edge owner.

ingested: Counter

Source-admission counter.

emitted: Counter

Sink-emission counter.

Implementations

impl StreamGraph

pub fn valid_config( chain_length: usize, capacity: usize, record_domain_size: u64, ) -> bool

Test whether a chain configuration is represented by this carrier.

pub fn capacity(&self) -> usize

Capacity shared by every Buffer edge owner.

pub fn new( chain_length: usize, capacity: usize, max_inputs: usize, record_domain_size: u64, ) -> StreamGraph

Construct an empty valid stream graph.

pub fn source_ingest(&mut self, value: u64) -> bool

Admit one in-domain record when source and backpressure bounds permit it.

pub fn middle2_fire(&mut self) -> bool

Transfer the oldest first-edge record to the second edge.

pub fn middle3_fire(&mut self) -> bool

Transfer the oldest second-edge record through the optional fourth stage.

pub fn sink_consume(&mut self) -> bool

Consume the oldest record from the final edge.

pub fn done_stuttering(&mut self) -> bool

Execute the terminal stutter after bounded input is drained.