Struct SrtHandler 

pub struct SrtHandler { /* private fields */ }

Available on crate features ingest and srt only.

SRT server: one UDP listener that demultiplexes many concurrent SRT connections by peer address and routes each by its streamid mode — m=publish callers are ingested (published onto the bus), m=request callers are served (a stream muxed back to them as MPEG-TS). Each connection runs as its own task with independent ARQ/encryption state.

Implementations

impl SrtHandler

pub fn new(bind: SocketAddr, key: StreamKey) -> Self

A listener bound to bind. Publish-only until with_playback is set. key is the fallback stream key when a m=publish caller omits streamid.

pub fn with_playback(self, playback: Arc<dyn PlaybackRegistry>) -> Self

Enable serving m=request (egress) callers from playback.

pub fn with_gate(self, gate: EgressGate) -> Self

Gate m=request (egress) callers through gate (per-app toggle + token).

pub fn with_passphrase(self, passphrase: impl Into<String>) -> Self

Available on crate feature srt-encrypt only.

Pre-shared passphrase for AES-CTR (both encrypted ingest and egress). Feature srt-encrypt.

Trait Implementations

impl Clone for SrtHandler

fn clone(&self) -> SrtHandler

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl InboundProtocol for SrtHandler

fn name(&self) -> &'static str

Stable, human-readable protocol name ("rtmp", "rtsp", …). Used in logs and the engine’s per-worker lifecycle tracing.

fn serve<'life0, 'async_trait>( &'life0 self, ctx: IngestContext, shutdown: CancellationToken, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Run the protocol’s listener until shutdown is cancelled.