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
.