Struct BatchingConfig 

pub struct BatchingConfig { /* private fields */ }

Configuration for batching AppendRecords.

Implementations

impl BatchingConfig

pub fn new() -> Self

Create a new BatchingConfig with default settings.

pub fn with_linger(self, linger: Duration) -> Self

Set the duration for how long to wait for more records before flushing a batch.

Defaults to 5ms.

pub fn with_max_batch_bytes( self, max_batch_bytes: usize, ) -> Result<Self, ValidationError>

Set the maximum metered bytes per batch.

Note: It must not exceed 1MiB.

Defaults to 1MiB.

pub fn with_max_batch_records( self, max_batch_records: usize, ) -> Result<Self, ValidationError>

Set the maximum number of records per batch.

Note: It must not exceed 1000.

Defaults to 1000.

Trait Implementations

impl Clone for BatchingConfig

fn clone(&self) -> BatchingConfig

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for BatchingConfig

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for BatchingConfig

fn default() -> Self

Returns the “default value” for a type.