Skip to main content

Module endpoint

moqtap_client::draft17

Module endpoint 

Source
Expand description

Draft-17 MoQT endpoint.

Major architectural differences from earlier drafts:

  • Unified Setup message (no separate CLIENT_SETUP / SERVER_SETUP).
  • Response messages (SubscribeOk, PublishOk, FetchOk, PublishDone, RequestOk, RequestError) do NOT carry a request_id. Each request opens its own bidirectional stream and its response arrives as the first message on that stream, so the stream itself identifies the request. The transport layer knows which request_id each bidi stream belongs to; callers must supply that request_id via Endpoint::receive_response_on_stream.
  • No Unsubscribe, FetchCancel, MaxRequestId, RequestsBlocked, PublishNamespaceDone, or PublishNamespaceCancel messages.
  • Request-producing messages (Subscribe, Publish, Fetch, PublishNamespace, SubscribeNamespace, TrackStatus, RequestUpdate) gain a required_request_id_delta field.
  • New PublishBlocked message notifies subscribers a publisher is blocked.
  • Namespace and NamespaceDone are unsolicited announcements of namespace suffixes.

Re-exports§

use std::collections::HashMap; 🔒
use std::collections::HashSet; 🔒
use std::sync::Arc; 🔒
use std::sync::Mutex; 🔒
use crate::draft17::fetch::FetchError; 🔒
use crate::draft17::fetch::FetchState; 🔒
use crate::draft17::fetch::FetchStateMachine; 🔒
use crate::draft17::namespace::NamespaceError; 🔒
use crate::draft17::namespace::PublishNamespaceState; 🔒
use crate::draft17::namespace::PublishNamespaceStateMachine; 🔒
use crate::draft17::namespace::SubscribeNamespaceState; 🔒
use crate::draft17::namespace::SubscribeNamespaceStateMachine; 🔒
use crate::draft17::publish::PublishError as PublishFlowError; 🔒
use crate::draft17::publish::PublishState; 🔒
use crate::draft17::publish::PublishStateMachine; 🔒
use crate::draft17::session::request_id::RequestIdAllocator; 🔒
use crate::draft17::session::request_id::RequestIdError; 🔒
use crate::draft17::session::request_id::Role; 🔒
use crate::draft17::session::setup; 🔒
use crate::draft17::session::setup::SetupError; 🔒
use crate::draft17::session::state::SessionError; 🔒
use crate::draft17::session::state::SessionState; 🔒
use crate::draft17::session::state::SessionStateMachine; 🔒
use crate::draft17::subscription::SubscriptionError; 🔒
use crate::draft17::subscription::SubscriptionState; 🔒
use crate::draft17::subscription::SubscriptionStateMachine; 🔒
use crate::draft17::track_status::TrackStatusError; 🔒
use crate::draft17::track_status::TrackStatusState; 🔒
use crate::draft17::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::draft17::error_codes::PublishDoneStatusCode; 🔒
use moqtap_codec::draft17::error_codes::RequestErrorCode; 🔒
use moqtap_codec::draft17::error_codes::SessionErrorCode; 🔒
use moqtap_codec::draft17::message; 🔒
use moqtap_codec::draft17::message::ControlMessage; 🔒
use moqtap_codec::draft17::message::Fetch; 🔒
use moqtap_codec::draft17::message::FetchPayload; 🔒
use moqtap_codec::draft17::message::FetchType; 🔒
use moqtap_codec::draft17::message::GoAway; 🔒
use moqtap_codec::draft17::message::MessageType; 🔒
use moqtap_codec::draft17::message::Publish; 🔒
use moqtap_codec::draft17::message::PublishBlocked; 🔒
use moqtap_codec::draft17::message::PublishDone; 🔒
use moqtap_codec::draft17::message::PublishNamespace; 🔒
use moqtap_codec::draft17::message::RequestError; 🔒
use moqtap_codec::draft17::message::RequestOk; 🔒
use moqtap_codec::draft17::message::RequestUpdate; 🔒
use moqtap_codec::draft17::message::Setup; 🔒
use moqtap_codec::draft17::message::Subscribe; 🔒
use moqtap_codec::draft17::message::SubscribeNamespace; 🔒
use moqtap_codec::draft17::message::SubscribeOk; 🔒
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.

Functions§

prefixes_overlap 🔒
Whether two namespace prefixes overlap.