Struct sea_streamer_socket::SeaConsumer
source · pub struct SeaConsumer { /* private fields */ }
Expand description
sea-streamer-socket
concrete type of Consumer.
Trait Implementations§
source§impl Consumer for SeaConsumer
impl Consumer for SeaConsumer
type Error = BackendErr
type Message<'a> = SeaMessage<'a>
type NextFuture<'a> = NextFuture<'a>
type Stream<'a> = SeaMessageStream<'a>
source§fn seek<'life0, 'async_trait>(
&'life0 mut self,
to: Timestamp
) -> Pin<Box<dyn Future<Output = StreamResult<(), BackendErr>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn seek<'life0, 'async_trait>( &'life0 mut self, to: Timestamp ) -> Pin<Box<dyn Future<Output = StreamResult<(), BackendErr>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,
Seek all streams to an arbitrary point in time. It will start consuming from the earliest message
with a timestamp later than
to
. Read moresource§fn rewind<'life0, 'async_trait>(
&'life0 mut self,
pos: SeqPos
) -> Pin<Box<dyn Future<Output = StreamResult<(), BackendErr>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn rewind<'life0, 'async_trait>( &'life0 mut self, pos: SeqPos ) -> Pin<Box<dyn Future<Output = StreamResult<(), BackendErr>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,
Rewind all streams to a particular sequence number. Read more
source§fn assign(&mut self, ss: (StreamKey, ShardId)) -> StreamResult<(), BackendErr>
fn assign(&mut self, ss: (StreamKey, ShardId)) -> StreamResult<(), BackendErr>
Assign this consumer to a particular shard. Can be called multiple times to assign
to multiple shards. You cannot assign streams that has not been subscribed. Read more
source§fn unassign(&mut self, ss: (StreamKey, ShardId)) -> StreamResult<(), BackendErr>
fn unassign(&mut self, ss: (StreamKey, ShardId)) -> StreamResult<(), BackendErr>
Unassign a shard. Returns
ConsumerNotAssigned
if this consumer has not been assigned to this stream or shard.source§fn next(&self) -> Self::NextFuture<'_>
fn next(&self) -> Self::NextFuture<'_>
Poll and receive one message: it awaits until there are new messages
source§impl Debug for SeaConsumer
impl Debug for SeaConsumer
source§impl From<StdioConsumer> for SeaConsumer
impl From<StdioConsumer> for SeaConsumer
source§fn from(i: StdioConsumer) -> Self
fn from(i: StdioConsumer) -> Self
Converts to this type from the input type.
Auto Trait Implementations§
impl RefUnwindSafe for SeaConsumer
impl Send for SeaConsumer
impl Sync for SeaConsumer
impl Unpin for SeaConsumer
impl UnwindSafe for SeaConsumer
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