Struct MethodRegistry 

pub struct MethodRegistry { /* private fields */ }

Method registry with optional authentication

Implementations

impl MethodRegistry

pub fn new(methods: Vec<Box<dyn JsonRPCMethod>>) -> Self

Create a new method registry with the given method implementations

pub fn empty() -> Self

Create an empty registry

pub fn with_auth<A: AuthPolicy + 'static>(self, policy: A) -> Self

Set an authentication/authorization policy

When set, can_access will be checked before executing methods. The user implements ALL auth logic in the trait.

Example

let registry = MethodRegistry::new(methods)
    .with_auth(MyAuthPolicy::new());

pub fn add_method(self, method: Box<dyn JsonRPCMethod>) -> Self

Add a method implementation to the registry

pub async fn call( &self, method_name: &str, params: Option<Value>, id: Option<RequestId>, ) -> Response

Call a registered method asynchronously using compile-time dispatch Note: This method should typically be replaced by using the dispatch_methods! macro directly for better compile-time optimization

pub async fn call_with_context( &self, method_name: &str, params: Option<Value>, id: Option<RequestId>, ctx: &ConnectionContext, ) -> Response

Call a registered method with authentication context

Use this when you have connection context from your transport layer.

pub fn has_method(&self, method_name: &str) -> bool

Check if a method is registered

pub fn get_methods(&self) -> Vec<String>

Get list of all registered methods

pub fn method_count(&self) -> usize

Get the number of registered methods

pub fn generate_openapi_spec(&self, title: &str, version: &str) -> OpenApiSpec

Generate OpenAPI specification for all registered methods

pub fn generate_openapi_spec_with_info( &self, title: &str, version: &str, description: Option<&str>, servers: Vec<OpenApiServer>, ) -> OpenApiSpec

Generate OpenAPI specification with custom info and servers

pub fn export_openapi_json( &self, title: &str, version: &str, ) -> Result<String, Error>

Export OpenAPI spec as JSON string

Trait Implementations

impl Default for MethodRegistry

fn default() -> Self

Returns the “default value” for a type.

impl Handler for MethodRegistry

fn handle_request<'life0, 'async_trait>( &'life0 self, request: Request, ) -> Pin<Box<dyn Future<Output = Response> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Handle a JSON-RPC request and return a response

fn handle_notification<'life0, 'async_trait>( &'life0 self, notification: Notification, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Handle a JSON-RPC notification (no response expected)

fn supports_method(&self, method: &str) -> bool

Check if a method is supported

fn get_supported_methods(&self) -> Vec<String>

Get list of supported methods

impl MessageProcessor for MethodRegistry

fn process_message<'life0, 'async_trait>( &'life0 self, message: Message, ) -> Pin<Box<dyn Future<Output = Option<Response>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Process a single JSON-RPC message

fn process_batch<'life0, 'async_trait>( &'life0 self, messages: Vec<Message>, ) -> Pin<Box<dyn Future<Output = Vec<Response>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Process a batch of JSON-RPC messages

fn get_capabilities(&self) -> ProcessorCapabilities

Get processor capabilities

fn supports_batching(&self) -> bool

Check if batch processing is supported