Struct Coordinator 

pub struct Coordinator { /* private fields */ }

Cloneable typed coordinator over AudioIngress and Session History.

Implementations

impl Coordinator

pub fn new( audio: AudioIngress, history: SessionHistory, config: Config, ) -> Result<Self, Error>

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

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

pub async fn recordings(&self) -> Result<Vec<Recording>, Error>

pub async fn recording_by_sha256( &self, sha256: &str, ) -> Result<Recording, Error>

pub async fn recording_history( &self, recording_id: Uuid, ) -> Result<RecordingHistory, Error>

pub async fn recording_history_with_current_speaker_candidates( &self, recording_id: Uuid, ) -> Result<RecordingHistory, Error>

Returns recording history after re-scoring every unsigned speaker chunk.

This explicit read is intended for a human opening one audio review. It runs synchronous classifier work on Tokio’s blocking pool; routine background observation should use Coordinator::recording_history.

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

Returns one authorized correction-packet chunk as an exact WAV interval.

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

Returns the known-speaker dropdown choices for this coordinator.

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

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

pub async fn retry_ingress( &self, input: RetryIngress, ) -> Result<SessionRecord, Error>

pub async fn synchronize_completed_transcripts(&self) -> Result<(), Error>

Trait Implementations

impl Clone for Coordinator

fn clone(&self) -> Coordinator

Returns a duplicate of the value.

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

Performs copy-assignment from source.