Struct AdaptiveController 

pub struct AdaptiveController {
    pub quote: Limiter,
    pub store: Limiter,
    pub fetch: Limiter,
    /* private fields */
}

Bundle of per-channel limiters owned by the Client.

Fields

quote: Limiter

store: Limiter

fetch: Limiter

Implementations

impl AdaptiveController

pub fn new(start: ChannelStart, config: AdaptiveConfig) -> Self

Create a controller with cold-start values per channel. Sanitizes the config (NaN guards, floor/ceiling enforcement) before constructing limiters. The supplied start is captured as the per-instance cold-start floor for warm_start.

pub fn snapshot(&self) -> ChannelStart

Snapshot current per-channel caps for persistence.

pub fn config(&self) -> &AdaptiveConfig

Read-only access to the controller’s adaptive config. Made read-only deliberately: each Limiter snapshots its own Arc<LimiterConfig> at construction, so post-hoc mutation would silently desync warm_start‘s enabled check from the limiters’ frozen copies.

pub fn warm_start(&self, snapshot: ChannelStart)

Apply a previously-saved snapshot as the warm-start cap.

The effective warm value per channel is max(snapshot, self.cold_start) — flooring at the per-instance cold-start (NOT the global default) so:

1. A prior bad run that pinned cap=1 doesn’t pessimize this run forever.
2. A controller built with custom (e.g. low) cold starts for benchmarking is not silently jumped above its construction parameters.

Does not clear sliding windows. When enabled = false, this is a no-op — fixed-concurrency mode means fixed-concurrency.

Trait Implementations

impl Clone for AdaptiveController

fn clone(&self) -> AdaptiveController

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for AdaptiveController

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

Formats the value using the given formatter.

impl Default for AdaptiveController

fn default() -> Self

Returns the “default value” for a type.