Struct ReactorMesh 

pub struct ReactorMesh { /* private fields */ }

Deterministic multi-shard reactor mesh using bounded per-shard SPSC lanes.

Routing policy:

• Hostcall completions are hash-routed by call_id for shard affinity.
• Inbound events use deterministic round-robin distribution across shards.

Drain policy:

• drain_global_order() emits envelopes in ascending global sequence across all shard heads, preserving deterministic external ordering.

Implementations

impl ReactorMesh

pub fn new(config: ReactorMeshConfig) -> Self

Create a mesh using the provided config.

The mesh is fail-closed for invalid config values: shard_count == 0 or lane_capacity == 0 returns an empty mesh.

pub fn shard_count(&self) -> usize

Number of shard lanes.

pub fn total_depth(&self) -> usize

Total pending envelopes across all shards.

pub fn has_pending(&self) -> bool

Whether any lane has pending envelopes.

pub fn queue_depth(&self, shard_id: usize) -> Option<usize>

Per-shard queue depth.

pub fn telemetry(&self) -> ReactorMeshTelemetry

Snapshot queueing telemetry for diagnostics.

pub const fn placement_manifest(&self) -> &ReactorPlacementManifest

Deterministic shard placement manifest used by this mesh.

pub fn enqueue_hostcall_complete( &mut self, call_id: String, outcome: HostcallOutcome, ) -> Result<ReactorEnvelope, ReactorBackpressure>

Enqueue a hostcall completion using deterministic hash routing.

pub fn enqueue_event( &mut self, event_id: String, payload: Value, ) -> Result<ReactorEnvelope, ReactorBackpressure>

Enqueue an inbound event using deterministic round-robin routing.

pub fn drain_shard( &mut self, shard_id: usize, budget: usize, ) -> Vec<ReactorEnvelope>

Drain one shard up to budget envelopes.

pub fn drain_global_order(&mut self, budget: usize) -> Vec<ReactorEnvelope>

Drain across shards in deterministic global sequence order.

impl ReactorMesh

pub fn preferred_numa_node(&self, shard_id: usize) -> usize

Look up the preferred NUMA node for a shard via the placement manifest.

pub fn affinity_advice( &self, enforcement: AffinityEnforcement, ) -> Vec<ThreadAffinityAdvice>

Generate thread affinity advice from the mesh’s placement manifest.

Trait Implementations

impl Clone for ReactorMesh

fn clone(&self) -> ReactorMesh

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ReactorMesh

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

Formats the value using the given formatter.