Struct rabbitmq_stream_protocol::commands::deliver::DeliverCommand

pub struct DeliverCommand {
    pub subscription_id: u8,
    pub chunk_first_offset: u64,
    pub messages: Vec<Message>,
    /* private fields */
}

Fields

subscription_id: u8

chunk_first_offset: u64

messages: Vec<Message>

Implementations

impl DeliverCommand

pub fn new( subscription_id: u8, magic_version: i8, chunk_type: u8, num_entries: u16, timestamp: u64, epoch: u64, chunk_first_offset: u64, chunk_crc: i32, trailer_length: u32, reserved: u32, messages: Vec<Message> ) -> Self

Trait Implementations

impl Clone for DeliverCommand

fn clone(&self) -> DeliverCommand

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Command for DeliverCommand

fn key(&self) -> u16

impl Debug for DeliverCommand

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

Formats the value using the given formatter.

impl Decoder for DeliverCommand

fn decode(input: &[u8]) -> Result<(&[u8], Self), DecodeError>

impl Encoder for DeliverCommand

fn encoded_size(&self) -> u32

fn encode(&self, writer: &mut impl Write) -> Result<(), EncodeError>

impl PartialEq<DeliverCommand> for DeliverCommand

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

impl StructuralEq for DeliverCommand

impl StructuralPartialEq for DeliverCommand