Enum OverflowPolicy 

pub enum OverflowPolicy {
    Block,
    Buffer {
        limit: u32,
    },
    DropToDlq,
    DropSilent,
}

Policy when producer has no credits left.

Variants

Block

Block the producer until credits are available.

Buffer

Buffer messages locally (up to buffer_limit).

Fields

limit: u32

Maximum number of messages to buffer.

DropToDlq

Drop the message and route to dead letter queue.

DropSilent

Drop the message silently (with metric increment).

Trait Implementations

impl Clone for OverflowPolicy

fn clone(&self) -> OverflowPolicy

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for OverflowPolicy

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

Formats the value using the given formatter.

impl PartialEq for OverflowPolicy

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

Tests for self and other values to be equal, and is used by ==.

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

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

impl Copy for OverflowPolicy

impl Eq for OverflowPolicy

impl StructuralPartialEq for OverflowPolicy