Enum sea_streamer::ConsumerMode
source ยท pub enum ConsumerMode {
RealTime,
Resumable,
LoadBalanced,
}
Expand description
Mode of stream consumption.
Variantsยง
RealTime
This is the โvanillaโ stream consumer. It does not auto-commit, and thus only consumes messages from now on.
Resumable
When the process restarts, it will resume the stream from the previous committed sequence.
LoadBalanced
You should assign a consumer group manually. The load-balancing mechanism is implementation-specific.
Trait Implementationsยง
sourceยงimpl Clone for ConsumerMode
impl Clone for ConsumerMode
sourceยงfn clone(&self) -> ConsumerMode
fn clone(&self) -> ConsumerMode
Returns a copy of the value. Read more
1.0.0 ยท sourceยงfn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source
. Read moresourceยงimpl Debug for ConsumerMode
impl Debug for ConsumerMode
sourceยงimpl Default for ConsumerMode
impl Default for ConsumerMode
sourceยงfn default() -> ConsumerMode
fn default() -> ConsumerMode
Returns the โdefault valueโ for a type. Read more
sourceยงimpl PartialEq<ConsumerMode> for ConsumerMode
impl PartialEq<ConsumerMode> for ConsumerMode
sourceยงfn eq(&self, other: &ConsumerMode) -> bool
fn eq(&self, other: &ConsumerMode) -> bool
This method tests for
self
and other
values to be equal, and is used
by ==
.impl Copy for ConsumerMode
impl Eq for ConsumerMode
impl StructuralEq for ConsumerMode
impl StructuralPartialEq for ConsumerMode
Auto Trait Implementationsยง
impl RefUnwindSafe for ConsumerMode
impl Send for ConsumerMode
impl Sync for ConsumerMode
impl Unpin for ConsumerMode
impl UnwindSafe for ConsumerMode
Blanket Implementationsยง
sourceยงimpl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere T: ?Sized,
sourceยงfn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more