Enum nakadion::ProcessingStatus

pub enum ProcessingStatus {
    Processed(Option<usize>),
    Failed {
        reason: String,
    },
}

This struct must be returned after processing a batch to tell nakadion how to continue.

Variants

Processed(Option<usize>)

The cursor of the just processed batch can be committed to make progrss on the stream.

Optionally the number of processed events can be provided to help with deciding on when to commit the cursor.

The number of events should be the number of events that were in the batch.

Failed

Processing failed. Do not commit the cursor. This always ends in the streaming being aborted for the current stream.

A reason must be given which will be logged.

Fields of Failed

reason: String

Methods

impl ProcessingStatus

pub fn processed_no_hint() -> ProcessingStatus

Cursor can be committed and no information on how many events were processed is given.

pub fn processed(num_events_hint: usize) -> ProcessingStatus

Cursor can be committed and a hint on how many events were processed is given.

pub fn failed<T: Into<String>>(reason: T) -> ProcessingStatus

Processing events failed with the given reason.

Trait Implementations

impl Clone for ProcessingStatus

fn clone(&self) -> ProcessingStatus

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Eq for ProcessingStatus

impl PartialEq<ProcessingStatus> for ProcessingStatus

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

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

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

This method tests for !=.

impl Debug for ProcessingStatus

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

Formats the value using the given formatter.