Struct sea_streamer_socket::SeaConsumerOptions
source ยท pub struct SeaConsumerOptions { /* private fields */ }
Expand description
sea-streamer-socket
concrete type of ConsumerOptions.
Implementationsยง
sourceยงimpl SeaConsumerOptions
impl SeaConsumerOptions
pub fn into_stdio_consumer_options(self) -> StdioConsumerOptions
sourcepub fn set_stdio_consumer_options<F: FnOnce(&mut StdioConsumerOptions)>(
&mut self,
func: F
)
pub fn set_stdio_consumer_options<F: FnOnce(&mut StdioConsumerOptions)>( &mut self, func: F )
Set options that only applies to Stdio
pub fn set_auto_stream_reset(&mut self, _val: SeaStreamReset)
Trait Implementationsยง
sourceยงimpl Clone for SeaConsumerOptions
impl Clone for SeaConsumerOptions
sourceยงfn clone(&self) -> SeaConsumerOptions
fn clone(&self) -> SeaConsumerOptions
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 SeaConsumerOptions
impl ConsumerOptions for SeaConsumerOptions
sourceยงfn mode(&self) -> StreamResult<&ConsumerMode, BackendErr>
fn mode(&self) -> StreamResult<&ConsumerMode, BackendErr>
Get currently set ConsumerMode
sourceยงfn consumer_group(&self) -> StreamResult<&ConsumerGroup, BackendErr>
fn consumer_group(&self) -> StreamResult<&ConsumerGroup, BackendErr>
Get currently set consumer group; may return StreamErr::ConsumerGroupNotSet
.
sourceยงfn set_consumer_group(
&mut self,
group_id: ConsumerGroup
) -> StreamResult<&mut Self, BackendErr>
fn set_consumer_group( &mut self, group_id: ConsumerGroup ) -> StreamResult<&mut Self, BackendErr>
Set consumer group for this consumer. Note the semantic is implementation-specific.
type Error = BackendErr
fn new(mode: ConsumerMode) -> Self
sourceยงimpl Debug for SeaConsumerOptions
impl Debug for SeaConsumerOptions
sourceยงimpl Default for SeaConsumerOptions
impl Default for SeaConsumerOptions
sourceยงfn default() -> SeaConsumerOptions
fn default() -> SeaConsumerOptions
Returns the โdefault valueโ for a type. Read more
Auto Trait Implementationsยง
impl Freeze for SeaConsumerOptions
impl RefUnwindSafe for SeaConsumerOptions
impl Send for SeaConsumerOptions
impl Sync for SeaConsumerOptions
impl Unpin for SeaConsumerOptions
impl UnwindSafe for SeaConsumerOptions
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