Module message 

Control message types with encode/decode.

Re-exports

use crate::auth_token::AuthorizationToken; 🔒

use crate::auth_token::AUTH_TOKEN_PARAMETER; 🔒

use crate::error::CodecError; 🔒

use crate::error::MAX_FULL_TRACK_NAME_LENGTH; 🔒

use crate::error::MAX_GOAWAY_URI_LENGTH; 🔒

use crate::error::MAX_MESSAGE_LENGTH; 🔒

use crate::error::MAX_REASON_PHRASE_LENGTH; 🔒

use crate::kvp::KeyValuePair; 🔒

use crate::kvp::KvpValue; 🔒

pub use crate::types::check_group_range;

pub use crate::types::check_location_range;

pub use crate::types::check_open_ended_group_range;

use crate::varint::VarInt; 🔒

use bytes::Buf; 🔒

use bytes::BufMut; 🔒

use crate::types::*; 🔒

Structs

ClientSetup

CLIENT_SETUP message (type 0x20).

Fetch

FETCH message (type 0x16).

FetchCancel

FETCH_CANCEL message (type 0x17).

FetchError

FETCH_ERROR message (type 0x19).

FetchOk

FETCH_OK message (type 0x18).

GoAway

GOAWAY message (type 0x10).

MaxRequestId

MAX_REQUEST_ID message (type 0x15).

Publish

PUBLISH message (type 0x1D).

PublishDone

PUBLISH_DONE message (type 0x0B).

PublishError

PUBLISH_ERROR message (type 0x1F).

PublishNamespace

PUBLISH_NAMESPACE message (type 0x06).

PublishNamespaceCancel

PUBLISH_NAMESPACE_CANCEL message (type 0x0C).

PublishNamespaceDone

PUBLISH_NAMESPACE_DONE message (type 0x09).

PublishNamespaceError

PUBLISH_NAMESPACE_ERROR message (type 0x08).

PublishNamespaceOk

PUBLISH_NAMESPACE_OK message (type 0x07).

PublishOk

PUBLISH_OK message (type 0x1E).

RequestsBlocked

REQUESTS_BLOCKED message (type 0x1A).

ServerSetup

SERVER_SETUP message (type 0x21).

Subscribe

SUBSCRIBE message (type 0x03).

SubscribeError

SUBSCRIBE_ERROR message (type 0x05).

SubscribeNamespace

SUBSCRIBE_NAMESPACE message (type 0x11).

SubscribeNamespaceError

SUBSCRIBE_NAMESPACE_ERROR message (type 0x13).

SubscribeNamespaceOk

SUBSCRIBE_NAMESPACE_OK message (type 0x12).

SubscribeOk

SUBSCRIBE_OK message (type 0x04).

SubscribeUpdate

SUBSCRIBE_UPDATE message (type 0x02).

TrackStatus

TRACK_STATUS message (type 0x0D) — subscribe-like request.

TrackStatusError

TRACK_STATUS_ERROR message (type 0x0F).

TrackStatusOk

TRACK_STATUS_OK message (type 0x0E) — subscribe_ok-like response.

Unsubscribe

UNSUBSCRIBE message (type 0x0A).

UnsubscribeNamespace

UNSUBSCRIBE_NAMESPACE message (type 0x14).

Enums

ControlMessage

A parsed MoQT control message (draft-14).

FetchPayload

FETCH payload — either a standalone fetch or a joining fetch.

FetchType

FETCH type discriminator (standalone vs joining).

MessageType

Control message type IDs (draft-14).

Constants

KNOWN_SETUP_PARAMETERS 🔒

Every setup parameter type draft-14 names, from Section 9.3.2.

KNOWN_VERSION_SPECIFIC_PARAMETERS 🔒

Every version-specific parameter type draft-14 names, from Section 9.2.1.

REPEATABLE_PARAMETER 🔒

The one parameter type whose own definition lets it repeat.

Functions

check_authorization_tokens 🔒

Hold every AUTHORIZATION TOKEN parameter to the Token structure it names.

check_discriminators 🔒

Refuse a message whose discriminator disagrees with the fields beside it.

check_full_track_name 🔒

Hold a namespace-plus-name pair to the Full Track Name cap.

check_group_order 🔒

Refuse a Group Order of 0x0 on the messages that forbid it.

check_no_duplicate_parameters_received 🔒

Refuse a received parameter list that repeats a type this draft names.

check_no_duplicate_parameters_sent 🔒

Refuse a parameter list a sender may not put on the wire.

check_ranges 🔒

Refuse a request whose range ends before it starts.

decode_parameters 🔒

Decode a version-specific parameter list, refusing a repeated known type.

decode_setup_parameters 🔒

Decode a SETUP message’s parameter list, refusing a repeated known type.

encode_parameters 🔒

Encode a parameter list, refusing every repeat the sender’s rule forbids and every token that is not one.

read_group_order_response 🔒

Read a Group Order from a message that must name a real order.

read_reason_phrase 🔒

Read a Reason Phrase, holding it to the cap the draft states for the reader.