Struct RedexReplicationRouter 

pub struct RedexReplicationRouter { /* private fields */ }

Per-Redex registry of runtime handles, dispatching by channel id. Cheap to clone (everything is Arc) so the same router can be shared between Redex (for registration) and MeshNode (for inbound dispatch).

Implementations

impl RedexReplicationRouter

pub fn new() -> Self

Construct an empty router.

pub fn register( &self, channel_id: ChannelId, handle: Arc<ReplicationRuntimeHandle>, ) -> Option<Arc<ReplicationRuntimeHandle>>

Register a runtime handle under channel_id. Returns the previously-registered handle if one existed, so the caller can cancel it cleanly. Re-registration is the RedexFileConfig::replication update path — same channel, new config, new runtime.

pub fn get( &self, channel_id: &ChannelId, ) -> Option<Arc<ReplicationRuntimeHandle>>

Look up a runtime handle. Cloned Arc so the caller can drive the handle (dispatch events, cancel) without holding the DashMap shard lock.

pub fn unregister( &self, channel_id: &ChannelId, ) -> Option<Arc<ReplicationRuntimeHandle>>

Remove the registration for channel_id. Returns the removed handle, if any, so the caller can cancel + await its exit deterministically.

pub fn len(&self) -> usize

Number of registered runtimes.

pub fn is_empty(&self) -> bool

True iff no runtimes are registered.

pub fn snapshot_handles( &self, ) -> Vec<(ChannelId, Arc<ReplicationRuntimeHandle>)>

Snapshot every registered (ChannelId, handle) pair. The Arc clone is cheap; the caller can iterate without holding shard locks. Consumed by Redex to build the per-channel status snapshot for operator observability.

Trait Implementations

impl Default for RedexReplicationRouter

fn default() -> RedexReplicationRouter

Returns the “default value” for a type.

impl ReplicationInboundRouter for RedexReplicationRouter

fn try_route( &self, channel_id: ChannelId, inbound: Inbound, ) -> Result<(), Inbound>

Try to route an inbound event to its channel’s runtime. Sync + non-blocking — must not call into async code, must not hold locks across awaits (the mesh dispatch loop is the sole caller and runs in a synchronous critical section).