Struct ModuleCommunicationHub 

pub struct ModuleCommunicationHub { /* private fields */ }

Communication hub for managing inter-module messages

Implementations

impl ModuleCommunicationHub

pub fn new() -> Self

Create a new communication hub

pub fn send_message(&mut self, message: InterModuleMessage) -> CoreResult<()>

Send a message from one module to another

pub fn receive_messages(&mut self, module_name: &str) -> Vec<InterModuleMessage>

Receive messages for a specific module

pub fn get_pending_count(&self, module_name: &str) -> usize

Get pending message count for a module

pub fn optimize_routing(&mut self) -> CoreResult<()>

Optimize routing paths between modules

pub fn enable_compression(&mut self) -> CoreResult<()>

Enable message compression for large payloads

pub fn add_route(&mut self, source: String, destination: String)

Add a routing entry

pub fn remove_route(&mut self, source: &str, destination: &str)

Remove a routing entry

pub fn get_routes(&self, source: &str) -> Vec<String>

Get routing destinations for a source module

pub fn broadcast_message( &mut self, message: InterModuleMessage, ) -> CoreResult<()>

Broadcast a message to all connected modules

pub fn get_statistics(&self) -> &CommunicationStatistics

Get communication statistics

pub fn reset_statistics(&mut self)

Reset communication statistics

pub fn update_latency(&mut self, latency: Duration)

Update message latency statistics

pub fn update_error_rate(&mut self, error_occurred: bool)

Update error rate statistics

pub fn clear_queues(&mut self)

Clear all message queues

pub fn clear_module_queue(&mut self, module_name: &str)

Clear queue for a specific module

pub fn get_memory_usage(&self) -> usize

Get total memory usage of all queues

pub fn cleanup_expired_messages(&mut self, max_age: Duration)

Cleanup expired messages (messages older than specified duration)

pub fn get_health_status(&self) -> CommunicationHealth

Get health status of the communication hub

pub fn create_optimized_pipeline( &self, input: &AdvancedInput, config: &CrossModuleOptimizationConfig, ) -> CoreResult<OptimizedPipeline>

Create an optimized processing pipeline

Trait Implementations

impl Debug for ModuleCommunicationHub

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

Formats the value using the given formatter.

impl Default for ModuleCommunicationHub

fn default() -> Self

Returns the “default value” for a type.