Struct P2mHandler 

pub struct P2mHandler<P2mApi> { /* private fields */ }

gRPC server router that handles incoming requests and routes them to appropriate services.

Trace2eRouter implements the gRPC server-side logic by accepting incoming requests and routing them to the appropriate process-to-middleware (P2M) or machine-to-machine (M2M) service handlers.

Type Parameters

• P2mApi - Service handling process-to-middleware requests
• M2mApi - Service handling machine-to-machine requests

Request Routing

The router translates incoming Protocol Buffer requests to internal API types, calls the appropriate service, and converts responses back to Protocol Buffer format for transmission.

Implementations

impl<P2mApi> P2mHandler<P2mApi>

pub fn new(p2m: P2mApi) -> Self

Creates a new router with the specified service handlers.

Arguments

• p2m - Service for handling process-to-middleware requests

Trait Implementations

impl<P2mApi> P2m for P2mHandler<P2mApi>

where P2mApi: Service<P2mRequest, Response = P2mResponse, Error = TraceabilityError> + Clone + Sync + Send + 'static, P2mApi::Future: Send,

Implementation of the trace2e gRPC service protocol.

This implementation provides the server-side handlers for all gRPC endpoints defined in the trace2e protocol. It handles both P2M (process-to-middleware) and M2M (machine-to-machine) operations by delegating to the appropriate internal service handlers.

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

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

Handles local process enrollment requests.

Registers a local file descriptor with the middleware for tracking. This is called when a process opens a local file or resource.

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

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

Handles remote process enrollment requests.

Registers a network connection (socket) with the middleware for tracking. This is called when a process establishes a network connection.

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

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

Handles I/O authorization requests from processes.

Evaluates whether a process is authorized to perform an I/O operation on a specific file descriptor. Returns a grant ID if authorized.

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

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

Handles I/O operation completion reports from processes.

Records the completion and result of an I/O operation that was previously authorized. This completes the audit trail for the operation.