Struct InProcessRelay 

pub struct InProcessRelay { /* private fields */ }

Available on crate feature cluster only.

An in-process ClusterRelay for one node: mirrors a peer’s stream into the local engine.

Implementations

impl InProcessRelay

pub fn new( node: impl Into<NodeAddr>, local: Arc<dyn PublishRegistry>, directory: Arc<ClusterDirectory>, ) -> Self

A relay for node, mirroring into local, discovering via directory.

pub fn with_peer( self, addr: impl Into<NodeAddr>, playback: Arc<dyn PlaybackRegistry>, ) -> Self

Register a peer node’s playback registry so pull can subscribe to its streams.

pub fn with_reconnect(self, reconnect: bool) -> Self

Opt into reconnect/failover parity with the network relay: when a mirrored origin’s stream ends, re-locate the stream (excluding the node that just failed) and resume from a live replica, keeping the same local publish handle — viewers don’t see the stream drop. Stops when the stream is gone everywhere or on withdraw. Off by default (one-shot), keeping the reference minimal. Pair with ClusterDirectory::with_ttl so a crashed origin’s lease lapses and failover actually has somewhere to go.

Trait Implementations

impl ClusterRelay for InProcessRelay

fn locate<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 StreamKey, ) -> Pin<Box<dyn Future<Output = Result<Option<NodeAddr>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Find a node currently serving key, if any (e.g. via the control plane).

fn pull<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, key: &'life1 StreamKey, origin: &'life2 NodeAddr, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Begin relaying key from origin into the local engine, returning once the local mirror is publishing.

fn announce<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 StreamKey, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Advertise that this node serves key so edges can discover it.

fn withdraw<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 StreamKey, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Withdraw a previous announce when the stream ends.

fn ensure_mirrored<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 StreamKey, ) -> Pin<Box<dyn Future<Output = Result<bool>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Demand policy on top of the locate/pull mechanism: make key available locally, returning true if a mirror is now (or already) present and false if no origin serves it.