Struct CrossOperationRouter 

pub struct CrossOperationRouter { /* private fields */ }

Deterministic kernel-side routing state. Every map is converted to an ordered vector at the checkpoint boundary, avoiding map-key JSON encoding quirks in cross-SDK snapshots.

Implementations

impl CrossOperationRouter

pub fn new(max_pending_per_recipient: usize) -> Self

pub fn register(&mut self, registration: OperationRegistration) -> bool

pub fn operation( &self, address: &OperationAddress, ) -> Option<&OperationRegistration>

pub fn delivery(&self, id: &str) -> Option<&DurableDelivery>

pub fn route( &mut self, message: CrossOperationMessage, now_turn: u32, payload_availability: PayloadAvailability, ) -> RouteOutcome

pub fn dispatch_next( &mut self, receiver: &OperationAddress, now_turn: u32, ) -> Option<CrossOperationMessage>

Returns the next delivery only after all earlier accepted deliveries for the receiver have settled. Host transport can therefore retry without changing receiver-visible order.

pub fn settle( &mut self, message_id: &str, settlement: DeliverySettlement, now_turn: u32, ) -> Option<DeliveryState>

pub fn cancel_operation(&mut self, address: &OperationAddress) -> usize

Cancelling either endpoint is a durable cancellation fact for all nonterminal deliveries touching that operation. A later Host acknowledgement cannot resurrect them.

pub fn snapshot(&self) -> CrossOperationRouterSnapshot

pub fn from_snapshot( snapshot: CrossOperationRouterSnapshot, ) -> Result<Self, SnapshotError>

Trait Implementations

impl Clone for CrossOperationRouter

fn clone(&self) -> CrossOperationRouter

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for CrossOperationRouter

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

Formats the value using the given formatter.

impl Default for CrossOperationRouter

fn default() -> CrossOperationRouter

Returns the “default value” for a type.

impl Eq for CrossOperationRouter

impl PartialEq for CrossOperationRouter

fn eq(&self, other: &CrossOperationRouter) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for CrossOperationRouter