Struct StreamGraphFanout 

pub struct StreamGraphFanout {
    pub max_inputs: usize,
    pub record_domain_size: u64,
    pub left_queue: Buffer<u64>,
    pub right_queue: Buffer<u64>,
    pub ingested: Counter,
    pub left_emitted: Counter,
    pub right_emitted: Counter,
}

Retained verification profile for a source fanning out to two FIFO sinks.

Fields

max_inputs: usize

Maximum records admitted by the source.

record_domain_size: u64

Exclusive upper bound of record values.

left_queue: Buffer<u64>

Left-branch FIFO owner.

right_queue: Buffer<u64>

Right-branch FIFO owner.

ingested: Counter

Source-admission counter.

left_emitted: Counter

Left-sink emission counter.

right_emitted: Counter

Right-sink emission counter.

Implementations

impl StreamGraphFanout

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

Test whether the shared queue capacity and value domain are valid.

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

Construct an empty valid fan-out execution.

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

Replicate one source record into both branch queues.

pub fn consume_left(&mut self) -> bool

Consume one record from the left FIFO branch.

pub fn consume_right(&mut self) -> bool

Consume one record from the right FIFO branch.

pub fn terminal(&self) -> bool

Whether bounded input was admitted and both branches are drained.