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>

Constructs a coordinator over already-opened capability handles.

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

Checks that AudioIngress can read its current state.

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

Durably submits one admitted recording and returns its combined state.

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

Returns recordings with their correlated ingress state.

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

Finds a recording by its SHA-256 digest.

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

Returns one recording and its correlated pieces.

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

Gives one failed recording a fresh processing budget.

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

Applies the complete human-confirmed speaker mapping and immediately attempts the now-authorized Session History handoff.

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

Retries one Session History ingress record.

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

Submits every missing transcript piece to Session History.

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.