Struct SrtHandler 

pub struct SrtHandler { /* private fields */ }

Available on crate features ingest and srt only.

SRT ingest worker — binds a UDP listener and demuxes one MPEG-TS feed.

Implementations

impl SrtHandler

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

A listener bound to bind that publishes the received feed as key.

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

Available on crate feature srt-encrypt only.

Accept an encrypted feed, decrypting with passphrase (the SRT passphrase the caller was configured with). 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 Debug for SrtHandler

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

Formats the value using the given formatter.

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.