Enum SinkPolicy 

pub enum SinkPolicy {
    FailDecision {
        timeout_ms: u64,
    },
    Backpressure {
        max_pending: usize,
        enqueue_timeout_ms: u64,
        delivery_timeout_ms: u64,
    },
    DropCounted {
        max_pending: usize,
        delivery_timeout_ms: u64,
    },
}

How evidence reaches the sink, and what the caller receives.

Variants

FailDecision

Deliver inline; the decision fails unless the sink acknowledges within timeout_ms.

Fields

timeout_ms: u64

Backpressure

Queue for the worker, waiting at most enqueue_timeout_ms for one of max_pending slots; the decision fails if none frees.

Fields

max_pending: usize

enqueue_timeout_ms: u64

delivery_timeout_ms: u64

DropCounted

Queue if a slot is free; otherwise drop the record and count it.

Fields

max_pending: usize

delivery_timeout_ms: u64

Trait Implementations

impl Clone for SinkPolicy

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for SinkPolicy

impl Debug for SinkPolicy

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

Formats the value using the given formatter.

impl Eq for SinkPolicy

impl PartialEq for SinkPolicy

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for SinkPolicy