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 std::sync::MutexGuard; 🔒

use crate::draft16::fetch::FetchError; 🔒

use crate::draft16::fetch::FetchState; 🔒

use crate::draft16::fetch::FetchStateMachine; 🔒

use crate::draft16::namespace::NamespaceError; 🔒

use crate::draft16::namespace::PublishNamespaceState; 🔒

use crate::draft16::namespace::PublishNamespaceStateMachine; 🔒

use crate::draft16::namespace::SubscribeNamespaceState; 🔒

use crate::draft16::namespace::SubscribeNamespaceStateMachine; 🔒

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

use crate::draft16::publish::PublishState; 🔒

use crate::draft16::publish::PublishStateMachine; 🔒

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

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

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

use crate::draft16::session::setup; 🔒

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

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

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

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

use crate::draft16::subscription::SubscriptionError; 🔒

use crate::draft16::subscription::SubscriptionState; 🔒

use crate::draft16::subscription::SubscriptionStateMachine; 🔒

use crate::draft16::track_status::TrackStatusError; 🔒

use crate::draft16::track_status::TrackStatusState; 🔒

use crate::draft16::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::draft16::error_codes::RequestErrorCode; 🔒

use moqtap_codec::draft16::error_codes::SessionErrorCode; 🔒

use moqtap_codec::draft16::message; 🔒

use moqtap_codec::draft16::message::ClientSetup; 🔒

use moqtap_codec::draft16::message::ControlMessage; 🔒

use moqtap_codec::draft16::message::Fetch; 🔒

use moqtap_codec::draft16::message::FetchCancel; 🔒

use moqtap_codec::draft16::message::FetchPayload; 🔒

use moqtap_codec::draft16::message::FetchType; 🔒

use moqtap_codec::draft16::message::GoAway; 🔒

use moqtap_codec::draft16::message::MaxRequestId; 🔒

use moqtap_codec::draft16::message::MessageType; 🔒

use moqtap_codec::draft16::message::PublishDone; 🔒

use moqtap_codec::draft16::message::PublishNamespace; 🔒

use moqtap_codec::draft16::message::PublishNamespaceCancel; 🔒

use moqtap_codec::draft16::message::PublishNamespaceDone; 🔒

use moqtap_codec::draft16::message::RequestError; 🔒

use moqtap_codec::draft16::message::RequestOk; 🔒

use moqtap_codec::draft16::message::RequestUpdate; 🔒

use moqtap_codec::draft16::message::RequestsBlocked; 🔒

use moqtap_codec::draft16::message::ServerSetup; 🔒

use moqtap_codec::draft16::message::Subscribe; 🔒

use moqtap_codec::draft16::message::SubscribeNamespace; 🔒

use moqtap_codec::draft16::message::SubscribeOk; 🔒

use moqtap_codec::draft16::message::Unsubscribe; 🔒

use moqtap_codec::kvp::KeyValuePair; 🔒

use moqtap_codec::kvp::KvpValue; 🔒

use moqtap_codec::varint::VarInt; 🔒

use moqtap_codec::types::*; 🔒

Structs

Endpoint

Unified MoQT endpoint wrapping session lifecycle, request ID allocation, and all per-request state machines (subscriptions, fetches, namespaces).

FetchTrack 🔒

The track one fetch is for, which the fetch’s own state machine does not hold. A fetch names no Track Alias, so this is the only place a fetch’s track is written down; for a Joining Fetch, which names no track either, this is the joined subscription’s track resolved when the fetch was made.

InboundFetch 🔒

A fetch the peer opened with FETCH.

InboundPublishNamespace 🔒

An announcement the peer made with PUBLISH_NAMESPACE.

InboundSubscribe 🔒

A subscription the peer opened with SUBSCRIBE.

InboundTrackStatus 🔒

A track status the peer asked for with TRACK_STATUS.

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.

UpdatedRequest 🔒

The kinds Section 9.2.2’s qualifiers distinguish between.

Constants

FORWARD_PARAMETER 🔒

Section 9.2.2.8, “for a subscription”.

NEW_GROUP_REQUEST_PARAMETER 🔒

Section 9.2.2.9, “for a subscription”.

SUBSCRIBER_PRIORITY_PARAMETER 🔒

Section 9.2.2.3, “for a subscription or FETCH”.

SUBSCRIPTION_FILTER_PARAMETER 🔒

Section 9.2.2.5, “for a subscription”.

Functions

prefixes_overlap 🔒

Whether two namespace prefixes overlap.