Struct DataFlowController 

pub struct DataFlowController {
    pub buffers: Vec<PortBuffer>,
    pub policy: BackpressurePolicy,
}

Coordinates all port buffers in the graph and enforces backpressure.

Fields

buffers: Vec<PortBuffer>

All port buffers managed by this controller.

policy: BackpressurePolicy

Backpressure strategy applied to full buffers.

Implementations

impl DataFlowController

pub fn new(policy: BackpressurePolicy) -> Self

Creates a new controller with no buffers and the given policy.

pub fn add_buffer(&mut self, buffer: PortBuffer)

Adds a new buffer to this controller.

pub fn get_buffer(&mut self, node_id: u64, port: u32) -> Option<&mut PortBuffer>

Returns a mutable reference to the buffer for (node_id, port).

pub fn total_packets_in_flight(&self) -> usize

Returns the total number of packets currently held across all buffers.

pub fn clear_buffer(&mut self, node_id: u64, port: u32) -> bool

Drains the buffer for (node_id, port). Returns true if the buffer existed (it may have already been empty).

Trait Implementations

impl Debug for DataFlowController

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

Formats the value using the given formatter.