pub struct VoiceServiceImpl { /* private fields */ }Expand description
VoiceService gRPC implementation backed by the AgentBus.
Implementations§
Source§impl VoiceServiceImpl
impl VoiceServiceImpl
pub fn new(bus: Arc<AgentBus>) -> Self
pub fn into_service(self) -> VoiceServiceServer<Self>
Trait Implementations§
Source§impl VoiceService for VoiceServiceImpl
impl VoiceService for VoiceServiceImpl
Source§type StreamVoiceEventsStream = Pin<Box<dyn Stream<Item = Result<VoiceEvent, Status>> + Send>>
type StreamVoiceEventsStream = Pin<Box<dyn Stream<Item = Result<VoiceEvent, Status>> + Send>>
Server streaming response type for the StreamVoiceEvents method.
Source§fn create_voice_session<'life0, 'async_trait>(
&'life0 self,
request: Request<CreateVoiceSessionRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<VoiceSession>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn create_voice_session<'life0, 'async_trait>(
&'life0 self,
request: Request<CreateVoiceSessionRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<VoiceSession>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Create a new voice session (LiveKit room + agent dispatch)
Source§fn get_voice_session<'life0, 'async_trait>(
&'life0 self,
request: Request<GetVoiceSessionRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<VoiceSession>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn get_voice_session<'life0, 'async_trait>(
&'life0 self,
request: Request<GetVoiceSessionRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<VoiceSession>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Get current state of a voice session
Source§fn delete_voice_session<'life0, 'async_trait>(
&'life0 self,
request: Request<DeleteVoiceSessionRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<()>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn delete_voice_session<'life0, 'async_trait>(
&'life0 self,
request: Request<DeleteVoiceSessionRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<()>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
End a voice session
Source§fn list_voices<'life0, 'async_trait>(
&'life0 self,
_request: Request<ListVoicesRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<ListVoicesResponse>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn list_voices<'life0, 'async_trait>(
&'life0 self,
_request: Request<ListVoicesRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<ListVoicesResponse>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
List available voice profiles
Source§fn stream_voice_events<'life0, 'async_trait>(
&'life0 self,
request: Request<StreamVoiceEventsRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<Self::StreamVoiceEventsStream>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn stream_voice_events<'life0, 'async_trait>(
&'life0 self,
request: Request<StreamVoiceEventsRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<Self::StreamVoiceEventsStream>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Stream voice events (transcripts, state changes) for a session
Auto Trait Implementations§
impl Freeze for VoiceServiceImpl
impl !RefUnwindSafe for VoiceServiceImpl
impl Send for VoiceServiceImpl
impl Sync for VoiceServiceImpl
impl Unpin for VoiceServiceImpl
impl UnsafeUnpin for VoiceServiceImpl
impl !UnwindSafe for VoiceServiceImpl
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::RequestSource§impl<T> Pointable for T
impl<T> Pointable for T
Source§impl<T> PolicyExt for Twhere
T: ?Sized,
impl<T> PolicyExt for Twhere
T: ?Sized,
Source§impl<T> ServiceExt for T
impl<T> ServiceExt for T
Source§fn map_response_body<F>(self, f: F) -> MapResponseBody<Self, F>where
Self: Sized,
fn map_response_body<F>(self, f: F) -> MapResponseBody<Self, F>where
Self: Sized,
Apply a transformation to the response body. Read more
Source§fn trace_for_http(self) -> Trace<Self, SharedClassifier<ServerErrorsAsFailures>>where
Self: Sized,
fn trace_for_http(self) -> Trace<Self, SharedClassifier<ServerErrorsAsFailures>>where
Self: Sized,
High level tracing that classifies responses using HTTP status codes. Read more
Source§fn trace_for_grpc(self) -> Trace<Self, SharedClassifier<GrpcErrorsAsFailures>>where
Self: Sized,
fn trace_for_grpc(self) -> Trace<Self, SharedClassifier<GrpcErrorsAsFailures>>where
Self: Sized,
High level tracing that classifies responses using gRPC headers. Read more