moq-mux 0.10.13

Media muxers and demuxers for MoQ
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60

//! Media muxers and demuxers for MoQ.
//!
//! Sits between [`moq_net`] (pub/sub transport) and [`hang`] (media
//! catalog). Takes containerized media in, produces a moq broadcast,
//! and the other way around.
//!
//! - [`container`](mod@container) holds one submodule per container
//!   format. Each describes how media frames are packaged on the wire,
//!   and some also handle the corresponding file or stream format.
//! - [`codec`] holds one submodule per codec. Each parses the codec's
//!   configuration record and provides an importer that publishes a
//!   raw bitstream to a broadcast.
//! - [`catalog`] publishes and subscribes to the broadcast catalog,
//!   the JSON manifest listing every track and how to decode it.
//! - [`clock`](mod@clock) holds the broadcast [`Clock`] and the translators
//!   that move a source's own timestamps onto it.
//! - [`import`](mod@import) is the front door for callers who only have
//!   a format string. It picks the right concrete importer for you.
//! - [`select`] picks which renditions of a broadcast to keep, on either
//!   the import or the consume side.
//! - [`Pacer`] maps each exported frame's media timestamp to the wall-clock
//!   instant it should be delivered at, for byte streams whose spacing is
//!   part of the format (MPEG-TS).
//! - [`rate`] turns bandwidth grants into stable media bitrate targets shared
//!   by audio, video, and transcode senders.
//! - [`timeline`](mod@timeline) publishes the broadcast's segment index: one
//!   record per aligned segment, mapping a span of content time to the group
//!   ranges that carry it on each track, so consumers can seek or build
//!   HLS/DASH playlists without downloading media.

pub mod binary;
pub mod catalog;
pub mod clock;
pub mod codec;
pub mod container;
mod error;
pub mod import;
pub mod json;
mod pace;
pub mod rate;
pub mod select;
mod source;
pub mod timeline;

pub use clock::{Clock, SourceMap};
pub use error::*;
pub use pace::Pacer;
pub use source::{Binding, Source};

/// Translate a catalog entry's declared compression into the flag the codecs take.
///
/// An unrecognized algorithm is an error rather than a fallback to plaintext: reading its frames
/// raw would hand the caller garbage.
pub(crate) fn compression(compression: Option<&hang::catalog::Compression>) -> Result<bool> {
	match compression {
		None => Ok(false),
		Some(hang::catalog::Compression::Deflate) => Ok(true),
		Some(other) => Err(Error::UnsupportedCompression(other.to_string())),
	}
}