Enum nakadion::components::committer::CommitTrigger

pub enum CommitTrigger {
    Deadline {
        n_cursors: usize,
        n_events: Option<usize>,
    },
    Events {
        n_cursors: usize,
        n_events: Option<usize>,
    },
    Cursors {
        n_cursors: usize,
        n_events: Option<usize>,
    },
}

The reason why data was committed if working in background mode

Variants

Deadline

The deadline to commit was reached

Fields of Deadline

n_cursors: usizen_events: Option<usize>

Events

Enough events were received

Fields of Events

n_cursors: usizen_events: Option<usize>

Cursors

Enough cursors were received

Fields of Cursors

n_cursors: usizen_events: Option<usize>

Implementations

impl CommitTrigger

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

pub fn n_cursors(&self) -> usize

pub fn n_events(&self) -> Option<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