Struct SlimHeader 

pub struct SlimHeader {
    pub source: Option<Name>,
    pub destination: Option<Name>,
    pub fanout: u32,
    pub recv_from: Option<u64>,
    pub forward_to: Option<u64>,
    pub incoming_conn: Option<u64>,
    pub error: Option<bool>,
}

recvFrom = connection from where the sub/unsub is supposed to be received forwardTo = connection where to forward the message incomingConn = connection from where the packet was received error = if true the publication contains an error notification

Fields

source: Option<Name>

destination: Option<Name>

fanout: u32

recv_from: Option<u64>

forward_to: Option<u64>

incoming_conn: Option<u64>

error: Option<bool>

Implementations

impl SlimHeader

pub fn recv_from(&self) -> u64

Returns the value of recv_from, or the default value if recv_from is unset.

pub fn forward_to(&self) -> u64

Returns the value of forward_to, or the default value if forward_to is unset.

pub fn incoming_conn(&self) -> u64

Returns the value of incoming_conn, or the default value if incoming_conn is unset.

pub fn error(&self) -> bool

Returns the value of error, or the default value if error is unset.

impl SlimHeader

SLIM Header This header is used to identify the source and destination of the message and to manage the connections used to send and receive the message

pub fn new( source: &Name, destination: &Name, flags: Option<SlimHeaderFlags>, ) -> Self

pub fn clear(&mut self)

pub fn get_recv_from(&self) -> Option<u64>

pub fn get_forward_to(&self) -> Option<u64>

pub fn get_incoming_conn(&self) -> Option<u64>

pub fn get_error(&self) -> Option<bool>

pub fn get_source(&self) -> Name

pub fn get_dst(&self) -> Name

pub fn set_source(&mut self, source: &Name)

pub fn set_destination(&mut self, dst: &Name)

pub fn get_fanout(&self) -> u32

pub fn set_recv_from(&mut self, recv_from: Option<u64>)

pub fn set_forward_to(&mut self, forward_to: Option<u64>)

pub fn set_error(&mut self, error: Option<bool>)

pub fn set_incoming_conn(&mut self, incoming_conn: Option<u64>)

pub fn set_error_flag(&mut self, error: Option<bool>)

pub fn set_fanout(&mut self, fanout: u32)

pub fn get_in_out_connections(&self) -> (u64, Option<u64>)

Trait Implementations

impl Clone for SlimHeader

fn clone(&self) -> SlimHeader

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SlimHeader

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

Formats the value using the given formatter.

impl Default for SlimHeader

fn default() -> Self

Returns the “default value” for a type.

impl Message for SlimHeader

fn encoded_len(&self) -> usize

Returns the encoded length of the message without a length delimiter.

fn clear(&mut self)

Clears the message, resetting all fields to their default.

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

where Self: Sized,

Encodes the message to a buffer.

fn encode_to_vec(&self) -> Vec<u8>

where Self: Sized,

Encodes the message to a newly allocated buffer.

fn encode_length_delimited( &self, buf: &mut impl BufMut, ) -> Result<(), EncodeError>

where Self: Sized,

Encodes the message with a length-delimiter to a buffer.

fn encode_length_delimited_to_vec(&self) -> Vec<u8>

where Self: Sized,

Encodes the message with a length-delimiter to a newly allocated buffer.

fn decode(buf: impl Buf) -> Result<Self, DecodeError>

where Self: Default,

Decodes an instance of the message from a buffer.

fn decode_length_delimited(buf: impl Buf) -> Result<Self, DecodeError>

where Self: Default,

Decodes a length-delimited instance of the message from the buffer.

fn merge(&mut self, buf: impl Buf) -> Result<(), DecodeError>

where Self: Sized,

Decodes an instance of the message from a buffer, and merges it into self.

fn merge_length_delimited(&mut self, buf: impl Buf) -> Result<(), DecodeError>

where Self: Sized,

Decodes a length-delimited instance of the message from buffer, and merges it into self.

impl PartialEq for SlimHeader

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

impl StructuralPartialEq for SlimHeader