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 both underlying capabilities can read their 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 configured-user recordings with their correlated ingress state.

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

Finds a configured-user recording by its SHA-256 digest.

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

Returns one configured-user recording and its correlated pieces.

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

Gives one failed configured-user recording a fresh processing budget.

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

Retries memory ingress only for a currently correlated audio piece.

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

Submits every missing configured-user 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.