Struct BatchOptions 

pub struct BatchOptions {
    pub max_concurrent_docs: Option<usize>,
    pub max_inflight_bytes: Option<usize>,
}

Concurrency limits for batch processing.

Both limits are optional and independent. When both are set the more restrictive one governs at any given moment.

Fields

max_concurrent_docs: Option<usize>

Maximum documents in-flight simultaneously.

This field drives two independent limits that both happen to share this value:

1. ConcurrencyController::max_inflight_rows — the semaphore that rate-limits how many documents can hold permits at the same time.
2. buffer_unordered cap — how many per-document futures are created and polled ahead of readiness.

In practice they are always set together: the effective maximum is the minimum of whichever blocks first for a given workload. Defaults to 32.

max_inflight_bytes: Option<usize>

Maximum total bytes of document content in-flight simultaneously.

Useful for memory-bounded batch runs over large corpora. None means unlimited (byte accounting is still tracked for observability).

Trait Implementations

impl Default for BatchOptions

fn default() -> Self

Returns the “default value” for a type.