Struct PolicyEnabledServer 

pub struct PolicyEnabledServer<H: ServerHandler> { /* private fields */ }

Available on crate features server and policy only.

A server handler wrapper that enforces policies transparently

This wrapper can be applied to any existing ServerHandler implementation to add policy enforcement without changing the MCP protocol or breaking backwards compatibility.

Implementations

impl<H: ServerHandler> PolicyEnabledServer<H>

pub fn new(inner: H) -> Self

Create a new policy-enabled server wrapping an existing handler

pub fn with_policy(inner: H, policy: Policy) -> Result<Self, ErrorData>

Create a new policy-enabled server with a specific policy

pub fn with_compiled_policy(inner: H, policy: Arc<CompiledPolicy>) -> Self

Create from a pre-compiled policy

pub fn inner(&self) -> &H

Get a reference to the inner handler

pub fn inner_mut(&mut self) -> &mut H

Get a mutable reference to the inner handler

pub fn has_policy(&self) -> bool

Check if policy enforcement is enabled

Trait Implementations

impl<H: Clone + ServerHandler> Clone for PolicyEnabledServer<H>

fn clone(&self) -> PolicyEnabledServer<H>

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<H: ServerHandler> ServerHandler for PolicyEnabledServer<H>

async fn initialize( &self, params: InitializeRequestParams, context: RequestContext<RoleServer>, ) -> Result<InitializeResult, ErrorData>

async fn ping( &self, context: RequestContext<RoleServer>, ) -> Result<(), ErrorData>

async fn list_tools( &self, params: Option<PaginatedRequestParams>, context: RequestContext<RoleServer>, ) -> Result<ListToolsResult, ErrorData>

async fn call_tool( &self, params: CallToolRequestParams, context: RequestContext<RoleServer>, ) -> Result<CallToolResult, ErrorData>

async fn list_resources( &self, params: Option<PaginatedRequestParams>, context: RequestContext<RoleServer>, ) -> Result<ListResourcesResult, ErrorData>

async fn read_resource( &self, params: ReadResourceRequestParams, context: RequestContext<RoleServer>, ) -> Result<ReadResourceResult, ErrorData>

async fn list_prompts( &self, params: Option<PaginatedRequestParams>, context: RequestContext<RoleServer>, ) -> Result<ListPromptsResult, ErrorData>

async fn get_prompt( &self, params: GetPromptRequestParams, context: RequestContext<RoleServer>, ) -> Result<GetPromptResult, ErrorData>

async fn complete( &self, params: CompleteRequestParams, context: RequestContext<RoleServer>, ) -> Result<CompleteResult, ErrorData>

async fn set_level( &self, params: SetLevelRequestParams, context: RequestContext<RoleServer>, ) -> Result<(), ErrorData>

async fn list_resource_templates( &self, params: Option<PaginatedRequestParams>, context: RequestContext<RoleServer>, ) -> Result<ListResourceTemplatesResult, ErrorData>

async fn subscribe( &self, params: SubscribeRequestParams, context: RequestContext<RoleServer>, ) -> Result<(), ErrorData>

async fn unsubscribe( &self, params: UnsubscribeRequestParams, context: RequestContext<RoleServer>, ) -> Result<(), ErrorData>

async fn on_custom_request( &self, request: CustomRequest, context: RequestContext<RoleServer>, ) -> Result<CustomResult, ErrorData>

async fn on_initialized(&self, context: NotificationContext<RoleServer>)

async fn on_custom_notification( &self, notification: CustomNotification, context: NotificationContext<RoleServer>, )

fn enqueue_task( &self, _request: CallToolRequestParams, _context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<CreateTaskResult, McpError>> + Send + '_

fn on_cancelled( &self, notification: CancelledNotificationParam, context: NotificationContext<RoleServer>, ) -> impl Future<Output = ()> + Send + '_

fn on_progress( &self, notification: ProgressNotificationParam, context: NotificationContext<RoleServer>, ) -> impl Future<Output = ()> + Send + '_

fn on_roots_list_changed( &self, context: NotificationContext<RoleServer>, ) -> impl Future<Output = ()> + Send + '_

fn get_info(&self) -> ServerInfo

fn list_tasks( &self, request: Option<PaginatedRequestParams>, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<ListTasksResult, McpError>> + Send + '_

fn get_task_info( &self, request: GetTaskInfoParams, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<GetTaskInfoResult, McpError>> + Send + '_

fn get_task_result( &self, request: GetTaskResultParams, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<TaskResult, McpError>> + Send + '_

fn cancel_task( &self, request: CancelTaskParams, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<(), McpError>> + Send + '_