Struct BatchOptions 

pub struct BatchOptions {
    pub max_lines: NonZero<usize>,
    pub target_bytes: NonZero<usize>,
    pub max_delay: Duration,
}

Available on crate feature std only.

Transport batching policy, independent of subprocess options and listing limits.

Defaults are 256 lines, a 256 KiB byte target, and 10 ms from adding the first complete line to a new batch. The first threshold reached flushes the batch. Counts are nonzero by construction. One oversized line is emitted alone; lines are never split.

Fields

max_lines: NonZero<usize>

Maximum lines per batch, not a total result limit.

target_bytes: NonZero<usize>

Typical maximum serialized batch size. A larger single line is allowed.

max_delay: Duration

Maximum time spent collecting more lines after starting a batch, while the stream is being polled. Downstream backpressure still applies. Zero emits each line immediately. No empty timer batches are emitted.

Implementations

impl BatchOptions

pub fn new( max_lines: usize, target_bytes: usize, max_delay: Duration, ) -> Result<BatchOptions, TryFromIntError>

Creates a policy, rejecting zero line/byte thresholds.

use asimov_flow::BatchOptions;
use std::time::Duration;
let options = BatchOptions::new(128, 64 * 1024, Duration::from_millis(5))?;
assert_eq!(options.max_lines.get(), 128);

Trait Implementations

impl Clone for BatchOptions

fn clone(&self) -> BatchOptions

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for BatchOptions

impl Debug for BatchOptions

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

Formats the value using the given formatter.

impl Default for BatchOptions

fn default() -> BatchOptions

Returns the “default value” for a type.

impl Eq for BatchOptions

impl PartialEq for BatchOptions

fn eq(&self, other: &BatchOptions) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for BatchOptions