Struct ModuleCommunicationManager 

pub struct ModuleCommunicationManager { /* private fields */ }

模块间通信管理器

Implementations

impl ModuleCommunicationManager

pub fn new() -> Self

创建新的模块通信管理器

pub fn register_module( &self, module_id: String, name: String, version: String, ) -> Receiver<Message>

注册模块

pub async fn send_message(&self, message: Message)

发送消息

pub async fn broadcast_event( &self, event_type: EventType, data: Value, sender: String, )

广播事件

pub fn register_event_listener(&self, event_type: EventType, module_id: String)

注册事件监听器

pub fn remove_event_listener(&self, event_type: EventType, module_id: &String)

移除事件监听器

pub fn update_module_status(&self, module_id: &String, status: ModuleStatus)

更新模块状态

pub fn get_module_status(&self, module_id: &String) -> Option<ModuleStatus>

获取模块状态

pub fn list_modules(&self) -> Vec<(String, ModuleInfo)>

列出所有模块

pub async fn acknowledge_message(&self, message_id: &String)

确认消息

pub async fn send_message_with_ack( &self, message: Message, ) -> Result<Message, String>

发送消息并等待确认

pub async fn start_heartbeat(&self)

启动心跳检测

pub async fn send_ping(&self, module_id: &String)

发送心跳消息

pub async fn handle_pong(&self, module_id: &String)

处理心跳响应

pub fn get_message_status(&self, message_id: &String) -> Option<MessageStatus>

获取消息状态

pub fn cleanup_expired_messages(&self)

清理过期消息

pub async fn send_message_batch(&self, batch: MessageBatch)

发送消息批次

pub fn queue_message(&self, message: Message)

将消息加入批处理队列

pub async fn process_message_batches(&self)

处理消息批次

pub async fn start_batch_processor(&self)

启动批处理器

pub fn cache_message(&self, key: String, value: Value)

缓存消息

pub fn get_cached_message(&self, key: &str) -> Option<Value>

获取缓存的消息

pub fn clear_cache(&self)

清除缓存

pub fn set_batch_size_threshold(&mut self, threshold: usize)

设置批处理大小阈值

pub fn set_batch_interval(&mut self, interval: u64)

设置批处理间隔

pub fn set_cache_size_limit(&mut self, limit: usize)

设置缓存大小限制

Trait Implementations

impl Clone for ModuleCommunicationManager

fn clone(&self) -> ModuleCommunicationManager

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Send for ModuleCommunicationManager

impl Sync for ModuleCommunicationManager