Struct fluvio::consumer::ConsumerConfig [−][src]
pub struct ConsumerConfig { /* fields omitted */ }
Configures the behavior of consumer fetching and streaming
Implementations
impl ConsumerConfig
[src]
impl ConsumerConfig
[src]pub fn with_max_bytes(self, max_bytes: i32) -> Self
[src]
Maximum number of bytes to be fetched at a time.
pub fn with_wasm_filter(self, bytes: Vec<u8>) -> Self
[src]
set wasm filter
Trait Implementations
impl Default for ConsumerConfig
[src]
impl Default for ConsumerConfig
[src]Auto Trait Implementations
impl RefUnwindSafe for ConsumerConfig
impl RefUnwindSafe for ConsumerConfig
impl Send for ConsumerConfig
impl Send for ConsumerConfig
impl Sync for ConsumerConfig
impl Sync for ConsumerConfig
impl Unpin for ConsumerConfig
impl Unpin for ConsumerConfig
impl UnwindSafe for ConsumerConfig
impl UnwindSafe for ConsumerConfig
Blanket Implementations
impl<T> Instrument for T
[src]
impl<T> Instrument for T
[src]