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 retry(&self, recording_id: Uuid) -> Result<(), Error>

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

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

Applies exact observation-level full-name confirmations to one completed recording.

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.