Struct WorkflowIntegration 

pub struct WorkflowIntegration {
    pub triggers: HashMap<String, WorkflowTrigger>,
    pub cron_triggers: HashMap<String, WorkflowCronTrigger>,
    pub provenance: HashMap<String, Vec<WorkflowProvenance>>,
}

Workflow integration manager

Fields

triggers: HashMap<String, WorkflowTrigger>

Triggers that create workflows

cron_triggers: HashMap<String, WorkflowCronTrigger>

Cron triggers that create workflows

provenance: HashMap<String, Vec<WorkflowProvenance>>

Provenance records

Implementations

impl WorkflowIntegration

pub fn new() -> Self

Create a new workflow integration manager

pub fn register_trigger( &mut self, trigger_id: impl Into<String>, trigger: WorkflowTrigger, )

Register a workflow trigger

pub fn register_cron_trigger( &mut self, trigger_id: impl Into<String>, trigger: WorkflowCronTrigger, )

Register a cron trigger

pub fn record_provenance(&mut self, provenance: WorkflowProvenance)

Record workflow provenance

pub fn get_provenance( &self, output_ref: &FlowRef, ) -> Option<Vec<WorkflowProvenance>>

Get provenance for an output reference

pub fn build_lineage(&self, output_ref: &FlowRef) -> Vec<(FlowRef, String)>

Build complete provenance lineage (all upstream objects)

Trait Implementations

impl Clone for WorkflowIntegration

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WorkflowIntegration

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

Formats the value using the given formatter.

impl Default for WorkflowIntegration

fn default() -> Self

Returns the “default value” for a type.