Struct LoggingMiddleware 

pub struct LoggingMiddleware { /* private fields */ }

Logging middleware that logs all messages.

Examples

use pmcp::shared::{LoggingMiddleware, Middleware};
use pmcp::types::{JSONRPCRequest, RequestId};
use tracing::Level;

// Create logging middleware with different levels
let debug_logger = LoggingMiddleware::new(Level::DEBUG);
let info_logger = LoggingMiddleware::new(Level::INFO);
let default_logger = LoggingMiddleware::default(); // Uses DEBUG level

let mut request = JSONRPCRequest {
    jsonrpc: "2.0".to_string(),
    method: "tools.list".to_string(),
    params: Some(serde_json::json!({"category": "development"})),
    id: RequestId::from(456i64),
};

// Log at different levels
debug_logger.on_request(&mut request).await?;
info_logger.on_request(&mut request).await?;
default_logger.on_request(&mut request).await?;

Implementations

impl LoggingMiddleware

pub fn new(level: Level) -> Self

Create a new logging middleware with the specified level.

Trait Implementations

impl Debug for LoggingMiddleware

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

Formats the value using the given formatter.

impl Default for LoggingMiddleware

fn default() -> Self

Returns the “default value” for a type.

impl Middleware for LoggingMiddleware

fn on_request<'life0, 'life1, 'async_trait>( &'life0 self, request: &'life1 mut JSONRPCRequest, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Called before a request is sent.

fn on_response<'life0, 'life1, 'async_trait>( &'life0 self, response: &'life1 mut JSONRPCResponse, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Called after a response is received.

fn on_send<'life0, 'life1, 'async_trait>( &'life0 self, message: &'life1 TransportMessage, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Called when a message is sent (any type).

fn on_receive<'life0, 'life1, 'async_trait>( &'life0 self, message: &'life1 TransportMessage, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Called when a message is received (any type).