Enum ControlMessage 

pub enum ControlMessage {
    ClientSetup(ClientSetup),
    ServerSetup(ServerSetup),
    GoAway(GoAway),
    MaxRequestId(MaxRequestIdMsg),
    RequestsBlocked(RequestsBlocked),
    Subscribe(Subscribe),
    SubscribeOk(SubscribeOk),
    SubscribeError(SubscribeError),
    SubscribeUpdate(SubscribeUpdate),
    Unsubscribe(Unsubscribe),
    Publish(Publish),
    PublishOk(PublishOk),
    PublishError(PublishError),
    PublishDone(PublishDone),
    PublishNamespace(PublishNamespaceMsg),
    PublishNamespaceOk(PublishNamespaceOk),
    PublishNamespaceError(PublishNamespaceError),
    PublishNamespaceDone(PublishNamespaceDone),
    PublishNamespaceCancel(PublishNamespaceCancel),
    SubscribeNamespace(SubscribeNamespace),
    SubscribeNamespaceOk(SubscribeNamespaceOk),
    SubscribeNamespaceError(SubscribeNamespaceError),
    UnsubscribeNamespace(UnsubscribeNamespace),
    Fetch(Fetch),
    FetchOk(FetchOk),
    FetchError(FetchError),
    FetchCancel(FetchCancel),
    TrackStatus(TrackStatusMsg),
    TrackStatusOk(TrackStatusOk),
    TrackStatusError(TrackStatusError),
}

Variants

ClientSetup(ClientSetup)

ServerSetup(ServerSetup)

GoAway(GoAway)

MaxRequestId(MaxRequestIdMsg)

RequestsBlocked(RequestsBlocked)

Subscribe(Subscribe)

SubscribeOk(SubscribeOk)

SubscribeError(SubscribeError)

SubscribeUpdate(SubscribeUpdate)

Unsubscribe(Unsubscribe)

Publish(Publish)

PublishOk(PublishOk)

PublishError(PublishError)

PublishDone(PublishDone)

PublishNamespace(PublishNamespaceMsg)

PublishNamespaceOk(PublishNamespaceOk)

PublishNamespaceError(PublishNamespaceError)

PublishNamespaceDone(PublishNamespaceDone)

PublishNamespaceCancel(PublishNamespaceCancel)

SubscribeNamespace(SubscribeNamespace)

SubscribeNamespaceOk(SubscribeNamespaceOk)

SubscribeNamespaceError(SubscribeNamespaceError)

UnsubscribeNamespace(UnsubscribeNamespace)

Fetch(Fetch)

FetchOk(FetchOk)

FetchError(FetchError)

FetchCancel(FetchCancel)

TrackStatus(TrackStatusMsg)

TrackStatusOk(TrackStatusOk)

TrackStatusError(TrackStatusError)

Implementations

impl ControlMessage

pub fn encode(&self, buf: &mut impl BufMut) -> Result<(), CodecError>

Encode this control message to bytes (including type ID and length prefix).

pub fn decode(buf: &mut impl Buf) -> Result<Self, CodecError>

Decode a control message from bytes (reads type ID and length prefix first).

fn encode_payload(&self, buf: &mut impl BufMut) -> Result<(), CodecError>

fn decode_payload( msg_type: MessageType, buf: &mut impl Buf, ) -> Result<Self, CodecError>

pub fn message_type(&self) -> MessageType

Get the message type ID for this message.

Trait Implementations

impl Clone for ControlMessage

fn clone(&self) -> ControlMessage

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ControlMessage

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl PartialEq for ControlMessage

fn eq(&self, other: &ControlMessage) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Eq for ControlMessage

impl StructuralPartialEq for ControlMessage