Struct Message 

pub struct Message {
    pub typ: MessageType,
    pub length: u32,
    pub transaction_id: TransactionId,
    pub attributes: Attributes,
    pub raw: Vec<u8>,
}

Fields

typ: MessageType

length: u32

transaction_id: TransactionId

attributes: Attributes

raw: Vec<u8>

Implementations

impl Message

pub fn new() -> Self

pub fn marshal_binary(&self) -> Result<Vec<u8>>

pub fn unmarshal_binary(&mut self, data: &[u8]) -> Result<()>

pub fn new_transaction_id(&mut self) -> Result<()>

pub fn reset(&mut self)

pub fn add(&mut self, t: AttrType, v: &[u8])

pub fn write_length(&mut self)

pub fn write_header(&mut self)

pub fn write_transaction_id(&mut self)

pub fn write_attributes(&mut self)

pub fn write_type(&mut self)

pub fn set_type(&mut self, t: MessageType)

pub fn encode(&mut self)

pub fn decode(&mut self) -> Result<()>

pub fn write_to<W: Write>(&self, writer: &mut W) -> Result<usize>

pub fn read_from<R: Read>(&mut self, reader: &mut R) -> Result<usize>

pub fn write(&mut self, t_buf: &[u8]) -> Result<usize>

pub fn clone_to(&self, b: &mut Message) -> Result<()>

pub fn contains(&self, t: AttrType) -> bool

pub fn get(&self, t: AttrType) -> Result<Vec<u8>>

pub fn build(&mut self, setters: &[Box<dyn Setter>]) -> Result<()>

pub fn check<C: Checker>(&self, checkers: &[C]) -> Result<()>

pub fn parse<G: Getter>(&self, getters: &mut [G]) -> Result<()>

Trait Implementations

impl Clone for Message

fn clone(&self) -> Message

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Message

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

Formats the value using the given formatter.

impl Default for Message

fn default() -> Message

Returns the “default value” for a type.

impl Display for Message

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

Formats the value using the given formatter.

impl PartialEq for Message

fn eq(&self, other: &Self) -> 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 Protocol<TransportMessage<BytesMut>, Message, Event> for Client

fn poll_write(&mut self) -> Option<Self::Wout>

Returns packets to transmit

It should be polled for transmit after:

• the application performed some I/O
• a call was made to handle_read
• a call was made to handle_write
• a call was made to handle_timeout

type Rout = ()

Output read message type

type Wout = TransportMessage<BytesMut>

Output write message type

type Eout = Event

Output event type

type Error = Error

Error type for protocol operations

type Time = Instant

Time/Instant type for timeout handling

fn handle_read(&mut self, msg: TaggedBytesMut) -> Result<()>

Handle an incoming read message.

fn poll_read(&mut self) -> Option<Self::Rout>

Poll for a processed read message.

fn handle_write(&mut self, m: Message) -> Result<()>

Handle an outgoing write message.

fn poll_event(&mut self) -> Option<Self::Eout>

Poll for a generated event.

fn poll_timeout(&mut self) -> Option<Self::Time>

Poll for the next timeout deadline.

fn handle_timeout(&mut self, now: Instant) -> Result<()>

Handle a timeout event.

fn close(&mut self) -> Result<()>

Close the protocol.

fn handle_event(&mut self, _evt: Ein) -> Result<(), Self::Error>

Handle a custom event.

impl Setter for Message

fn add_to(&self, b: &mut Message) -> Result<()>