Function create_event_bus

nodedb/src/event/bus.rs:180–182

Creates the event bus: one ring buffer pair per Data Plane core. Returns `(producers, consumers)` — producers go to Data Plane cores, consumers go to Event Plane Tokio tasks.

(num_cores: usize)

/// Returns `(producers, consumers)` — producers go to Data Plane cores,
/// consumers go to Event Plane Tokio tasks.
pub fn create_event_bus(num_cores: usize) -> (Vec<EventProducer>, Vec<EventConsumerRx>) {
    create_event_bus_with_capacity(num_cores, DEFAULT_EVENT_BUS_CAPACITY)
}

/// Creates the event bus with a custom ring buffer capacity.
pub fn create_event_bus_with_capacity(