[−][src]Enum nakadion::handler::EventsPostAction
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 the batch
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
[src]
Trait Implementations
impl Clone for EventsPostAction
[src]
fn clone(&self) -> EventsPostAction
[src]
fn clone_from(&mut self, source: &Self)
1.0.0[src]
impl Debug for EventsPostAction
[src]
impl Eq for EventsPostAction
[src]
impl PartialEq<EventsPostAction> for EventsPostAction
[src]
fn eq(&self, other: &EventsPostAction) -> bool
[src]
fn ne(&self, other: &EventsPostAction) -> bool
[src]
impl StructuralEq for EventsPostAction
[src]
impl StructuralPartialEq for EventsPostAction
[src]
Auto Trait Implementations
impl RefUnwindSafe for EventsPostAction
impl Send for EventsPostAction
impl Sync for EventsPostAction
impl Unpin for EventsPostAction
impl UnwindSafe for EventsPostAction
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<Q, K> Equivalent<K> for Q where
K: Borrow<Q> + ?Sized,
Q: Eq + ?Sized,
[src]
K: Borrow<Q> + ?Sized,
Q: Eq + ?Sized,
fn equivalent(&self, key: &K) -> bool
[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,
[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.
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>,