Struct BatchConfig 

pub struct BatchConfig {
    pub batch_max_size: usize,
    pub inactive_timeout: Duration,
    pub buffer_duration: Duration,
    pub max_retry_count: u32,
    pub retry_delay: Duration,
    pub max_pending_entries: usize,
}

Tuning knobs for a BatchSink, matching the field names (and defaults) of APISIX’s batch-processor schema plus featherbit’s channel capacity.

Fields

batch_max_size: usize

Maximum entries per batch; reaching it triggers an immediate flush. A value of 1 flushes every entry as it arrives, with no timers. Default 1000.

inactive_timeout: Duration

Flush the buffer when no new entry has arrived for this long. Default 5 seconds.

buffer_duration: Duration

Flush the buffer when the oldest buffered entry is this old, even if entries keep trickling in fast enough to reset inactive_timeout. Default 60 seconds.

max_retry_count: u32

How many times a batch is retried after its first failed flush before being dropped. Default 0 (no retries).

retry_delay: Duration

Delay between retry attempts. Default 1 second.

max_pending_entries: usize

Capacity of the channel between BatchSink::push and the background task. When full, pushed entries are dropped with a warning. Default 10_000.

Implementations

impl BatchConfig

pub fn from_config(config: &HashMap<String, Value>) -> Result<Self, String>

Parses the APISIX-shaped keys (batch_max_size, inactive_timeout, buffer_duration, max_retry_count, retry_delay — seconds as integers — and max_pending_entries) from a plugin config map, using the defaults for absent keys.

Returns an error naming the offending key when a present value is not a non-negative integer.

Trait Implementations

impl Clone for BatchConfig

fn clone(&self) -> BatchConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for BatchConfig

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

Formats the value using the given formatter.

impl Default for BatchConfig

fn default() -> Self

Returns the “default value” for a type.