Struct fluvio::consumer::ConsumerConfig
source · pub struct ConsumerConfig {
pub disable_continuous: bool,
pub max_bytes: i32,
pub isolation: Isolation,
pub smartmodule: Vec<SmartModuleInvocation>,
}
Expand description
Configures the behavior of consumer fetching and streaming
Fields§
§disable_continuous: bool
§max_bytes: i32
§isolation: Isolation
§smartmodule: Vec<SmartModuleInvocation>
Implementations§
source§impl ConsumerConfig
impl ConsumerConfig
pub fn builder() -> ConsumerConfigBuilder
Trait Implementations§
source§impl Clone for ConsumerConfig
impl Clone for ConsumerConfig
source§fn clone(&self) -> ConsumerConfig
fn clone(&self) -> ConsumerConfig
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 Debug for ConsumerConfig
impl Debug for ConsumerConfig
source§impl From<ConsumerConfigExt> for ConsumerConfig
impl From<ConsumerConfigExt> for ConsumerConfig
source§fn from(value: ConsumerConfigExt) -> Self
fn from(value: ConsumerConfigExt) -> Self
Converts to this type from the input type.
Auto Trait Implementations§
impl Freeze for ConsumerConfig
impl RefUnwindSafe for ConsumerConfig
impl Send for ConsumerConfig
impl Sync for ConsumerConfig
impl Unpin for ConsumerConfig
impl UnwindSafe for ConsumerConfig
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