Trait sea_streamer_types::ConsumerOptions

pub trait ConsumerOptions: Default + Clone + Send {
    type Error: Error;

    // Required methods
    fn new(mode: ConsumerMode) -> Self;
    fn mode(&self) -> StreamResult<&ConsumerMode, Self::Error>;
    fn consumer_group(&self) -> StreamResult<&ConsumerGroup, Self::Error>;
    fn set_consumer_group(
        &mut self,
        group_id: ConsumerGroup
    ) -> StreamResult<&mut Self, Self::Error>;
}

Common options of a Consumer.

Required Associated Types

type Error: Error

Required Methods

fn new(mode: ConsumerMode) -> Self

fn mode(&self) -> StreamResult<&ConsumerMode, Self::Error>

Get currently set ConsumerMode

fn consumer_group(&self) -> StreamResult<&ConsumerGroup, Self::Error>

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

fn set_consumer_group( &mut self, group_id: ConsumerGroup ) -> StreamResult<&mut Self, Self::Error>

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

Object Safety

This trait is not object safe.

Implementors