Struct DcpServer 

pub struct DcpServer {
    pub context: Arc<DcpContext>,
    pub config: ServerConfig,
    pub metrics: Arc<Metrics>,
    /* private fields */
}

DCP Server

Fields

context: Arc<DcpContext>

Shared context

config: ServerConfig

Server configuration

metrics: Arc<Metrics>

Performance metrics

Implementations

impl DcpServer

pub fn new( router: BinaryTrieRouter, context: DcpContext, config: ServerConfig, ) -> Self

Create a new DCP server

pub fn security_audit(&self) -> SecurityAuditLog

Get structured security audit receipts.

pub fn create_session(&self) -> Result<Arc<Session>, DCPError>

Create a new session

pub fn get_session(&self, id: u64) -> Option<Arc<Session>>

Get a session by ID

pub fn remove_session(&self, id: u64) -> Option<Arc<Session>>

Remove a session

pub fn session_count(&self) -> usize

Get active session count

pub fn invoke( &self, tool_id: u16, args: &SharedArgs<'_>, ) -> Result<ToolResult, DCPError>

Invoke a tool by ID.

Raw invocation is deny-by-default. Use invoke_authorized with the negotiated capability manifest for execution.

pub fn invoke_authorized( &self, capabilities: &CapabilityManifest, tool_id: u16, args: &SharedArgs<'_>, ) -> Result<ToolResult, SecurityError>

Invoke a tool only when the negotiated capabilities allow it.

pub fn invoke_signed_authorized( &self, capabilities: &CapabilityManifest, invocation: &SignedInvocation, public_key: &[u8; 32], nonce_store: &mut NonceStore, args: &SharedArgs<'_>, ) -> Result<ToolResult, SecurityError>

Invoke a signed tool call only when signature, args hash, negotiated capabilities, schema validation, and replay protection all pass.

pub fn invoke_by_name( &self, name: &str, args: &SharedArgs<'_>, ) -> Result<ToolResult, DCPError>

Invoke a tool by name (for MCP compatibility).

Raw name-based invocation is deny-by-default. Use invoke_by_name_authorized after capability negotiation.

pub fn invoke_by_name_authorized( &self, capabilities: &CapabilityManifest, name: &str, args: &SharedArgs<'_>, ) -> Result<ToolResult, SecurityError>

Invoke a named tool only when negotiated capabilities allow it.

pub fn upgrade_session(&self, session_id: u64) -> Result<(), DCPError>

Upgrade a session from MCP to DCP

pub fn cleanup_expired_sessions(&self) -> usize

Clean up expired sessions

pub fn server_info(&self) -> ServerInfo

Get server info