Enum M2mRequest

pub enum M2mRequest {
    GetDestinationCompliance {
        source: Resource,
        destination: Resource,
    },
    GetSourceCompliance {
        authority_ip: String,
        resources: HashSet<Resource>,
    },
    UpdateProvenance {
        source_prov: HashMap<String, HashSet<Resource>>,
        destination: Resource,
    },
}

Middleware-to-Middleware (M2M) request types.

These requests enable communication between distributed middleware instances to maintain consistent compliance policies and provenance records across the network. Used primarily for cross-node data flows and distributed policy enforcement.

Variants

GetDestinationCompliance

Request compliance policies for a destination resource from its authoritative middleware.

Used when a local middleware needs to evaluate whether a data flow to a remote resource is permitted. The source middleware queries the destination middleware to obtain current policies before authorizing the operation.

Fields

source: Resource

Source resource where data originates

destination: Resource

Destination resource where data will be written

GetSourceCompliance

Request compliance policies for source resources from their authoritative middleware.

Used by destination middleware to verify that incoming data flows comply with source policies and organizational requirements.

Fields

authority_ip: String

IP address of the authoritative middleware for the source resources

resources: HashSet<Resource>

Set of source resources to query policies for

UpdateProvenance

Update provenance records on the destination middleware following a cross-node data flow.

Transfers lineage information from source to destination to maintain complete provenance chains across distributed systems.

Fields

source_prov: HashMap<String, HashSet<Resource>>

Provenance data from source resources organized by node ID

destination: Resource

Destination resource receiving the data and provenance updates

Trait Implementations

impl Clone for M2mRequest

fn clone(&self) -> M2mRequest

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for M2mRequest

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

Formats the value using the given formatter.

impl From<GetDestinationCompliance> for M2mRequest

Converts Protocol Buffer GetDestinationCompliance request to internal M2M request.

fn from(req: GetDestinationCompliance) -> Self

Converts to this type from the input type.

impl From<GetSourceCompliance> for M2mRequest

Converts Protocol Buffer GetSourceCompliance request to internal M2M request.

fn from(req: GetSourceCompliance) -> Self

Converts to this type from the input type.

impl From<UpdateProvenance> for M2mRequest

Converts Protocol Buffer UpdateProvenance request to internal M2M request.

fn from(req: UpdateProvenance) -> Self

Converts to this type from the input type.

impl<S, P, C> Service<M2mRequest> for M2mApiService<S, P, C>

where S: Service<SequencerRequest, Response = SequencerResponse, Error = TraceabilityError> + Clone + Send + 'static, S::Future: Send, P: Service<ProvenanceRequest, Response = ProvenanceResponse, Error = TraceabilityError> + Clone + Send + NodeId + 'static, P::Future: Send, C: Service<ComplianceRequest, Response = ComplianceResponse, Error = TraceabilityError> + Clone + Send + 'static, C::Future: Send,

type Response = M2mResponse

Responses given by the service.

type Error = TraceabilityError

Errors produced by the service.

type Future = Pin<Box<dyn Future<Output = Result<<M2mApiService<S, P, C> as Service<M2mRequest>>::Response, <M2mApiService<S, P, C> as Service<M2mRequest>>::Error>> + Send>>

The future response value.

fn poll_ready(&mut self, _: &mut Context<'_>) -> Poll<Result<(), Self::Error>>

Returns Poll::Ready(Ok(())) when the service is able to process requests.

fn call(&mut self, request: M2mRequest) -> Self::Future

Process the request and return the response asynchronously.

impl Service<M2mRequest> for M2mGrpc

type Response = M2mResponse

Responses given by the service.

type Error = TraceabilityError

Errors produced by the service.

type Future = Pin<Box<dyn Future<Output = Result<<M2mGrpc as Service<M2mRequest>>::Response, <M2mGrpc as Service<M2mRequest>>::Error>> + Send>>

The future response value.

fn poll_ready(&mut self, _: &mut Context<'_>) -> Poll<Result<(), Self::Error>>

Returns Poll::Ready(Ok(())) when the service is able to process requests.

fn call(&mut self, request: M2mRequest) -> Self::Future

Process the request and return the response asynchronously.

impl Service<M2mRequest> for M2mLoopback

type Response = M2mResponse

Responses given by the service.

type Error = TraceabilityError

Errors produced by the service.

type Future = Pin<Box<dyn Future<Output = Result<<M2mLoopback as Service<M2mRequest>>::Response, <M2mLoopback as Service<M2mRequest>>::Error>> + Send>>

The future response value.

fn poll_ready(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>>

Returns Poll::Ready(Ok(())) when the service is able to process requests.

fn call(&mut self, request: M2mRequest) -> Self::Future

Process the request and return the response asynchronously.

impl Service<M2mRequest> for M2mNop

Implementation of the M2M service interface for the no-op transport.

This implementation handles all M2M request types by returning appropriate default responses without performing any actual distributed operations. All requests complete immediately and successfully.

fn poll_ready(&mut self, _: &mut Context<'_>) -> Poll<Result<(), Self::Error>>

Always reports ready to handle requests immediately.

fn call(&mut self, request: M2mRequest) -> Self::Future

Handles M2M requests by returning appropriate default responses.

Request Handling

• GetDestinationCompliance: Returns a default policy with public confidentiality, zero integrity, not deleted, and consent given
• GetSourceCompliance: Returns an empty policy map indicating no source policies are available
• UpdateProvenance: Acknowledges the request without performing any provenance updates

type Response = M2mResponse

Responses given by the service.

type Error = TraceabilityError

Errors produced by the service.

type Future = Pin<Box<dyn Future<Output = Result<<M2mNop as Service<M2mRequest>>::Response, <M2mNop as Service<M2mRequest>>::Error>> + Send>>

The future response value.