Struct Engine 

pub struct Engine<'a> {
    pub renderer: &'a dyn Renderer,
    pub clusterer: &'a dyn WorkstreamClusterer,
    pub redactor: &'a dyn Redactor,
}

Fields

renderer: &'a dyn Renderer

clusterer: &'a dyn WorkstreamClusterer

redactor: &'a dyn Redactor

Implementations

impl<'a> Engine<'a>

pub fn new( renderer: &'a dyn Renderer, clusterer: &'a dyn WorkstreamClusterer, redactor: &'a dyn Redactor, ) -> Self

pub fn run( &self, ingest: IngestOutput, user: &str, window_label: &str, out_dir: &Path, zip: bool, bundle_profile: &BundleProfile, ) -> Result<(RunOutputs, WorkstreamSource)>

Run the full pipeline: ingest → cluster → render

Uses WorkstreamManager to respect user-curated workstreams.

pub fn import( &self, ingest: IngestOutput, user: &str, window_label: &str, out_dir: &Path, zip: bool, workstreams: Option<WorkstreamsFile>, bundle_profile: &BundleProfile, ) -> Result<(RunOutputs, WorkstreamSource)>

Import a pre-built ledger and run the full render pipeline.

When workstreams is Some, uses them directly (writes as curated). When None, falls through to normal clustering.

pub fn refresh( &self, ingest: IngestOutput, user: &str, window_label: &str, out_dir: &Path, zip: bool, bundle_profile: &BundleProfile, ) -> Result<RunOutputs>

Refresh receipts and stats without regenerating workstreams

This preserves user curation while updating event data.