Struct O2mHandler 

pub struct O2mHandler<O2mApi> { /* private fields */ }

gRPC server handler for operator-to-middleware operations.

O2mHandler implements the gRPC server-side logic for administrative operations including policy management, provenance queries, and consent management by operators and compliance officers.

Type Parameters

• O2mApi - Service handling operator-to-middleware requests

Implementations

impl<O2mApi> O2mHandler<O2mApi>

pub fn new(o2m: O2mApi) -> Self

Creates a new O2M handler with the specified service handler.

Arguments

• o2m - Service for handling operator-to-middleware requests

Trait Implementations

impl<O2mApi> O2m for O2mHandler<O2mApi>

where O2mApi: Service<O2mRequest, Response = O2mResponse, Error = TraceabilityError> + Clone + Sync + Send + 'static, O2mApi::Future: Send,

Implementation of the O2M gRPC service protocol.

This implementation provides the server-side handlers for all operator-facing endpoints including policy configuration and provenance analysis.

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

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

Handles policy retrieval requests from operators.

Returns the current compliance policies for the specified set of resources.

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

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

Handles policy update requests from operators.

Sets a complete compliance policy for a specific resource.

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

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

Handles confidentiality setting requests from operators.

Updates the confidentiality policy for a specific resource.

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

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

Handles integrity setting requests from operators.

Updates the integrity level for a specific resource.

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

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

Handles deletion marking requests from operators.

Marks a resource as deleted for compliance tracking purposes.

fn o2m_enforce_consent<'life0, 'async_trait>( &'life0 self, request: Request<EnforceConsentRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<Self::O2MEnforceConsentStream>, Status>> + Send + 'async_trait>>

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

Handles consent enforcement requests from operators.

Enables consent enforcement for a resource and returns a stream of consent request notifications that can be monitored by the operator.

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

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

Handles consent decision requests from operators.

Sets the consent decision for a specific data flow operation.

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

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

Handles provenance query requests from operators.

Returns the complete provenance lineage for a specific resource.

type O2MEnforceConsentStream = Pin<Box<dyn Stream<Item = Result<ConsentNotification, Status>> + Send>>

Server streaming response type for the O2MEnforceConsent method.