Crate sdivi_pipeline 

sdivi-pipeline

Orchestration crate for the Structural Divergence Indexer.

Owns all FS I/O, clock access, and atomic writes. The pure-compute facade (WASM-compatible, no FS) lives in sdivi-core.

Quick start

use sdivi_pipeline::Pipeline;
use sdivi_config::Config;

let pipeline = Pipeline::new(Config::default(), vec![]);
// Call pipeline.snapshot(repo_root, commit, timestamp) to run all five stages.

Re-exports

pub use boundaries::infer_from_snapshots;

pub use boundaries::read_prior_partitions;

pub use change_coupling::collect_cochange_events;

pub use change_coupling::ChangeCouplingError;

pub use commit_extract::CommitExtractError;

pub use error::PipelineError;

pub use pipeline::Pipeline;

pub use pipeline::WriteMode;

pub use store::latest_snapshot;

pub use store::read_snapshot_by_id;

pub use store::read_snapshots;

pub use store::write_boundary_spec;

pub use time::current_timestamp;

Modules

boundaries

Boundary inference helpers — reads snapshot history, builds prior-partition slices, and delegates to sdivi_core::infer_boundaries.

cache

Partition cache I/O — load and save the warm-start LeidenPartition.

change_coupling

Git shell-out for change-coupling event collection.

commit_extract

Git shell-outs for resolving refs and extracting historical trees.

error

pipeline

Pipeline — five-stage analysis pipeline with full FS orchestration.

store

Snapshot and boundary persistence helpers — atomic write, retention, and read utilities.

time

Time utilities for the pipeline — clock access lives here, not in sdivi-core.