Struct ImpulseQueue 

pub struct ImpulseQueue { /* private fields */ }

Thread-safe queue of Impulse events awaiting consumption.

Implementations

impl ImpulseQueue

pub fn new() -> Self

Create a new, empty impulse queue.

pub fn emit( &self, source_structure: u8, source_node: [u8; 32], target_structure: u8, impulse_type: ImpulseType, payload: Value, hlc_timestamp: u64, ) -> u64

Enqueue a new impulse and return its assigned id.

pub fn drain_ready(&self) -> Vec<Impulse>

Drain all unacknowledged impulses, returning them sorted by hlc_timestamp (ascending). Acknowledged impulses are discarded.

pub fn len(&self) -> usize

Total number of impulses in the queue (acknowledged or not).

pub fn is_empty(&self) -> bool

Returns true if the queue contains no impulses.

pub fn clear(&self)

Remove all impulses from the queue (e.g. during calibration).

pub fn pending_count(&self) -> usize

Count of impulses that have not yet been acknowledged.

Trait Implementations

impl Default for ImpulseQueue

fn default() -> Self

Returns the “default value” for a type.