Module endpoint 

Unified endpoint state machine orchestrating all MoQT protocol flows.

Re-exports

use std::collections::HashMap; 🔒

use std::sync::Arc; 🔒

use std::sync::Mutex; 🔒

use crate::draft08::fetch::FetchError; 🔒

use crate::draft08::fetch::FetchState; 🔒

use crate::draft08::fetch::FetchStateMachine; 🔒

use crate::draft08::namespace::AnnounceState; 🔒

use crate::draft08::namespace::AnnounceStateMachine; 🔒

use crate::draft08::namespace::NamespaceError; 🔒

use crate::draft08::namespace::SubscribeAnnouncesState; 🔒

use crate::draft08::namespace::SubscribeAnnouncesStateMachine; 🔒

use crate::draft08::session::setup; 🔒

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

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

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

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

use crate::draft08::session::subscribe_id::SubscribeIdAllocator; 🔒

use crate::draft08::session::subscribe_id::SubscribeIdError; 🔒

use crate::draft08::subscription::SubscriptionError; 🔒

use crate::draft08::subscription::SubscriptionState; 🔒

use crate::draft08::subscription::SubscriptionStateMachine; 🔒

use crate::draft08::track_status::TrackStatusError; 🔒

use crate::draft08::track_status::TrackStatusState; 🔒

use crate::draft08::track_status::TrackStatusStateMachine; 🔒

use crate::forwarding_preference::ObjectForwardingPreference; 🔒

use crate::forwarding_preference::TrackForwardingPreferences; 🔒

use crate::track_locations::EndOfTrackPlacement; 🔒

use crate::track_locations::ObjectLocation; 🔒

use crate::track_locations::ObjectRole; 🔒

use crate::track_locations::TrackLocations; 🔒

use crate::track_locations::TrackObjects; 🔒

use moqtap_codec::draft08::error_codes::SessionErrorCode; 🔒

use moqtap_codec::draft08::error_codes::SubscribeErrorCode; 🔒

use moqtap_codec::draft08::message; 🔒

use moqtap_codec::draft08::message::Announce; 🔒

use moqtap_codec::draft08::message::AnnounceCancel; 🔒

use moqtap_codec::draft08::message::AnnounceError; 🔒

use moqtap_codec::draft08::message::AnnounceOk; 🔒

use moqtap_codec::draft08::message::ClientSetup; 🔒

use moqtap_codec::draft08::message::ControlMessage; 🔒

use moqtap_codec::draft08::message::Fetch; 🔒

use moqtap_codec::draft08::message::FetchCancel; 🔒

use moqtap_codec::draft08::message::FetchType; 🔒

use moqtap_codec::draft08::message::GoAway; 🔒

use moqtap_codec::draft08::message::MaxSubscribeId; 🔒

use moqtap_codec::draft08::message::ServerSetup; 🔒

use moqtap_codec::draft08::message::Subscribe; 🔒

use moqtap_codec::draft08::message::SubscribeAnnounces; 🔒

use moqtap_codec::draft08::message::SubscribeAnnouncesError; 🔒

use moqtap_codec::draft08::message::SubscribeAnnouncesOk; 🔒

use moqtap_codec::draft08::message::SubscribeDone; 🔒

use moqtap_codec::draft08::message::SubscribeError; 🔒

use moqtap_codec::draft08::message::SubscribeOk; 🔒

use moqtap_codec::draft08::message::SubscribeUpdate; 🔒

use moqtap_codec::draft08::message::SubscribesBlocked; 🔒

use moqtap_codec::draft08::message::TrackStatus; 🔒

use moqtap_codec::draft08::message::TrackStatusRequest; 🔒

use moqtap_codec::draft08::message::Unannounce; 🔒

use moqtap_codec::draft08::message::Unsubscribe; 🔒

use moqtap_codec::draft08::message::UnsubscribeAnnounces; 🔒

use moqtap_codec::kvp::KeyValuePair; 🔒

use moqtap_codec::varint::VarInt; 🔒

use moqtap_codec::types::*; 🔒

Structs

Endpoint

Unified draft-08 MoQT endpoint wrapping session lifecycle, subscribe ID allocation, and all per-flow state machines (subscriptions, fetches, announces, subscribe-announces, track statuses).

InboundAnnounce 🔒

An announcement the peer made with ANNOUNCE.

InboundFetch 🔒

A FETCH the peer sent, and how far the fetch it opened has got.

InboundSubscribe 🔒

A SUBSCRIBE the peer sent, and how far the subscription it opened has got.

InboundSubscribeAnnounces 🔒

A SUBSCRIBE_ANNOUNCES the peer sent, and how far the namespace subscription it opens has got.

InboundTrackStatus 🔒

A track status the peer asked for with TRACK_STATUS_REQUEST.

TrackBinding 🔒

A Track Alias attached to a Full Track Name, and nothing else: the subscription whose lifetime the attachment follows is the map’s key.

Enums

EndpointError

Errors that can occur during draft-08 endpoint operations.

Role

Which side of the session this endpoint is.

SubscribeSide

Which end of the session opened a subscription.

Functions

prefixes_overlap 🔒

Whether two namespace prefixes overlap.

Type Aliases

NamespaceKey 🔒

Key identifying a namespace (used for Announce / SubscribeAnnounces maps).

TrackKey 🔒

Key identifying a track (namespace + track name).