Struct sea_streamer::SeaConsumerOptions

pub struct SeaConsumerOptions { /* private fields */ }

Available on crate feature sea-streamer-socket only.

sea-streamer-socket concrete type of ConsumerOptions.

Implementations

impl SeaConsumerOptions

pub fn into_kafka_consumer_options(self) -> KafkaConsumerOptions

pub fn into_stdio_consumer_options(self) -> StdioConsumerOptions

pub fn set_kafka_consumer_options<F>(&mut self, func: F)where F: FnOnce(&mut KafkaConsumerOptions),

Set options that only applies to Kafka

pub fn set_stdio_consumer_options<F>(&mut self, func: F)where F: FnOnce(&mut StdioConsumerOptions),

Set options that only applies to Stdio

pub fn set_auto_stream_reset(&mut self, _val: SeaStreamReset)

Trait Implementations

impl Clone for SeaConsumerOptions

fn clone(&self) -> SeaConsumerOptions

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl ConsumerOptions for SeaConsumerOptions

fn mode(&self) -> Result<&ConsumerMode, StreamErr<BackendErr>>

Get currently set ConsumerMode

fn consumer_group(&self) -> Result<&ConsumerGroup, StreamErr<BackendErr>>

Get currently set consumer group; may return StreamErr::ConsumerGroupNotSet.

fn set_consumer_group( &mut self, group_id: ConsumerGroup ) -> Result<&mut SeaConsumerOptions, StreamErr<BackendErr>>

Set consumer group for this consumer. Note the semantic is implementation-specific.

type Error = BackendErr

fn new(mode: ConsumerMode) -> SeaConsumerOptions

impl Debug for SeaConsumerOptions

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

impl Default for SeaConsumerOptions

fn default() -> SeaConsumerOptions

Returns the “default value” for a type.