Enum nakadion::handler::BatchPostAction

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

Returned by a BatchHandler and tell Nakadion how to continue.

Variants

Commit(BatchStats)

Commit the batch

DoNotCommit(BatchStats)

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 BatchPostAction

pub fn commit_no_stats() -> Self

pub fn commit(t_deserialize: Duration) -> Self

pub fn do_not_commit_no_stats() -> Self

pub fn do_not_commit(t_deserialize: Duration) -> Self

Trait Implementations

impl Clone for BatchPostAction

fn clone(&self) -> BatchPostAction

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for BatchPostAction

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

Formats the value using the given formatter.

impl From<JoinError> for BatchPostAction

fn from(v: JoinError) -> Self

Performs the conversion.