Struct FanoutRouter 

pub struct FanoutRouter<const N: usize> { /* private fields */ }

Fanout router handle.

This is a single-step primitive; long-running routing loops live in indexbus-route.

Implementations

impl<const N: usize> FanoutRouter<N>

pub fn route_once_with(&self, source: RouterSource, mode: RouterMode) -> bool

Route a single event.

Returns true if an event was consumed from the source queue.

Ordering for a given consumer matches the router’s routing order.

pub fn route_once_with_stats( &self, source: RouterSource, mode: RouterMode, ) -> RouteOnceResult

Route a single event and return delivery statistics.

pub fn route_once_with_credit_masks( &self, source: RouterSource, mode: RouterMode, eligible_mask: u64, no_credit_mask: u64, full_mask: u64, ) -> RouteOnceCreditResult

Credit-aware routing step.

eligible_mask marks which consumers are eligible for delivery. no_credit_mask marks consumers that are explicitly ineligible due to exhausted credit. full_mask marks consumers whose destination queues are full.

The router will attempt to deliver only to eligible_mask consumers.

pub fn as_ptr(&self) -> *mut SharedFanoutLayout<N>

Return the underlying shared-memory pointer.

This is intended for low-level integrations; callers must uphold the mapping lifetime.

Trait Implementations

impl<const N: usize> Send for FanoutRouter<N>