Module message

Message processing and routing for TAP Node

This module provides functionality for processing and routing TAP messages between agents.

Re-exports

pub use processor::DefaultMessageProcessor;

pub use processor::LoggingMessageProcessor;

pub use processor::MessageProcessor;

pub use processor::ValidationMessageProcessor;

pub use processor_pool::ProcessorPool;

pub use processor_pool::ProcessorPoolConfig;

pub use router::DefaultMessageRouter;

pub use sender::HttpMessageSender;

pub use sender::MessageSender;

pub use sender::NodeMessageSender;

Modules

processor

Message Processor Implementations for TAP Node

processor_pool

Processor pool for concurrent message processing.

router

Message routing implementation.

sender

Message sender implementations for TAP Node.

Structs

CompositeMessageProcessor

A message processor that applies multiple processors in sequence

CompositeMessageRouter

A composite router that tries multiple routers in sequence

Enums

MessageProcessorType

Processor enum to replace trait objects

MessageRouterType

Router enum to replace trait objects

Traits

MessageRouter

Router to determine the destination agent for a message

RouterAsyncExt

Async extension trait for the MessageRouter