1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33
# src/pipeline ## Purpose Offline diarization pipeline orchestration: segment → embed → cluster → resegment → merge → emit DiarizationResult. ## Surfaces - `Pipeline` - `PipelineError` ## Dependencies - `types` — DiarizationConfig, DiarizationResult - `vad` — VoiceActivityDetector - `ahc` — agglomerative clustering - `wav` — audio input ## Invariants - Pipeline output turns are monotonically ordered and non-overlapping (before overlap detection). ## Verification ```bash cargo test --test e2e_smoke_test --features onnx,download ``` ## Notes - Pipeline does not own individual algorithms; it orchestrates them.