Struct fluvio::consumer::ConsumerConfigExtBuilder
source · pub struct ConsumerConfigExtBuilder { /* private fields */ }
Expand description
Builder for ConsumerConfigExt
.
Implementations§
source§impl ConsumerConfigExtBuilder
impl ConsumerConfigExtBuilder
pub fn topic<VALUE: Into<String>>(&mut self, value: VALUE) -> &mut Self
pub fn offset_consumer<VALUE: Into<String>>( &mut self, value: VALUE ) -> &mut Self
pub fn offset_start(&mut self, value: Offset) -> &mut Self
pub fn offset_strategy(&mut self, value: OffsetManagementStrategy) -> &mut Self
pub fn offset_flush(&mut self, value: Duration) -> &mut Self
pub fn disable_continuous(&mut self, value: bool) -> &mut Self
pub fn max_bytes(&mut self, value: i32) -> &mut Self
pub fn isolation(&mut self, value: Isolation) -> &mut Self
pub fn smartmodule(&mut self, value: Vec<SmartModuleInvocation>) -> &mut Self
sourcepub fn build(&self) -> Result<ConsumerConfigExt, ConsumerConfigExtBuilderError>
pub fn build(&self) -> Result<ConsumerConfigExt, ConsumerConfigExtBuilderError>
source§impl ConsumerConfigExtBuilder
impl ConsumerConfigExtBuilder
pub fn partition(&mut self, value: PartitionId) -> &mut Self
Trait Implementations§
source§impl Clone for ConsumerConfigExtBuilder
impl Clone for ConsumerConfigExtBuilder
source§fn clone(&self) -> ConsumerConfigExtBuilder
fn clone(&self) -> ConsumerConfigExtBuilder
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 moreAuto Trait Implementations§
impl Freeze for ConsumerConfigExtBuilder
impl RefUnwindSafe for ConsumerConfigExtBuilder
impl Send for ConsumerConfigExtBuilder
impl Sync for ConsumerConfigExtBuilder
impl Unpin for ConsumerConfigExtBuilder
impl UnwindSafe for ConsumerConfigExtBuilder
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