Struct sea_streamer::SeaConsumer

pub struct SeaConsumer { /* private fields */ }

Available on crate feature sea-streamer-socket only.

sea-streamer-socket concrete type of Consumer.

Trait Implementations

impl Consumer for SeaConsumer

type Error = BackendErr

type Message<'a> = SeaMessage<'a>

type NextFuture<'a> = NextFuture<'a>

type Stream<'a> = SeaMessageStream<'a>

async fn seek( &mut self, to: OffsetDateTime ) -> Result<(), StreamErr<BackendErr>>

Seek all streams to an arbitrary point in time. It will start consuming from the earliest message with a timestamp later than to.

async fn rewind(&mut self, pos: SeqPos) -> Result<(), StreamErr<BackendErr>>

Rewind all streams to a particular sequence number.

fn assign( &mut self, ss: (StreamKey, ShardId) ) -> Result<(), StreamErr<BackendErr>>

Assign this consumer to a particular shard. Can be called multiple times to assign to multiple shards. Returns error StreamKeyNotFound if the stream is not currently subscribed.

fn unassign( &mut self, ss: (StreamKey, ShardId) ) -> Result<(), StreamErr<BackendErr>>

Unassign a shard. Returns error StreamKeyNotFound if the stream is not currently subscribed. Returns error StreamKeyEmpty if all streams have been unassigned.

fn next(&self) -> <SeaConsumer as Consumer>::NextFuture<'_>

Poll and receive one message: it awaits until there are new messages. This method can be called from multiple threads.

fn stream<'a, 'b>(&'b mut self) -> <SeaConsumer as Consumer>::Stream<'a>

where 'b: 'a,

Returns an async stream. You cannot create multiple streams from the same consumer, nor perform any operation while streaming.

impl Debug for SeaConsumer

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

Formats the value using the given formatter.

impl From<KafkaConsumer> for SeaConsumer

fn from(i: KafkaConsumer) -> SeaConsumer

Converts to this type from the input type.

impl From<StdioConsumer> for SeaConsumer

fn from(i: StdioConsumer) -> SeaConsumer

Converts to this type from the input type.

impl SeaStreamerBackend for SeaConsumer

type Kafka = KafkaConsumer

type Stdio = StdioConsumer

fn backend(&self) -> Backend

Identifies the underlying backend

fn get_kafka( &mut self ) -> Option<&mut <SeaConsumer as SeaStreamerBackend>::Kafka>

Get the concrete type for the Kafka backend. None if it’s another Backend

fn get_stdio( &mut self ) -> Option<&mut <SeaConsumer as SeaStreamerBackend>::Stdio>

Get the concrete type for the Stdio backend. None if it’s another Backend