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

ShutDown(String)

Abort the consumption and shut down

Implementations

impl EventsPostAction

pub fn commit() -> Self

Trait Implementations

impl Clone for EventsPostAction

pub fn clone(&self) -> EventsPostAction

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for EventsPostAction

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

Formats the value using the given formatter.

impl Eq for EventsPostAction

impl PartialEq<EventsPostAction> for EventsPostAction

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

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

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

This method tests for !=.

impl StructuralEq for EventsPostAction

impl StructuralPartialEq for EventsPostAction