Enum nakadion::CommitStrategy
[−]
[src]
pub enum CommitStrategy { AllBatches, Latest, AfterSeconds { seconds: u16, }, Batches { after_batches: u32, after_seconds: Option<u16>, }, Events { after_events: u32, after_seconds: Option<u16>, }, }
Strategy for committing cursors
Variants
AllBatches
Commit all cursors immediately
Latest
Commit as late as possile
AfterSeconds
Commit latest after seconds
seconds
Fields of AfterSeconds
seconds: u16 |
Batches
Commit latest after after_batches
batches have been
received or after after_seconds
seconds have
elapsed
Fields of Batches
after_batches: u32 | |
after_seconds: Option<u16> |
Events
Commit latest after after_events
events have been
received or after after_seconds
seconds have
elapsed
This requires the BatchHandler
to return the number
of processed events to work properly.
Fields of Events
after_events: u32 | |
after_seconds: Option<u16> |
Trait Implementations
impl Debug for CommitStrategy
[src]
fn fmt(&self, __arg_0: &mut Formatter) -> Result
[src]
Formats the value using the given formatter. Read more
impl Clone for CommitStrategy
[src]
fn clone(&self) -> CommitStrategy
[src]
Returns a copy of the value. Read more
fn clone_from(&mut self, source: &Self)
1.0.0[src]
Performs copy-assignment from source
. Read more