Struct ThreadSafeRandAgent

pub struct ThreadSafeRandAgent { /* private fields */ }

推荐使用 ThreadSafeRandAgent，不推荐使用 RandAgent。 RandAgent 已不再维护，ThreadSafeRandAgent 支持多线程并发访问且更安全。 线程安全的 RandAgent，支持多线程并发访问

Implementations

impl ThreadSafeRandAgent

pub fn new(agents: Vec<(BoxAgent<'static>, i32, String, String)>) -> Self

创建新的线程安全 RandAgent

pub fn with_max_failures_and_callback( agents: Vec<(BoxAgent<'static>, i32, String, String)>, max_failures: u32, on_agent_invalid: OnAgentInvalidCallback, ) -> Self

使用自定义最大失败次数和回调创建线程安全 RandAgent

pub fn with_max_failures( agents: Vec<(BoxAgent<'static>, i32, String, String)>, max_failures: u32, ) -> Self

使用自定义最大失败次数创建线程安全 RandAgent

pub fn set_on_agent_invalid<F>(&mut self, callback: F)

where F: Fn(i32) + Send + Sync + 'static,

设置 agent 失效时的回调

pub async fn add_agent( &self, agent: BoxAgent<'static>, id: i32, provider: String, model: String, )

添加代理到集合中

pub async fn add_agent_with_max_failures( &self, agent: BoxAgent<'static>, id: i32, provider: String, model: String, max_failures: u32, )

使用自定义最大失败次数添加代理

pub async fn len(&self) -> usize

获取有效代理数量

pub async fn get_random_valid_agent_index(&self) -> Option<usize>

从集合中获取一个随机有效代理的索引

pub async fn get_random_valid_agent_state(&self) -> Option<ThreadSafeAgentState>

从集合中获取一个随机有效代理 注意: 并不会增加失败计数

pub async fn total_len(&self) -> usize

获取总代理数量（包括无效的）

pub async fn is_empty(&self) -> bool

检查是否有有效代理

pub async fn agents(&self) -> Vec<(String, String, u32, u32)>

获取所有代理（用于调试或检查）

pub async fn failure_stats(&self) -> Vec<(usize, u32, u32)>

获取失败统计

pub async fn reset_failures(&self)

重置所有代理的失败计数

Trait Implementations

impl Prompt for ThreadSafeRandAgent

async fn prompt( &self, prompt: impl Into<Message> + Send, ) -> Result<String, PromptError>

Send a simple prompt to the underlying completion model.