Struct google_api_proto::google::cloud::dialogflow::v2::participants_client::ParticipantsClient

source ·

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

Expand description

Service for managing [Participants][google.cloud.dialogflow.v2.Participant].

Implementations§

source §

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

source

pub fn new(inner: T) -> Self

source

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

source

pub fn with_interceptor<F>( inner: T, interceptor: F, ) -> ParticipantsClient<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,

source

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.

source

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

Enable decompressing responses.

source

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

Limits the maximum size of a decoded message.

Default: 4MB

source

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

Limits the maximum size of an encoded message.

Default: usize::MAX

source

pub async fn create_participant( &mut self, request: impl IntoRequest<CreateParticipantRequest>, ) -> Result<Response<Participant>, Status>

Creates a new participant in a conversation.

source

pub async fn get_participant( &mut self, request: impl IntoRequest<GetParticipantRequest>, ) -> Result<Response<Participant>, Status>

Retrieves a conversation participant.

source

pub async fn list_participants( &mut self, request: impl IntoRequest<ListParticipantsRequest>, ) -> Result<Response<ListParticipantsResponse>, Status>

Returns the list of all participants in the specified conversation.

source

pub async fn update_participant( &mut self, request: impl IntoRequest<UpdateParticipantRequest>, ) -> Result<Response<Participant>, Status>

Updates the specified participant.

source

pub async fn analyze_content( &mut self, request: impl IntoRequest<AnalyzeContentRequest>, ) -> Result<Response<AnalyzeContentResponse>, Status>

Adds a text (chat, for example), or audio (phone recording, for example) message from a participant into the conversation.

Note: Always use agent versions for production traffic sent to virtual agents. See Versions and environments.

source

pub async fn streaming_analyze_content( &mut self, request: impl IntoStreamingRequest<Message = StreamingAnalyzeContentRequest>, ) -> Result<Response<Streaming<StreamingAnalyzeContentResponse>>, Status>

Adds a text (chat, for example), or audio (phone recording, for example) message from a participant into the conversation. Note: This method is only available through the gRPC API (not REST).

The top-level message sent to the client by the server is StreamingAnalyzeContentResponse. Multiple response messages can be returned in order. The first one or more messages contain the recognition_result field. Each result represents a more complete transcript of what the user said. The next message contains the reply_text field and potentially the reply_audio field. The message can also contain the automated_agent_reply field.

Note: Always use agent versions for production traffic sent to virtual agents. See Versions and environments.

source