Enum P2mRequest

pub enum P2mRequest {
    LocalEnroll {
        pid: i32,
        fd: i32,
        path: String,
    },
    RemoteEnroll {
        pid: i32,
        fd: i32,
        local_socket: String,
        peer_socket: String,
    },
    IoRequest {
        pid: i32,
        fd: i32,
        output: bool,
    },
    IoReport {
        pid: i32,
        fd: i32,
        grant_id: u128,
        result: bool,
    },
}

Process-to-Middleware (P2M) request types.

These requests are initiated by application processes to the middleware for resource enrollment and I/O operation authorization. The workflow typically follows:

1. Enroll resources using LocalEnroll or RemoteEnroll
2. Request I/O permission using IoRequest
3. Report operation completion using IoReport

Variants

LocalEnroll

Register a file resource with the middleware for traceability tracking.

Must be called before any I/O operations on the file. The middleware will create appropriate resource identifiers and establish compliance policies.

Fields

pid: i32

Process identifier that opened the file

fd: i32

File descriptor assigned by the operating system

path: String

Absolute or relative path to the file

RemoteEnroll

Register a network stream resource with the middleware for traceability tracking.

Used for TCP connections. Both endpoints must be specified to enable proper flow tracking.

Fields

pid: i32

Process identifier that opened the stream

fd: i32

File descriptor assigned by the operating system

local_socket: String

Local socket address (e.g., “127.0.0.1:8080”)

peer_socket: String

Remote peer socket address (e.g., “192.168.1.100:9000”)

IoRequest

Request authorization to perform an I/O operation on a previously enrolled resource.

The middleware will evaluate compliance policies, check data lineage requirements, and coordinate with remote middleware instances if necessary before granting access.

Fields

pid: i32

Process identifier requesting the operation

fd: i32

File descriptor for the target resource

output: bool

Direction of data flow: true for output (write), false for input (read)

IoReport

Report the completion status of a previously authorized I/O operation.

This enables the middleware to update provenance records, release flow reservations, and maintain accurate audit trails for compliance purposes.

Fields

pid: i32

Process identifier that performed the operation

fd: i32

File descriptor for the resource

grant_id: u128

Grant identifier returned from the corresponding IoRequest

result: bool

Operation outcome: true for success, false for failure

Trait Implementations

impl Clone for P2mRequest

fn clone(&self) -> P2mRequest

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for P2mRequest

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

Formats the value using the given formatter.

impl<S, P, C, M> Service<P2mRequest> for P2mApiService<S, P, C, M>

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, M: Service<M2mRequest, Response = M2mResponse, Error = TraceabilityError> + Clone + Send + 'static, M::Future: Send,

type Response = P2mResponse

Responses given by the service.

type Error = TraceabilityError

Errors produced by the service.

type Future = Pin<Box<dyn Future<Output = Result<<P2mApiService<S, P, C, M> as Service<P2mRequest>>::Response, <P2mApiService<S, P, C, M> as Service<P2mRequest>>::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: P2mRequest) -> Self::Future

Process the request and return the response asynchronously.