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.

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.