[−][src]Enum nakadion::handler::BatchPostAction
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
[src]
pub fn commit_no_stats() -> Self
[src]
pub fn commit(t_deserialize: Duration) -> Self
[src]
pub fn do_not_commit_no_stats() -> Self
[src]
pub fn do_not_commit(t_deserialize: Duration) -> Self
[src]
Trait Implementations
impl Clone for BatchPostAction
[src]
fn clone(&self) -> BatchPostAction
[src]
fn clone_from(&mut self, source: &Self)
1.0.0[src]
impl Debug for BatchPostAction
[src]
impl From<JoinError> for BatchPostAction
[src]
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
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,
impl<T> Borrow<T> for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
T: ?Sized,
fn borrow_mut(&mut self) -> &mut T
[src]
impl<T> From<T> for T
[src]
impl<T, U> Into<U> for T where
U: From<T>,
[src]
U: From<T>,
impl<T> SendSyncUnwindSafe for T where
T: Send + Sync + UnwindSafe + ?Sized,
T: Send + Sync + UnwindSafe + ?Sized,
impl<T> ToOwned for T where
T: Clone,
[src]
T: Clone,
type Owned = T
The resulting type after obtaining ownership.
fn to_owned(&self) -> T
[src]
fn clone_into(&self, target: &mut T)
[src]
impl<T, U> TryFrom<U> for T where
U: Into<T>,
[src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>,
[src]
U: TryFrom<T>,
type Error = <U as TryFrom<T>>::Error
The type returned in the event of a conversion error.
fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>
[src]
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
V: MultiLane<T>,