Enum nakadion::instrumentation::CommitTrigger

pub enum CommitTrigger {
    Deadline {
        n_batches: usize,
        n_events: usize,
    },
    Events {
        n_batches: usize,
        n_events: usize,
    },
    Batches {
        n_batches: usize,
        n_events: usize,
    },
}

Variants

Deadline

The deadline to commit was reached

Fields of Deadline

n_batches: usizen_events: usize

Events

Enough events were received

Fields of Events

n_batches: usizen_events: usize

Batches

Enough cursors were received

Fields of Batches

n_batches: usizen_events: usize

Implementations

impl CommitTrigger

pub fn stats(&self) -> (usize, usize)

pub fn n_batches(&self) -> usize

pub fn n_events(&self) -> usize

Trait Implementations

impl Clone for CommitTrigger

fn clone(&self) -> CommitTrigger

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Copy for CommitTrigger

impl Debug for CommitTrigger

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

Formats the value using the given formatter.

impl Eq for CommitTrigger

impl PartialEq<CommitTrigger> for CommitTrigger

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

This method tests for self and other values to be equal, and is used by ==.

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

This method tests for !=.

impl StructuralEq for CommitTrigger

impl StructuralPartialEq for CommitTrigger