Struct IpcRouter

pub struct IpcRouter {
    connections: RwLock<Vec<ConnectionContext>>,
    network_service: Option<Arc<dyn NetworkService>>,
    process_service: Option<Arc<dyn ProcessService>>,
    rate_limiter: Mutex<HashMap<RateKey, TokenBucket>>,
}

A simple in-memory router that registers connections, authorizes requests, and returns a canned ‘not implemented’ response for authorized calls.

Fields

connections: RwLock<Vec<ConnectionContext>>

network_service: Option<Arc<dyn NetworkService>>

process_service: Option<Arc<dyn ProcessService>>

rate_limiter: Mutex<HashMap<RateKey, TokenBucket>>

Implementations

impl IpcRouter

pub fn new() -> Self

Create a new SimpleRouter.

pub fn with_process_service(self, svc: Arc<dyn ProcessService>) -> Self

Set the process service.

pub fn with_network_service(self, svc: Arc<dyn NetworkService>) -> Self

Set the network service (thin adapter).

fn should_rate_limit(service: &str) -> bool

fn match_quotas( ctx: &ConnectionContext, method: &MethodId, ) -> Result<Option<QuotaSet>, RpcError>

async fn enforce_rate_limits( &self, ctx: &ConnectionContext, method: &MethodId, request_bytes: usize, ) -> Result<(), RpcError>

fn decode_shutdown_request( args: Vec<u8>, ) -> Result<ShutdownTreeRequest, RpcError>

fn error_response(id: u64, code: &str, message: &str) -> Response

Helper to create an error response.

fn success_response(id: u64, bytes: Vec<u8>) -> Response

Helper to create a success response with serialized bytes.

fn check_service<T>( &self, service: &Option<T>, service_name: &str, id: u64, ) -> Result<(), Response>

Helper to check if a service is configured.

fn decode_request<T: DeserializeOwned>( &self, args: &[u8], method: &str, id: u64, ) -> Result<T, Response>

Helper to decode a request from bytes.

async fn handle_service_call<T: Serialize, E: Display>( &self, call: impl Future<Output = Result<T, E>>, id: u64, ) -> Result<Response, Error>

Helper to handle service call and serialize response.

async fn dispatch_process(&self, request: Request) -> Result<Response, Error>

async fn dispatch_network(&self, request: Request) -> Result<Response, Error>

impl IpcRouter

pub fn get(&self, id: &ConnectionId) -> Option<ConnectionContext>

Retrieve a registered connection by id.

Trait Implementations

impl Debug for IpcRouter

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for IpcRouter

fn default() -> Self

Returns the “default value” for a type.

impl Router for IpcRouter

fn register_connection<'life0, 'async_trait>( &'life0 self, ctx: ConnectionContext, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

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

Register a new connection after handshake.

fn dispatch<'life0, 'life1, 'async_trait>( &'life0 self, ctx: &'life1 ConnectionContext, request: Request, ) -> Pin<Box<dyn Future<Output = Result<Response, Error>> + Send + 'async_trait>>

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

Resolve and dispatch a request to a target service method.

fn is_authorized( &self, ctx: &ConnectionContext, method: &MethodId, ) -> Result<(), RpcError>

Check whether a given method is allowed by a connection’s capabilities.

fn emit_event<'life0, 'async_trait>( &'life0 self, event: Event, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

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

Emit an event to a connection or broadcast to all with appropriate policies.

fn observe_cancel<'life0, 'life1, 'async_trait>( &'life0 self, _ctx: &'life1 ConnectionContext, _id: u64, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

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

Observe a cancellation request for auditing/metrics.