Enum ProvenanceRequest

pub enum ProvenanceRequest {
    GetReferences(Resource),
    UpdateProvenance {
        source: Resource,
        destination: Resource,
    },
    UpdateProvenanceRaw {
        source_prov: HashMap<String, HashSet<Resource>>,
        destination: Resource,
    },
}

Provenance service request types.

Internal API for the provenance service, which tracks data lineage and ancestry relationships across resources and operations. Maintains comprehensive audit trails for compliance and data governance purposes.

Variants

GetReferences(Resource)

Retrieve the complete provenance lineage for a resource.

Returns all upstream resources and nodes that have contributed data to the specified resource, enabling full traceability analysis.

UpdateProvenance

Record a new data flow relationship between source and destination resources.

Updates the destination’s provenance to include the source resource, maintaining the complete lineage chain for audit and compliance purposes.

Fields

source: Resource

Source resource providing data

destination: Resource

Destination resource receiving data and provenance updates

UpdateProvenanceRaw

Update destination provenance with pre-computed source lineage data.

Used for cross-node flows where source provenance has been collected from remote middleware instances and needs to be merged with local records.

Fields

source_prov: HashMap<String, HashSet<Resource>>

Pre-computed provenance data organized by source node ID

destination: Resource

Destination resource to receive the provenance updates

Trait Implementations

impl Clone for ProvenanceRequest

fn clone(&self) -> ProvenanceRequest

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ProvenanceRequest

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

Formats the value using the given formatter.

impl Service<ProvenanceRequest> for ProvenanceService

type Response = ProvenanceResponse

Responses given by the service.

type Error = TraceabilityError

Errors produced by the service.

type Future = Pin<Box<dyn Future<Output = Result<<ProvenanceService as Service<ProvenanceRequest>>::Response, <ProvenanceService as Service<ProvenanceRequest>>::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: ProvenanceRequest) -> Self::Future

Process the request and return the response asynchronously.