turbomcp-grpc 3.1.2

gRPC transport for TurboMCP - high-performance MCP over HTTP/2
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81

//! `TurboMCP` gRPC Transport
//!
//! High-performance gRPC transport for the Model Context Protocol (MCP).
//! Built on [tonic](https://github.com/hyperium/tonic) for async/await support
//! and full HTTP/2 capabilities.
//!
//! # Features
//!
//! - **Server**: gRPC server implementation with streaming notifications
//! - **Client**: gRPC client with automatic reconnection
//! - **Tower Integration**: Composable middleware via Tower
//! - **TLS**: Optional TLS 1.3 support via rustls
//!
//! # Quick Start
//!
//! ## Server
//!
//! ```ignore
//! use turbomcp_grpc::server::McpGrpcServer;
//! use turbomcp_types::Tool;
//!
//! let server = McpGrpcServer::builder()
//!     .add_tool(Tool { name: "hello".into(), ..Default::default() })
//!     // .tool_handler(MyHandler) // implements ToolHandler
//!     .build();
//!
//! tonic::transport::Server::builder()
//!     .add_service(server.into_service())
//!     .serve("[::1]:50051".parse()?)
//!     .await?;
//! ```
//!
//! ## Client
//!
//! ```ignore
//! use turbomcp_grpc::client::McpGrpcClient;
//!
//! let mut client = McpGrpcClient::connect("http://[::1]:50051").await?;
//! client.initialize().await?;
//! let result = client
//!     .call_tool("hello", Some(serde_json::json!({"name": "World"})))
//!     .await?;
//! ```

#![cfg_attr(docsrs, feature(doc_cfg))]
#![warn(missing_docs)]
#![warn(clippy::all)]
#![warn(clippy::pedantic)]
#![allow(clippy::module_name_repetitions)]

/// Generated protobuf types for MCP
pub mod proto {
    #![allow(missing_docs)]
    #![allow(clippy::all)]
    #![allow(clippy::pedantic)]
    tonic::include_proto!("turbomcp.mcp.v1");
}

pub mod convert;
pub mod error;

#[cfg(feature = "server")]
#[cfg_attr(docsrs, doc(cfg(feature = "server")))]
pub mod server;

#[cfg(feature = "client")]
#[cfg_attr(docsrs, doc(cfg(feature = "client")))]
pub mod client;

pub mod layer;

// Re-exports for convenience
pub use error::{GrpcError, GrpcResult};

#[cfg(feature = "server")]
pub use server::McpGrpcServer;

#[cfg(feature = "client")]
pub use client::McpGrpcClient;

pub use layer::McpGrpcLayer;