Struct sea_streamer_stdio::StdioConsumerOptions
source ยท pub struct StdioConsumerOptions { /* private fields */ }
Trait Implementationsยง
sourceยงimpl Clone for StdioConsumerOptions
impl Clone for StdioConsumerOptions
sourceยงfn clone(&self) -> StdioConsumerOptions
fn clone(&self) -> StdioConsumerOptions
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 ConsumerOptions for StdioConsumerOptions
impl ConsumerOptions for StdioConsumerOptions
sourceยงfn set_consumer_group(&mut self, group: ConsumerGroup) -> StdioResult<&mut Self>
fn set_consumer_group(&mut self, group: ConsumerGroup) -> StdioResult<&mut Self>
If multiple consumers share the same group, only one in the group will receive a message. This is load-balanced in a round-robin fashion.
type Error = StdioErr
fn new(mode: ConsumerMode) -> Self
sourceยงfn mode(&self) -> StdioResult<&ConsumerMode>
fn mode(&self) -> StdioResult<&ConsumerMode>
Get currently set ConsumerMode
sourceยงfn consumer_group(&self) -> StdioResult<&ConsumerGroup>
fn consumer_group(&self) -> StdioResult<&ConsumerGroup>
Get currently set consumer group; may return
StreamErr::ConsumerGroupNotSet
.sourceยงimpl Debug for StdioConsumerOptions
impl Debug for StdioConsumerOptions
Auto Trait Implementationsยง
impl Freeze for StdioConsumerOptions
impl RefUnwindSafe for StdioConsumerOptions
impl Send for StdioConsumerOptions
impl Sync for StdioConsumerOptions
impl Unpin for StdioConsumerOptions
impl UnwindSafe for StdioConsumerOptions
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