Enum Frame 

pub enum Frame {
    Publish {
        topic: String,
        payload: Bytes,
        reply_to: Option<String>,
    },
    Subscribe {
        sid: u64,
        subject: String,
        queue_group: Option<String>,
    },
    Unsubscribe {
        sid: u64,
    },
    Message {
        topic: String,
        sid: u64,
        payload: Bytes,
        reply_to: Option<String>,
    },
    Ping,
    Pong,
    Ok,
    Err {
        message: String,
    },
}

A frame on the wire. This is the unit of communication between client and broker.

Variants

Publish

Client -> Broker: publish a message to a topic.

Fields

topic: String

payload: Bytes

reply_to: Option<String>

Subscribe

Client -> Broker: subscribe to a subject pattern.

Fields

sid: u64

subject: String

queue_group: Option<String>

Unsubscribe

Client -> Broker: unsubscribe from a subscription.

Fields

sid: u64

Message

Broker -> Client: deliver a message to a subscriber.

Fields

topic: String

sid: u64

payload: Bytes

reply_to: Option<String>

Ping

Bidirectional: keepalive ping.

Pong

Bidirectional: keepalive pong.

Ok

Broker -> Client: operation succeeded.

Err

Broker -> Client: operation failed.

Fields

message: String

Trait Implementations

impl Clone for Frame

fn clone(&self) -> Frame

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Frame

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for Frame

fn deserialize<D: Deserializer<'de>>(deserializer: D) -> Result<Self, D::Error>

Deserialize this value from the given Serde deserializer.

impl Encoder<Frame> for TopiqCodec

type Error = TopiqError

The type of encoding errors.

fn encode(&mut self, item: Frame, dst: &mut BytesMut) -> Result<(), TopiqError>

Encodes a frame into the buffer provided.

impl PartialEq for Frame

fn eq(&self, other: &Frame) -> 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 Serialize for Frame

fn serialize<S: Serializer>(&self, serializer: S) -> Result<S::Ok, S::Error>

Serialize this value into the given Serde serializer.

impl Eq for Frame

impl StructuralPartialEq for Frame