Struct AimdThrottleConfig 

pub struct AimdThrottleConfig {
    pub read: AimdConfig,
    pub write: AimdConfig,
    pub delete: AimdConfig,
    pub list: AimdConfig,
    pub burst_capacity: u32,
    pub max_retries: usize,
    pub min_backoff_ms: u64,
    pub max_backoff_ms: u64,
}

Configuration for the AIMD-throttled ObjectStore wrapper.

Each operation category (read, write, delete, list) has its own AIMD config. Use with_aimd to set all categories at once, or per-category methods like with_read_aimd for fine-grained control.

Fields

read: AimdConfig

AIMD configuration for read operations (get, get_opts, get_range, get_ranges, head).

write: AimdConfig

AIMD configuration for write operations (put, put_opts, put_multipart, copy, rename, etc.).

delete: AimdConfig

AIMD configuration for delete operations.

list: AimdConfig

AIMD configuration for list operations (list_with_delimiter).

burst_capacity: u32

Maximum tokens that can accumulate for bursts (shared across all categories).

max_retries: usize

Maximum number of retries for throttle errors within the AIMD layer.

min_backoff_ms: u64

Minimum backoff in milliseconds between retry attempts.

max_backoff_ms: u64

Maximum backoff in milliseconds between retry attempts.

Implementations

impl AimdThrottleConfig

pub fn with_aimd(self, aimd: AimdConfig) -> Self

Set the AIMD configuration for all four operation categories at once.

pub fn with_read_aimd(self, aimd: AimdConfig) -> Self

Set the AIMD configuration for read operations.

pub fn with_write_aimd(self, aimd: AimdConfig) -> Self

Set the AIMD configuration for write operations.

pub fn with_delete_aimd(self, aimd: AimdConfig) -> Self

Set the AIMD configuration for delete operations.

pub fn with_list_aimd(self, aimd: AimdConfig) -> Self

Set the AIMD configuration for list operations.

pub fn is_disabled(&self) -> bool

Returns true when the AIMD throttle layer should be bypassed entirely.

pub fn with_burst_capacity(self, burst_capacity: u32) -> Self

pub fn from_storage_options( storage_options: Option<&HashMap<String, String>>, ) -> Result<Self>

Build an AimdThrottleConfig from storage options and environment variables.

Storage options take precedence over environment variables, which take precedence over defaults. A single AIMD config is applied to all four operation categories (read/write/delete/list).

Setting	Storage Option Key	Env Var	Default
Initial rate	lance_aimd_initial_rate	LANCE_AIMD_INITIAL_RATE	2000
Min rate	lance_aimd_min_rate	LANCE_AIMD_MIN_RATE	1
Max rate	lance_aimd_max_rate	LANCE_AIMD_MAX_RATE	5000
Decrease factor	lance_aimd_decrease_factor	LANCE_AIMD_DECREASE_FACTOR	0.5
Additive increment	lance_aimd_additive_increment	LANCE_AIMD_ADDITIVE_INCREMENT	300
Burst capacity	lance_aimd_burst_capacity	LANCE_AIMD_BURST_CAPACITY	100
Max retries	lance_aimd_max_retries	LANCE_AIMD_MAX_RETRIES	3
Min backoff ms	lance_aimd_min_backoff_ms	LANCE_AIMD_MIN_BACKOFF_MS	100
Max backoff ms	lance_aimd_max_backoff_ms	LANCE_AIMD_MAX_BACKOFF_MS	300

Trait Implementations

impl Clone for AimdThrottleConfig

fn clone(&self) -> AimdThrottleConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for AimdThrottleConfig

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

Formats the value using the given formatter.

impl Default for AimdThrottleConfig

fn default() -> Self

Returns the “default value” for a type.