Struct LlHlsOrigin 

pub struct LlHlsOrigin { /* private fields */ }

Available on crate feature std only.

The LL-HLS origin ServedEgress: renders playlists and resolves blocking-reload/part-availability requests for one stream, backed by a shared Trunk. See this module’s own doc for exactly what comes straight from the Trunk and what needs the small synced Window.

Implementations

impl LlHlsOrigin

pub fn new( trunk: Arc<Trunk>, target_duration_secs: f64, part_target_ms: u32, window_segments: NonZeroUsize, ) -> Self

Build a fresh origin over trunk, subscribing its one SegmentCursor immediately (so the window starts empty but never misses a segment published from this point on).

window_segments bounds how many closed segments this origin advertises in a rendered Media Playlist — independent of media_plane::trunk::TrunkConfig::segment_capacity (the Trunk’s own retention bound): a caller may legitimately want a shorter advertised window than the Trunk retains for other consumers (e.g. a DVR SegmentEgress reading the same Trunk).

pub fn set_init(&self, bytes: impl Into<Bytes>)

Store the fMP4 init segment bytes — see this module’s doc for why an init segment is not something any Trunk ring holds.

pub fn init_bytes(&self) -> Option<Bytes>

The fMP4 init segment bytes, if set.

Trait Implementations

impl ServedEgress for LlHlsOrigin

type Request = LlHlsRequest

The protocol-specific request shape (e.g. LL-HLS’s Media Sequence Number + part index; a DASH segment/manifest request; a catch-up time range) — owned by the implementing crate, not this one.

type Body = LlHlsBody

The protocol-specific resolved body (a playlist string, manifest XML, segment bytes, …).

fn resolve( &self, request: LlHlsRequest, now: Timestamp, await_policy: AwaitPolicy, ) -> EgressResponse<LlHlsBody>

Resolve request against this implementation’s current state at time now, bounded by await_policy — see EgressResponse::Await’s contract.