Struct Trace2eRouter

pub struct Trace2eRouter<P2mApi, M2mApi> { /* 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, M2mApi> Trace2eRouter<P2mApi, M2mApi>

pub fn new(p2m: P2mApi, m2m: M2mApi) -> Self

Creates a new router with the specified service handlers.

Arguments

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

Trait Implementations

impl<P2mApi, M2mApi> Trace2eGrpc for Trace2eRouter<P2mApi, M2mApi>

where P2mApi: Service<P2mRequest, Response = P2mResponse, Error = TraceabilityError> + Clone + Sync + Send + 'static, P2mApi::Future: Send, M2mApi: Service<M2mRequest, Response = M2mResponse, Error = TraceabilityError> + Clone + Sync + Send + 'static, M2mApi::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.

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

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

Handles destination compliance policy requests from remote middleware.

Returns the compliance policy for a destination resource to enable remote middleware instances to evaluate flow authorization.

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

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

Handles source compliance policy requests from remote middleware.

Returns the compliance policies for a set of source resources to enable distributed flow evaluation across multiple middleware instances.

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

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

Handles provenance update requests from remote middleware.

Updates the provenance information for a destination resource based on data flows from remote sources. This maintains the audit trail across distributed operations.