Struct M2mHandler 

pub struct M2mHandler<M2mApi> { /* private fields */ }

Implementations

impl<M2mApi> M2mHandler<M2mApi>

pub fn new(m2m: M2mApi) -> Self

Creates a new router with the specified service handlers.

Arguments

• m2m - Service for handling machine-to-machine requests

Trait Implementations

impl<M2mApi> M2m for M2mHandler<M2mApi>

where M2mApi: Service<M2mRequest, Response = M2mResponse, Error = TraceabilityError> + Clone + Sync + Send + 'static, M2mApi::Future: Send,

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

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

Handles destination policy requests from remote middleware.

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

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

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

Handles source compliance checking requests from remote middleware.

Checks 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.

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

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

Handles deletion broadcast requests from remote middleware.

Broadcasts the deletion of a resource to all middleware instances.