Module endpoint 

Draft-19 MoQT endpoint.

Major changes from draft-18:

• GoAway drops the request_id field entirely; the control-stream and request-stream forms are now identical on the wire.
• PublishBlocked renamed to PublishSkipped (still type 0x0F, wire identical).
• GROUP_ORDER (parameter 0x22) moves from PUBLISH_OK to SUBSCRIBE_TRACKS.
• New Range Filter parameters (SUBGROUP_FILTER 0x25, OBJECTID_FILTER 0x26, PRIORITY_FILTER 0x27, OBJECT_PROPERTY_FILTER 0x28, TRACK_PROPERTY_FILTER 0x29) may appear on SUBSCRIBE / FETCH / SUBSCRIBE_TRACKS / REQUEST_UPDATE.
• RequestError adds CONFLICTING_FILTERS (0x35) and INVALID_FILTER (0x36); DUPLICATE_SUBSCRIPTION (0x19) is removed.

Re-exports

use std::collections::HashMap; 🔒

use std::collections::HashSet; 🔒

use std::sync::Arc; 🔒

use std::sync::Mutex; 🔒

use crate::draft19::fetch::FetchError; 🔒

use crate::draft19::fetch::FetchState; 🔒

use crate::draft19::fetch::FetchStateMachine; 🔒

use crate::draft19::namespace::NamespaceError; 🔒

use crate::draft19::namespace::PublishNamespaceState; 🔒

use crate::draft19::namespace::PublishNamespaceStateMachine; 🔒

use crate::draft19::namespace::SubscribeNamespaceState; 🔒

use crate::draft19::namespace::SubscribeNamespaceStateMachine; 🔒

use crate::draft19::publish::PublishError as PublishFlowError; 🔒

use crate::draft19::publish::PublishState; 🔒

use crate::draft19::publish::PublishStateMachine; 🔒

use crate::draft19::session::request_id::RequestIdAllocator; 🔒

use crate::draft19::session::request_id::RequestIdError; 🔒

use crate::draft19::session::request_id::Role; 🔒

use crate::draft19::session::setup; 🔒

use crate::draft19::session::setup::SetupError; 🔒

use moqtap_codec::kvp::KvpValue; 🔒

use moqtap_codec::range_filter; 🔒

use moqtap_codec::range_filter::RangeFilterError; 🔒

use moqtap_codec::varint::Moqt18; 🔒

use crate::draft19::session::state::SessionError; 🔒

use crate::draft19::session::state::SessionState; 🔒

use crate::draft19::session::state::SessionStateMachine; 🔒

use crate::draft19::subscription::SubscriptionError; 🔒

use crate::draft19::subscription::SubscriptionState; 🔒

use crate::draft19::subscription::SubscriptionStateMachine; 🔒

use crate::draft19::track_status::TrackStatusError; 🔒

use crate::draft19::track_status::TrackStatusState; 🔒

use crate::draft19::track_status::TrackStatusStateMachine; 🔒

use crate::malformed_tracks::MalformedTrackCondition; 🔒

use crate::malformed_tracks::MalformedTracks; 🔒

use crate::track_locations::ObjectLocation; 🔒

use crate::track_locations::ObjectRole; 🔒

use crate::track_locations::TrackLocations; 🔒

use crate::track_locations::TrackObjects; 🔒

use moqtap_codec::draft19::error_codes::PublishDoneStatusCode; 🔒

use moqtap_codec::draft19::error_codes::RequestErrorCode; 🔒

use moqtap_codec::draft19::error_codes::SessionErrorCode; 🔒

use moqtap_codec::draft19::message; 🔒

use moqtap_codec::draft19::message::ControlMessage; 🔒

use moqtap_codec::draft19::message::Fetch; 🔒

use moqtap_codec::draft19::message::FetchPayload; 🔒

use moqtap_codec::draft19::message::FetchType; 🔒

use moqtap_codec::draft19::message::GoAway; 🔒

use moqtap_codec::draft19::message::MessageType; 🔒

use moqtap_codec::draft19::message::Publish; 🔒

use moqtap_codec::draft19::message::PublishDone; 🔒

use moqtap_codec::draft19::message::PublishNamespace; 🔒

use moqtap_codec::draft19::message::PublishSkipped; 🔒

use moqtap_codec::draft19::message::RequestError; 🔒

use moqtap_codec::draft19::message::RequestOk; 🔒

use moqtap_codec::draft19::message::RequestUpdate; 🔒

use moqtap_codec::draft19::message::Setup; 🔒

use moqtap_codec::draft19::message::Subscribe; 🔒

use moqtap_codec::draft19::message::SubscribeNamespace; 🔒

use moqtap_codec::draft19::message::SubscribeOk; 🔒

use moqtap_codec::draft19::message::SubscribeTracks; 🔒

use moqtap_codec::kvp::KeyValuePair; 🔒

use moqtap_codec::varint::VarInt; 🔒

use moqtap_codec::types::*; 🔒

Structs

Endpoint

FetchTrack 🔒

The track one fetch is for, which the fetch’s own state machine does not hold.

TrackBinding 🔒

A Track Alias the peer has attached to a Full Track Name, and the request whose lifetime the attachment follows.

Enums

BindingKind 🔒

Which of the two sequences Section 5.1 names established the subscription that owns a binding, and so which state machine says whether it still has one.

EndpointError

Errors that can occur during endpoint operations.

FilterRejection

Why a peer’s request must be answered with REQUEST_ERROR and INVALID_FILTER.

Constants

MAX_FILTER_RANGES 🔒

The MAX_FILTER_RANGES Setup Option, Section 10.3.1.6.

MAX_REQUEST_UPDATES 🔒

The MAX_REQUEST_UPDATES Setup Option, Section 10.3.1.7.

TRACK_NAMESPACE_PREFIX 🔒

Parameter Type of TRACK_NAMESPACE_PREFIX.

Functions

apply_filter_update 🔒

Apply a REQUEST_UPDATE’s filter parameters to the set already in force.

prefixes_overlap 🔒

Whether two namespace prefixes overlap.

range_filter_parameters 🔒

The Range Filter parameters in parameters, dropping the removals.

request_parameters 🔒

The Message Parameters a request carries, or nothing for a message that is not a request.

setup_varint 🔒

Read a Setup Option’s value as a variable-length integer, or 0 if it is absent.

updated_prefix 🔒

The Track Namespace Prefix a REQUEST_UPDATE asks a namespace subscription to move to, and None when it asks for no such move.