Skip to main content

Module adaptive

Module adaptive 

Source
Expand description

Adaptive batch sizing — an AIMD controller that auto-tunes the effective write batch size per pipeline row from observed sink latency + error rate. Pure logic (no I/O); run_stream feeds it observations and emits metrics. See docs/superpowers/specs/2026-05-31-adaptive-batch-sizing-design.md.

Structs§

AdaptiveBatchConfig
Configuration for the adaptive batch-size controller. Lives under execution.adaptive_batch_size. Default enabled = false (opt-in); when disabled the pipeline writes each page exactly as before.
Adjustment
A size change the controller decided on.
AimdController
Additive-increase / multiplicative-decrease controller. Pure + deterministic.
Observation
One observed sub-batch write outcome fed to the controller.

Enums§

AdjustDirection
Direction of a batch-size adjustment (metric label).
AdjustReason
Why an adjustment happened (metric label).