pub struct LoaderConfig {
pub channel_capacity: usize,
pub batch_size: usize,
pub continue_on_sink_error: bool,
}Expand description
Configuration for the data loader.
Fields§
§channel_capacity: usizeSize of the bounded channel between source and fan-out task. Default: 4096.
batch_size: usizeMaximum events per batch (for future batching logic). Default: 256.
continue_on_sink_error: boolIf true, the loader continues even if a sink rejects events.
Default: false.
Trait Implementations§
Source§impl Clone for LoaderConfig
impl Clone for LoaderConfig
Source§fn clone(&self) -> LoaderConfig
fn clone(&self) -> LoaderConfig
Returns a duplicate of the value. Read more
1.0.0 (const: unstable) · 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 LoaderConfig
impl Debug for LoaderConfig
Auto Trait Implementations§
impl Freeze for LoaderConfig
impl RefUnwindSafe for LoaderConfig
impl Send for LoaderConfig
impl Sync for LoaderConfig
impl Unpin for LoaderConfig
impl UnsafeUnpin for LoaderConfig
impl UnwindSafe for LoaderConfig
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