Enum nakadion::handler::BatchPostAction [−][src]
pub enum BatchPostAction {
Commit(BatchStats),
DoNotCommit(BatchStats),
AbortStream(String),
ShutDown(String),
}
Expand description
Returned by a BatchHandler
and tell Nakadion
how to continue.
Variants
Commit(BatchStats)
Commit the batch
Tuple Fields of Commit
0: BatchStats
DoNotCommit(BatchStats)
Do not commit the batch and continue
Use if committed “manually” within the handler
Tuple Fields of DoNotCommit
0: BatchStats
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
Trait Implementations
Auto Trait Implementations
impl RefUnwindSafe for BatchPostAction
impl Send for BatchPostAction
impl Sync for BatchPostAction
impl Unpin for BatchPostAction
impl UnwindSafe for BatchPostAction
Blanket Implementations
Mutably borrows from an owned value. Read more
pub fn vzip(self) -> V
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more