Enum MessageVersion 

pub enum MessageVersion {
    V1,
    V2,
}

Represents the message format version.

Variants

V1

V2

Implementations

impl MessageVersion

pub fn value_of_magic_code( magic_code: i32, ) -> Result<MessageVersion, &'static str>

Returns the message version corresponding to the given magic code.

Errors

Returns an error if the magic code is not recognized.

pub fn get_magic_code(&self) -> i32

Returns the magic code for this message version.

pub fn get_topic_length_size(&self) -> usize

Returns the number of bytes used to encode the topic length.

pub fn get_topic_length(&self, buffer: &mut Bytes) -> usize

Reads and returns the topic length from the buffer, advancing the buffer position.

pub fn get_topic_length_at_index(&self, buffer: &[u8], index: usize) -> usize

Returns the topic length from the buffer at the specified index without advancing the position.

pub fn put_topic_length(&self, buffer: &mut Vec<u8>, topic_length: usize)

Writes the topic length to the buffer according to the message version.

pub fn is_v1(&self) -> bool

Returns true if this is message format version 1.

pub fn is_v2(&self) -> bool

Returns true if this is message format version 2.

Trait Implementations

impl Clone for MessageVersion

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for MessageVersion

impl Debug for MessageVersion

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

Formats the value using the given formatter.

impl Default for MessageVersion

fn default() -> Self

Returns the “default value” for a type.

impl Display for MessageVersion

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

Formats the value using the given formatter.

impl Eq for MessageVersion

impl Hash for MessageVersion

fn hash<__H: Hasher>(&self, state: &mut __H)

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)

where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher.

impl PartialEq for MessageVersion

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for MessageVersion