agentmesh 3.4.0

Public Preview — Rust SDK for the Agent Governance Toolkit (policy, trust, audit, identity)
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

// Copyright (c) Microsoft Corporation.
// Licensed under the MIT License.

//! Error types for the MCP module.

use thiserror::Error;

/// Errors returned by MCP governance and security primitives.
#[derive(Debug, Error)]
pub enum McpError {
    #[error("invalid configuration: {0}")]
    InvalidConfig(&'static str),

    #[error("serialization error: {0}")]
    Serialization(#[from] serde_json::Error),

    #[error("regex error: {0}")]
    Regex(#[from] regex::Error),

    #[error("invalid HMAC key")]
    InvalidHmacKey,

    #[error("invalid token format")]
    InvalidTokenFormat,

    #[error("invalid signature")]
    InvalidSignature,

    #[error("session expired")]
    SessionExpired,

    #[error("session limit exceeded for agent '{agent_id}' (limit: {limit})")]
    SessionLimitExceeded { agent_id: String, limit: usize },

    #[error("message replay detected")]
    ReplayDetected,

    #[error("rate limited; retry after {retry_after_secs} seconds")]
    RateLimited { retry_after_secs: u64 },

    #[error("human approval required for tool '{tool_name}'")]
    ApprovalRequired { tool_name: String },

    #[error("access denied: {reason}")]
    AccessDenied { reason: String },

    #[error("{store} store error: {message}")]
    Store {
        store: &'static str,
        message: String,
    },

    #[error("audit error: {0}")]
    Audit(String),

    #[error("nonce generation error: {0}")]
    NonceGeneration(String),
}

impl McpError {
    /// Create a store error with a concrete store label.
    pub fn store(store: &'static str, message: impl Into<String>) -> Self {
        Self::Store {
            store,
            message: message.into(),
        }
    }
}