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

This method tests for !=.

impl StructuralPartialEq for DeliverCommand