pub struct ShmFanoutRouter { /* private fields */ }Expand description
SHM-backed fanout router.
This is intentionally separate from producers/consumers to enforce the v1 role separation: the router role is the only component that touches fanout routing.
Implementations§
Source§impl ShmFanoutRouter
impl ShmFanoutRouter
Sourcepub fn route_once(&self, mode: RouterMode) -> bool
pub fn route_once(&self, mode: RouterMode) -> bool
Route one event from the SPSC producer queue.
Sourcepub fn route_once_with_stats(&self, mode: RouterMode) -> RouteOnceResult
pub fn route_once_with_stats(&self, mode: RouterMode) -> RouteOnceResult
Route one event from the SPSC producer queue and return delivery statistics.
Sourcepub fn route_once_broadcast(&self) -> bool
pub fn route_once_broadcast(&self) -> bool
Convenience: broadcast one event.
Sourcepub fn route_once_workqueue(&self) -> bool
pub fn route_once_workqueue(&self) -> bool
Convenience: work-queue one event.
Auto Trait Implementations§
impl Freeze for ShmFanoutRouter
impl !RefUnwindSafe for ShmFanoutRouter
impl Send for ShmFanoutRouter
impl !Sync for ShmFanoutRouter
impl Unpin for ShmFanoutRouter
impl !UnwindSafe for ShmFanoutRouter
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more