agenterra-rmcp

An Agenterra fork of the official Rust Model Context Protocol SDK implementation with tokio async runtime.

Note: This is a fork of the official Rust SDK for the Model Context Protocol. We maintain this fork to provide a stable, published version on crates.io while staying in sync with upstream changes.

Attribution

This project is based on the official Model Context Protocol Rust SDK developed by Anthropic and the MCP community. The original repository can be found at: https://github.com/modelcontextprotocol/rust-sdk

All credit for the core implementation goes to the original authors. This fork exists to:

• Provide published crates on crates.io under the agenterra-rmcp namespace

• Enable easier integration for projects that need a stable, versioned dependency

• Maintain compatibility with upstream changes

This repository contains the following crates:

• agenterra-rmcp: The core crate providing the MCP protocol implementation (If you want to get more information, please visit agenterra-rmcp)
• agenterra-rmcp-macros: A procedural macro crate for generating MCP tool implementations (If you want to get more information, please visit agenterra-rmcp-macros)

Usage

Import the crate

agenterra-rmcp = { version = "0.1", features = ["server"] }
## or from git
agenterra-rmcp = { git = "https://github.com/agenterra/agenterra-rmcp", branch = "main" }

Third Dependencies

Basic dependencies:

• tokio required

• serde required

Build a Client

use agenterra_rmcp::{ServiceExt, transport::{TokioChildProcess, ConfigureCommandExt}};
use tokio::process::Command;

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let client = ().serve(TokioChildProcess::new(Command::new("npx").configure(|cmd| {
        cmd.arg("-y").arg("@modelcontextprotocol/server-everything");
    }))?).await?;
    Ok(())
}

Build a Server

use tokio::io::{stdin, stdout};
let transport = (stdin(), stdout());

let service = common::counter::Counter::new();

// this call will finish the initialization process
let server = service.serve(transport).await?;

// request
let roots = server.list_roots().await?;

// or send notification
server.notify_cancelled(...).await?;

let quit_reason = server.waiting().await?;
// or cancel it
let quit_reason = server.cancel().await?;

Examples

See examples

OAuth Support

See oauth_support for details.

Related Resources

• MCP Specification
• Schema

Related Projects

• containerd-mcp-server - A containerd-based MCP server implementation

Development

Tips for Contributors

See docs/CONTRIBUTE.MD to get some tips for contributing.

Using Dev Container

If you want to use dev container, see docs/DEVCONTAINER.md for instructions on using Dev Container for development.