Enum nakadion::ProcessingStatus [−][src]
This struct must be returned after processing a batch to tell nakadion how to continue.
Variants
Processed(Option<usize>)
The cursor of the just processed batch can be committed to make progrss on the stream.
Optionally the number of processed events can be provided to help with deciding on when to commit the cursor.
The number of events should be the number of events that were in the batch.
Failed
Processing failed. Do not commit the cursor. This always ends in the streaming being aborted for the current stream.
A reason must be given which will be logged.
Fields of Failed
reason: String |
Methods
impl ProcessingStatus
[src]
impl ProcessingStatus
pub fn processed_no_hint() -> ProcessingStatus
[src]
pub fn processed_no_hint() -> ProcessingStatus
Cursor can be committed and no information on how many events were processed is given.
pub fn processed(num_events_hint: usize) -> ProcessingStatus
[src]
pub fn processed(num_events_hint: usize) -> ProcessingStatus
Cursor can be committed and a hint on how many events were processed is given.
pub fn failed<T: Into<String>>(reason: T) -> ProcessingStatus
[src]
pub fn failed<T: Into<String>>(reason: T) -> ProcessingStatus
Processing events failed with the given reason.
Trait Implementations
impl Debug for ProcessingStatus
[src]
impl Debug for ProcessingStatus
fn fmt(&self, f: &mut Formatter) -> Result
[src]
fn fmt(&self, f: &mut Formatter) -> Result
Formats the value using the given formatter. Read more
impl Clone for ProcessingStatus
[src]
impl Clone for ProcessingStatus
fn clone(&self) -> ProcessingStatus
[src]
fn clone(&self) -> ProcessingStatus
Returns a copy of the value. Read more
fn clone_from(&mut self, source: &Self)
1.0.0[src]
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from source
. Read more
impl PartialEq for ProcessingStatus
[src]
impl PartialEq for ProcessingStatus
fn eq(&self, other: &ProcessingStatus) -> bool
[src]
fn eq(&self, other: &ProcessingStatus) -> bool
This method tests for self
and other
values to be equal, and is used by ==
. Read more
fn ne(&self, other: &ProcessingStatus) -> bool
[src]
fn ne(&self, other: &ProcessingStatus) -> bool
This method tests for !=
.
impl Eq for ProcessingStatus
[src]
impl Eq for ProcessingStatus
Auto Trait Implementations
impl Send for ProcessingStatus
impl Send for ProcessingStatus
impl Sync for ProcessingStatus
impl Sync for ProcessingStatus