Struct InvocationBus 

pub struct InvocationBus { /* private fields */ }

Cheap fleet-local handle for publishing and polling invocations.

Implementations

impl InvocationBus

pub fn new(fleet: Arc<Fleet>) -> Self

pub fn node_id(&self) -> NodeId

pub fn cursor_at_head(&self) -> InvocationCursor

pub fn cursor_from_start(&self) -> InvocationCursor

pub fn reset_ring(&self) -> Result<()>

Clear the invocation ring during quiescent owner boot.

pub fn event_fd(&self) -> Result<RingEventFd>

Create this process’ readiness fd for the invocation ring.

pub fn submit(&self, operation: &str, payload: &[u8]) -> Result<InvocationId>

Commit a raw invocation. Success means publication, not execution.

pub fn submit_typed<C: InvocationCodec>( &self, invocation: &C, ) -> Result<InvocationId>

pub fn poll(&self, cursor: &mut InvocationCursor) -> InvocationPoll

Advance every node lane once. Ordering is lane-local, not fleet-global.

pub fn poll_operation( &self, cursor: &mut InvocationCursor, operation: &str, ) -> InvocationPoll

Poll one operation while still advancing past every ring frame.

Trait Implementations

impl Clone for InvocationBus

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.