Struct SendMessagesResponse 

pub struct SendMessagesResponse {
    pub confirmations: Vec<SendMessagesConfirmationResponse>,
}

The Apache Iggy producer/consumer escape hatch: same types Topic::iggy_producer/Topic::iggy_consumer/Topic::iggy_consumer_group return, and the stored message a failed publish hands back, re-exported so reaching for them doesn’t need an iggy dependency of your own. SendMessages response.

Wire format:

[confirmations_count:4][SendMessagesConfirmationResponse]*

confirmations_count == 0 supplies no offset information. Callers must also handle an empty successful reply body, which the server uses for a request classified as a duplicate. Neither response identifies an append position.

The server currently reports a single partition per request; the list decodes any count, so a later multi-partition send needs no wire change. Growing the count is the only compatible way to extend this response, the entry itself being frozen at 20 bytes.

Fields

confirmations: Vec<SendMessagesConfirmationResponse>

Trait Implementations

impl Clone for SendMessagesResponse

fn clone(&self) -> SendMessagesResponse

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SendMessagesResponse

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

Formats the value using the given formatter.

impl Eq for SendMessagesResponse

impl From<SendMessagesConfirmations> for SendMessagesResponse

fn from(body: SendMessagesConfirmations) -> SendMessagesResponse

Converts to this type from the input type.

impl PartialEq for SendMessagesResponse

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for SendMessagesResponse

impl WireDecode for SendMessagesResponse

fn decode(buf: &[u8]) -> Result<(SendMessagesResponse, usize), WireError>

Decode from buf, consuming exactly the bytes needed. Returns the decoded value and the number of bytes consumed.

fn decode_from(buf: &[u8]) -> Result<Self, WireError>

Convenience: decode from the entire buffer, ignoring trailing bytes.

impl WireEncode for SendMessagesResponse

fn encoded_size(&self) -> usize

Return the exact encoded size in bytes.

fn encode(&self, buf: &mut BytesMut)

Write the encoded representation into buf.

fn to_bytes(&self) -> Bytes

Convenience: allocate a new Bytes and encode into it.