Struct sea_streamer_file::FileConsumerOptions
source ยท pub struct FileConsumerOptions { /* private fields */ }
Implementationsยง
sourceยงimpl FileConsumerOptions
impl FileConsumerOptions
sourcepub fn set_auto_stream_reset(&mut self, v: AutoStreamReset) -> &mut Self
pub fn set_auto_stream_reset(&mut self, v: AutoStreamReset) -> &mut Self
Where to stream from the file.
If unset, defaults to Latest
.
pub fn auto_stream_reset(&self) -> &AutoStreamReset
sourcepub fn set_live_streaming(&mut self, v: bool) -> &mut Self
pub fn set_live_streaming(&mut self, v: bool) -> &mut Self
If true, follow the file like tail -f
and read new messages as there is more data.
If unset, defaults to true
.
pub fn live_streaming(&self) -> &bool
Trait Implementationsยง
sourceยงimpl Clone for FileConsumerOptions
impl Clone for FileConsumerOptions
sourceยงfn clone(&self) -> FileConsumerOptions
fn clone(&self) -> FileConsumerOptions
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 FileConsumerOptions
impl ConsumerOptions for FileConsumerOptions
sourceยงfn set_consumer_group(&mut self, group: ConsumerGroup) -> FileResult<&mut Self>
fn set_consumer_group(&mut self, group: ConsumerGroup) -> FileResult<&mut Self>
If multiple consumers share the same group, only one in the group will receive a message. This is load-balanced in a round-robin fashion.
type Error = FileErr
fn new(mode: ConsumerMode) -> Self
sourceยงfn mode(&self) -> FileResult<&ConsumerMode>
fn mode(&self) -> FileResult<&ConsumerMode>
Get currently set ConsumerMode
sourceยงfn consumer_group(&self) -> FileResult<&ConsumerGroup>
fn consumer_group(&self) -> FileResult<&ConsumerGroup>
Get currently set consumer group; may return
StreamErr::ConsumerGroupNotSet
.sourceยงimpl Debug for FileConsumerOptions
impl Debug for FileConsumerOptions
Auto Trait Implementationsยง
impl Freeze for FileConsumerOptions
impl RefUnwindSafe for FileConsumerOptions
impl Send for FileConsumerOptions
impl Sync for FileConsumerOptions
impl Unpin for FileConsumerOptions
impl UnwindSafe for FileConsumerOptions
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
sourceยงimpl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
sourceยงdefault unsafe fn clone_to_uninit(&self, dst: *mut T)
default unsafe fn clone_to_uninit(&self, dst: *mut T)
๐ฌThis is a nightly-only experimental API. (
clone_to_uninit
)