[−][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]
pub fn clone(&self) -> BatchPostAction
[src]
pub 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,
pub fn borrow_mut(&mut self) -> &mut T
[src]
impl<T> From<T> for T
[src]
impl<T> Instrument for T
[src]
pub fn instrument(self, span: Span) -> Instrumented<Self>
[src]
pub fn in_current_span(self) -> Instrumented<Self>
[src]
impl<T> Instrument for T
[src]
pub fn instrument(self, span: Span) -> Instrumented<Self>
[src]
pub fn in_current_span(self) -> Instrumented<Self>
[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,
[src]
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.
pub fn to_owned(&self) -> T
[src]
pub 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.
pub 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.
pub 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>,