Struct google_api_proto::google::assistant::embedded::v1alpha1::embedded_assistant_client::EmbeddedAssistantClient

pub struct EmbeddedAssistantClient<T> { /* private fields */ }

Service that implements Google Assistant API.

Implementations

impl<T> EmbeddedAssistantClient<T>

where T: GrpcService<BoxBody>, T::Error: Into<StdError>, T::ResponseBody: Body<Data = Bytes> + Send + 'static, <T::ResponseBody as Body>::Error: Into<StdError> + Send,

pub fn new(inner: T) -> Self

pub fn with_origin(inner: T, origin: Uri) -> Self

pub fn with_interceptor<F>( inner: T, interceptor: F, ) -> EmbeddedAssistantClient<InterceptedService<T, F>>

where F: Interceptor, T::ResponseBody: Default, T: Service<Request<BoxBody>, Response = Response<<T as GrpcService<BoxBody>>::ResponseBody>>, <T as Service<Request<BoxBody>>>::Error: Into<StdError> + Send + Sync,

pub fn send_compressed(self, encoding: CompressionEncoding) -> Self

Compress requests with the given encoding.

This requires the server to support it otherwise it might respond with an error.

pub fn accept_compressed(self, encoding: CompressionEncoding) -> Self

Enable decompressing responses.

pub fn max_decoding_message_size(self, limit: usize) -> Self

Limits the maximum size of a decoded message.

Default: 4MB

pub fn max_encoding_message_size(self, limit: usize) -> Self

Limits the maximum size of an encoded message.

Default: usize::MAX

pub async fn converse( &mut self, request: impl IntoStreamingRequest<Message = ConverseRequest>, ) -> Result<Response<Streaming<ConverseResponse>>, Status>

Initiates or continues a conversation with the embedded assistant service. Each call performs one round-trip, sending an audio request to the service and receiving the audio response. Uses bidirectional streaming to receive results, such as the END_OF_UTTERANCE event, while sending audio.

A conversation is one or more gRPC connections, each consisting of several streamed requests and responses. For example, the user says Add to my shopping list and the assistant responds What do you want to add?. The sequence of streamed requests and responses in the first gRPC message could be:

• ConverseRequest.config
• ConverseRequest.audio_in
• ConverseRequest.audio_in
• ConverseRequest.audio_in
• ConverseRequest.audio_in
• ConverseResponse.event_type.END_OF_UTTERANCE
• ConverseResponse.result.microphone_mode.DIALOG_FOLLOW_ON
• ConverseResponse.audio_out
• ConverseResponse.audio_out
• ConverseResponse.audio_out

The user then says bagels and the assistant responds OK, I’ve added bagels to your shopping list. This is sent as another gRPC connection call to the Converse method, again with streamed requests and responses, such as:

• ConverseRequest.config
• ConverseRequest.audio_in
• ConverseRequest.audio_in
• ConverseRequest.audio_in
• ConverseResponse.event_type.END_OF_UTTERANCE
• ConverseResponse.result.microphone_mode.CLOSE_MICROPHONE
• ConverseResponse.audio_out
• ConverseResponse.audio_out
• ConverseResponse.audio_out
• ConverseResponse.audio_out

Although the precise order of responses is not guaranteed, sequential ConverseResponse.audio_out messages will always contain sequential portions of audio.

Trait Implementations

impl<T: Clone> Clone for EmbeddedAssistantClient<T>

fn clone(&self) -> EmbeddedAssistantClient<T>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<T: Debug> Debug for EmbeddedAssistantClient<T>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.