Enum PersistOverflow 

pub enum PersistOverflow {
    Drop,
    Block,
}

Behavior when the L2 persist queue is full.

Variants

Drop

Non-blocking try_send; drop the job and increment persist_queue_drops (default).

Block

Apply backpressure: block the calling thread until the job is enqueued (or the queue closes).

When called from a Tokio worker thread, uses block_in_place so the runtime can schedule other work while waiting. Prefer this for scripts that must not lose emits under load.

Trait Implementations

impl Clone for PersistOverflow

fn clone(&self) -> PersistOverflow

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for PersistOverflow

impl Debug for PersistOverflow

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

Formats the value using the given formatter.

impl Default for PersistOverflow

fn default() -> PersistOverflow

Returns the “default value” for a type.

impl Eq for PersistOverflow

impl PartialEq for PersistOverflow

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for PersistOverflow