Struct Concurrency 

pub struct Concurrency {
    pub global: usize,
    pub per_provider: BTreeMap<String, usize>,
    pub default_per_provider: usize,
    pub adaptive: bool,
    pub max_retries: u32,
    pub base_backoff: Duration,
}

Concurrency policy for a matrix run.

Fields

global: usize

Max total cases in flight across all providers.

per_provider: BTreeMap<String, usize>

Explicit per-provider ceilings (provider id → max in flight).

default_per_provider: usize

Ceiling for providers without an explicit entry.

adaptive: bool

Whether to shrink/grow per-provider limits in response to rate limits.

max_retries: u32

Max times a rate-limited case is re-queued before it is recorded failed.

base_backoff: Duration

Base backoff applied after a rate limit (doubled per consecutive hit).

Implementations

impl Concurrency

pub fn new(global: usize) -> Self

A policy with a global cap and, by default, the same ceiling per provider (so adaptive backoff — not a static per-provider cap — does the throttling until the caller sets explicit per-provider limits).

pub fn provider(self, provider: impl Into<String>, limit: usize) -> Self

Set the ceiling for one provider.

Trait Implementations

impl Clone for Concurrency

fn clone(&self) -> Concurrency

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Concurrency

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

Formats the value using the given formatter.

impl Default for Concurrency

fn default() -> Self

Returns the “default value” for a type.