Struct AudioIngress 

pub struct AudioIngress { /* private fields */ }

Cloneable handle to durable, automatically processed audio.

Implementations

impl AudioIngress

pub async fn open( persistence_root: impl AsRef<Path>, transcriber: AudioTranscriber, classifier: Arc<SpeechClassifier>, ) -> Result<Self, Error>

Opens the owned persistence root with a shared classifier and starts automatic processing.

Ingress state is stored at <root>/state.sqlite3, originals remain below <root>/originals/, and classifier state is owned by the caller-supplied shared classifier.

pub async fn submit(&self, input: AudioInput) -> Result<Submission, Error>

Durably accepts complete WAV bytes and schedules automatic processing.

pub fn status(&self) -> Result<Status, Error>

Returns all current recording states and completed correction packets.

pub fn speaker_review_audio( &self, recording_id: Uuid, chunk_index: usize, ) -> Result<SpeakerReviewAudio, Error>

Reads the exact retained source interval for one correction-packet chunk.

pub fn retry(&self, recording_id: Uuid) -> Result<(), Error>

Gives a failed recording a fresh five-attempt processing budget.

pub fn known_speakers(&self) -> Result<Vec<String>, Error>

Returns all distinct known speaker names in deterministic order.

pub fn resolve_legacy_review( &self, recording_id: Uuid, disposition: LegacyReviewDisposition, ) -> Result<(), Error>

Resolves one finalized recording whose obsolete packet was never signed.

The caller owns the downstream-ingress decision. Reprocessing archives the exact old transcript and packet before it clears the active result and queues the retained WAV. Completing preserves both payloads and marks the recording as an immutable legacy result.

pub fn confirm_speakers( &self, confirmation: ChunkConfirmation, ) -> Result<CorrectionPacket, Error>

Applies exact known-or-unknown resolutions and signs off one review chunk.

The confirmation must cover every deterministic observation key in the packet exactly once. Classifier updates are idempotent. The corrected packet is committed before this method returns and is also visible through AudioIngress::status.

Trait Implementations

impl Clone for AudioIngress

fn clone(&self) -> AudioIngress

Returns a duplicate of the value.

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

Performs copy-assignment from source.