Struct OclaBus 

pub struct OclaBus { /* private fields */ }

The OCLA event bus. Zero-cost when disabled.

Global usage: ocla_bus::emit(event) — checks the global enable flag first. Test usage: OclaBus::scoped(cap) — isolated instance, no global state.

Implementations

impl OclaBus

pub fn scoped(capacity: usize) -> Self

Create a scoped (isolated) bus for testing. Does NOT affect the global bus.

pub fn enable(&self)

Enable the bus. Events will be recorded after this call.

pub fn disable(&self)

Disable the bus. Events will be discarded (< 5ns per call).

pub fn is_enabled(&self) -> bool

Check if the bus is enabled.

pub fn emit_if_enabled(&self, event: OclaEvent) -> u64

Emit an event if the bus is enabled. Returns the event ID, or 0 if disabled.

pub fn drain(&self) -> Vec<OclaBusRecord>

Drain all events from the ring (consumes them). Useful for test assertions.

pub fn events_since(&self, after_id: u64) -> Vec<OclaBusRecord>

Read events since a given ID (non-consuming).

pub fn latest(&self, n: usize) -> Vec<OclaBusRecord>

Read the last N events.

pub fn len(&self) -> usize

Current ring buffer occupancy.

pub fn is_empty(&self) -> bool

Whether the ring is empty.

pub fn total_emitted(&self) -> u64

Total events emitted (including those evicted from the ring).

pub fn overflow_count(&self) -> usize

Total queue overflows observed by this bus since creation.

pub fn overflow_policy(&self) -> OverflowPolicy

Overflow policy active for this bus.

Trait Implementations

impl Debug for OclaBus

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

Formats the value using the given formatter.