Skip to main content

Module endpoint

Module endpoint 

Source
Expand description

Draft-18 MoQT endpoint.

Major changes from draft-17:

  • Required Request ID Delta field removed from every request message.
  • SubscribeNamespace lost its subscribe_options field; namespace subscriptions only produce NAMESPACE / NAMESPACE_DONE. The new SubscribeTracks request type subscribes to PUBLISH messages and carries the FORWARD parameter.
  • PublishOk collapsed into RequestOk (REQUEST_OK at type 0x07); RequestOk gains a trailing Track Properties block.
  • GoAway gains an optional request_id (control stream only).
  • RequestError gains an optional Redirect structure (carried when error_code == REDIRECT).

Re-exportsΒ§

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

ConstantsΒ§

TRACK_NAMESPACE_PREFIX πŸ”’
Parameter Type of TRACK_NAMESPACE_PREFIX.

FunctionsΒ§

prefixes_overlap πŸ”’
Whether two namespace prefixes overlap.
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.