Enum rocketmq_common::common::message::MessageVersion

pub enum MessageVersion {
    V1,
    V2,
}

Variants

V1

V2

Implementations

impl MessageVersion

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

pub fn get_magic_code(&self) -> i32

pub fn get_topic_length_size(&self) -> usize

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

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

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

pub fn is_v1(&self) -> bool

pub fn is_v2(&self) -> bool

Trait Implementations

impl Clone for MessageVersion

fn clone(&self) -> MessageVersion

Returns a copy of the value.

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

Performs copy-assignment from source.

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 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: &MessageVersion) -> bool

This method tests for self and other values to be equal, and is used by ==.

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

This method tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Copy for MessageVersion

impl Eq for MessageVersion

impl StructuralPartialEq for MessageVersion