Enum nakadion::handler::EventsPostAction

pub enum EventsPostAction {
    Commit,
    DoNotCommit,
    AbortStream(String),
    ShutDown(String),
}

This is basically the same as a ProcessingStatus but returned from a EventsHandler.

It is not necessary to report the number of processed events since the EventsHandler itself keeps track of them.

Variants

Commit

Commit the batch

DoNotCommit

Do not commit the batch and continue

Use if committed “manually” within the handler

AbortStream(String)

Abort the current stream and reconnect

Tuple Fields of AbortStream

0: String

ShutDown(String)

Abort the consumption and shut down

Tuple Fields of ShutDown

0: String

Implementations

impl EventsPostAction

pub fn commit() -> Self

Trait Implementations

impl Clone for EventsPostAction

fn clone(&self) -> EventsPostAction

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for EventsPostAction

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

Formats the value using the given formatter.

impl PartialEq<EventsPostAction> for EventsPostAction

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

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

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

This method tests for !=.

impl Eq for EventsPostAction

impl StructuralEq for EventsPostAction

impl StructuralPartialEq for EventsPostAction