Enum Op

pub enum Op {
    INFO(ServerInfo),
    CONNECT(ConnectCommand),
    PUB(PubCommand),
    SUB(SubCommand),
    UNSUB(UnsubCommand),
    MSG(Message),
    PING,
    PONG,
    OK,
    ERR(ServerError),
}

Abstraction over NATS protocol messages

Variants

INFO(ServerInfo)

SERVER Sent to client after initial TCP/IP connection

CONNECT(ConnectCommand)

CLIENT Sent to server to specify connection information

PUB(PubCommand)

CLIENT Publish a message to a subject, with optional reply subject

SUB(SubCommand)

CLIENT Subscribe to a subject (or subject wildcard)

UNSUB(UnsubCommand)

CLIENT Unsubscribe (or auto-unsubscribe) from subject

MSG(Message)

SERVER Delivers a message payload to a subscriber

PING

BOTH PING keep-alive message

PONG

BOTH PONG keep-alive message

OK

SERVER Acknowledges well-formed protocol message in verbose mode

ERR(ServerError)

SERVER Indicates a protocol error. May cause client disconnect.

Implementations

impl Op

pub fn into_bytes(self) -> Result<Bytes, CommandError>

Transforms the OP into a byte slice

pub fn from_bytes(cmd_name: &[u8], buf: &[u8]) -> Result<Self, CommandError>

Tries to parse from a pair of command name and whole buffer

Trait Implementations

impl Clone for Op

fn clone(&self) -> Op

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Op

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

Formats the value using the given formatter.

impl PartialEq for Op

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