Struct ParallelProtocol 

pub struct ParallelProtocol { /* private fields */ }

并行协作协议

Implementations

impl ParallelProtocol

pub fn new(agent_id: impl Into<String>) -> ParallelProtocol

创建新的并行协议（不使用 LLM）

pub fn with_llm( agent_id: impl Into<String>, llm_client: Arc<LLMClient>, ) -> ParallelProtocol

创建支持 LLM 的并行协议

Trait Implementations

impl CollaborationProtocol for ParallelProtocol

fn name(&self) -> &str

获取协议名称

fn description(&self) -> &str

协议描述（供 LLM 理解）

fn applicable_scenarios(&self) -> Vec<String>

协议适用场景（供 LLM 参考选择）

fn mode(&self) -> CollaborationMode

获取协作模式

fn send_message<'life0, 'async_trait>( &'life0 self, msg: CollaborationMessage, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, ParallelProtocol: 'async_trait,

发送消息

fn receive_message<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Option<CollaborationMessage>, Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, ParallelProtocol: 'async_trait,

接收消息

fn process_message<'life0, 'async_trait>( &'life0 self, msg: CollaborationMessage, ) -> Pin<Box<dyn Future<Output = Result<CollaborationResult, Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, ParallelProtocol: 'async_trait,

处理消息并返回结果

fn stats(&self) -> HashMap<String, Value>

获取协议统计信息

fn version(&self) -> &str

获取协议版本

fn is_available(&self) -> bool

检查协议是否可用