Struct fluvio::consumer::ConsumerConfigExt
source · pub struct ConsumerConfigExt {
pub topic: String,
pub partition: Vec<PartitionId>,
pub mirror: Option<String>,
pub offset_consumer: Option<String>,
pub offset_start: Offset,
pub offset_strategy: OffsetManagementStrategy,
pub offset_flush: Duration,
pub max_bytes: i32,
pub isolation: Isolation,
pub smartmodule: Vec<SmartModuleInvocation>,
/* private fields */
}
Fields§
§topic: String
§partition: Vec<PartitionId>
§mirror: Option<String>
§offset_consumer: Option<String>
§offset_start: Offset
§offset_strategy: OffsetManagementStrategy
§offset_flush: Duration
§max_bytes: i32
§isolation: Isolation
§smartmodule: Vec<SmartModuleInvocation>
Implementations§
source§impl ConsumerConfigExt
impl ConsumerConfigExt
pub fn builder() -> ConsumerConfigExtBuilder
pub fn into_parts( self, ) -> (Offset, ConsumerConfig, Option<String>, OffsetManagementStrategy, Duration)
Trait Implementations§
source§impl Clone for ConsumerConfigExt
impl Clone for ConsumerConfigExt
source§fn clone(&self) -> ConsumerConfigExt
fn clone(&self) -> ConsumerConfigExt
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 ConsumerConfigExt
impl Debug for ConsumerConfigExt
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 ConsumerConfigExt
impl RefUnwindSafe for ConsumerConfigExt
impl Send for ConsumerConfigExt
impl Sync for ConsumerConfigExt
impl Unpin for ConsumerConfigExt
impl UnwindSafe for ConsumerConfigExt
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