Struct AgentWeights 

pub struct AgentWeights {
    pub states: HashMap<String, RateLimitState>,
    pub base_weights: HashMap<String, f64>,
}

Tracks per-agent weights for weighted round-robin routing.

Fields

states: HashMap<String, RateLimitState>

base_weights: HashMap<String, f64>

Configured base weights per agent (from config.yml). Used as the recovery ceiling instead of DEFAULT_WEIGHT.

Implementations

impl AgentWeights

pub fn ensure_agents(&mut self, agents: &[String])

Ensure all available agents have an entry, using configured base weights.

pub fn ensure_agents_with_weights( &mut self, agents: &[String], configured_weights: &HashMap<String, f64>, )

Ensure all available agents have an entry, applying configured base weights.

Agents with an explicit weight in config.yml use that as their base. Agents without a configured weight default to the minimum of the explicitly configured weights (see default_missing_weight), so an omission never outranks an agent the operator actually configured.

pub fn record_rate_limit(&mut self, agent: &str)

Record a rate limit event for an agent.

pub fn record_success(&mut self, agent: &str)

Record a successful task completion for an agent.

pub fn tick_recovery(&mut self)

Tick recovery for all agents.

pub fn weighted_select( &self, agents: &[String], task_id: &str, ) -> Option<String>

Select an agent by weighted probability from the given list.

Uses a simple weighted random selection: each agent’s probability is proportional to its weight. If all weights are zero (shouldn’t happen due to MIN_WEIGHT), falls back to uniform selection.

pub fn get_weight(&self, agent: &str) -> f64

Get the current weight for an agent.

pub fn snapshot(&self) -> Vec<(String, f64, u32)>

Get a snapshot of all agent weights (for logging/debugging).

Trait Implementations

impl Clone for AgentWeights

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for AgentWeights

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

Formats the value using the given formatter.

impl Default for AgentWeights

fn default() -> Self

Returns the “default value” for a type.