Struct ConsensusProtocol 

pub struct ConsensusProtocol { /* private fields */ }

共识协作协议

Implementations

impl ConsensusProtocol

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

创建新的共识协议（不使用 LLM）

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

创建支持 LLM 的共识协议

Trait Implementations

impl CollaborationProtocol for ConsensusProtocol

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, ConsensusProtocol: '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, ConsensusProtocol: '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, ConsensusProtocol: 'async_trait,

处理消息并返回结果

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

获取协议统计信息

fn version(&self) -> &str

获取协议版本

fn is_available(&self) -> bool

检查协议是否可用