google-cloud-discoveryengine-v1 2.8.0

// Copyright 2025 Google LLC
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
//     https://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.
//
// Code generated by sidekick. DO NOT EDIT.

/// A dyn-compatible, crate-private version of [super::AssistantService].
#[cfg(feature = "assistant-service")]
#[async_trait::async_trait]
pub trait AssistantService: std::fmt::Debug + Send + Sync {
    async fn list_operations(
        &self,
        req: google_cloud_longrunning::model::ListOperationsRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::ListOperationsResponse>>;

    async fn get_operation(
        &self,
        req: google_cloud_longrunning::model::GetOperationRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;

    async fn cancel_operation(
        &self,
        req: google_cloud_longrunning::model::CancelOperationRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<()>>;
}

/// All implementations of [super::AssistantService] also implement [AssistantService].
#[cfg(feature = "assistant-service")]
#[async_trait::async_trait]
impl<T: super::AssistantService> AssistantService for T {
    /// Forwards the call to the implementation provided by `T`.
    async fn list_operations(
        &self,
        req: google_cloud_longrunning::model::ListOperationsRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::ListOperationsResponse>>
    {
        T::list_operations(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn get_operation(
        &self,
        req: google_cloud_longrunning::model::GetOperationRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
        T::get_operation(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn cancel_operation(
        &self,
        req: google_cloud_longrunning::model::CancelOperationRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<()>> {
        T::cancel_operation(self, req, options).await
    }
}

/// A dyn-compatible, crate-private version of [super::CmekConfigService].
#[cfg(feature = "cmek-config-service")]
#[async_trait::async_trait]
pub trait CmekConfigService: std::fmt::Debug + Send + Sync {
    async fn update_cmek_config(
        &self,
        req: crate::model::UpdateCmekConfigRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;

    async fn get_cmek_config(
        &self,
        req: crate::model::GetCmekConfigRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::CmekConfig>>;

    async fn list_cmek_configs(
        &self,
        req: crate::model::ListCmekConfigsRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::ListCmekConfigsResponse>>;

    async fn delete_cmek_config(
        &self,
        req: crate::model::DeleteCmekConfigRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;

    async fn list_operations(
        &self,
        req: google_cloud_longrunning::model::ListOperationsRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::ListOperationsResponse>>;

    async fn get_operation(
        &self,
        req: google_cloud_longrunning::model::GetOperationRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;

    async fn cancel_operation(
        &self,
        req: google_cloud_longrunning::model::CancelOperationRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<()>>;

    fn get_polling_error_policy(
        &self,
        options: &crate::RequestOptions,
    ) -> std::sync::Arc<dyn google_cloud_gax::polling_error_policy::PollingErrorPolicy>;

    fn get_polling_backoff_policy(
        &self,
        options: &crate::RequestOptions,
    ) -> std::sync::Arc<dyn google_cloud_gax::polling_backoff_policy::PollingBackoffPolicy>;
}

/// All implementations of [super::CmekConfigService] also implement [CmekConfigService].
#[cfg(feature = "cmek-config-service")]
#[async_trait::async_trait]
impl<T: super::CmekConfigService> CmekConfigService for T {
    /// Forwards the call to the implementation provided by `T`.
    async fn update_cmek_config(
        &self,
        req: crate::model::UpdateCmekConfigRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
        T::update_cmek_config(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn get_cmek_config(
        &self,
        req: crate::model::GetCmekConfigRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::CmekConfig>> {
        T::get_cmek_config(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn list_cmek_configs(
        &self,
        req: crate::model::ListCmekConfigsRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::ListCmekConfigsResponse>> {
        T::list_cmek_configs(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn delete_cmek_config(
        &self,
        req: crate::model::DeleteCmekConfigRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
        T::delete_cmek_config(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn list_operations(
        &self,
        req: google_cloud_longrunning::model::ListOperationsRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::ListOperationsResponse>>
    {
        T::list_operations(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn get_operation(
        &self,
        req: google_cloud_longrunning::model::GetOperationRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
        T::get_operation(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn cancel_operation(
        &self,
        req: google_cloud_longrunning::model::CancelOperationRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<()>> {
        T::cancel_operation(self, req, options).await
    }

    fn get_polling_error_policy(
        &self,
        options: &crate::RequestOptions,
    ) -> std::sync::Arc<dyn google_cloud_gax::polling_error_policy::PollingErrorPolicy> {
        T::get_polling_error_policy(self, options)
    }

    fn get_polling_backoff_policy(
        &self,
        options: &crate::RequestOptions,
    ) -> std::sync::Arc<dyn google_cloud_gax::polling_backoff_policy::PollingBackoffPolicy> {
        T::get_polling_backoff_policy(self, options)
    }
}

/// A dyn-compatible, crate-private version of [super::CompletionService].
#[cfg(feature = "completion-service")]
#[async_trait::async_trait]
pub trait CompletionService: std::fmt::Debug + Send + Sync {
    async fn complete_query(
        &self,
        req: crate::model::CompleteQueryRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::CompleteQueryResponse>>;

    async fn import_suggestion_deny_list_entries(
        &self,
        req: crate::model::ImportSuggestionDenyListEntriesRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;

    async fn purge_suggestion_deny_list_entries(
        &self,
        req: crate::model::PurgeSuggestionDenyListEntriesRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;

    async fn import_completion_suggestions(
        &self,
        req: crate::model::ImportCompletionSuggestionsRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;

    async fn purge_completion_suggestions(
        &self,
        req: crate::model::PurgeCompletionSuggestionsRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;

    async fn list_operations(
        &self,
        req: google_cloud_longrunning::model::ListOperationsRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::ListOperationsResponse>>;

    async fn get_operation(
        &self,
        req: google_cloud_longrunning::model::GetOperationRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;

    async fn cancel_operation(
        &self,
        req: google_cloud_longrunning::model::CancelOperationRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<()>>;

    fn get_polling_error_policy(
        &self,
        options: &crate::RequestOptions,
    ) -> std::sync::Arc<dyn google_cloud_gax::polling_error_policy::PollingErrorPolicy>;

    fn get_polling_backoff_policy(
        &self,
        options: &crate::RequestOptions,
    ) -> std::sync::Arc<dyn google_cloud_gax::polling_backoff_policy::PollingBackoffPolicy>;
}

/// All implementations of [super::CompletionService] also implement [CompletionService].
#[cfg(feature = "completion-service")]
#[async_trait::async_trait]
impl<T: super::CompletionService> CompletionService for T {
    /// Forwards the call to the implementation provided by `T`.
    async fn complete_query(
        &self,
        req: crate::model::CompleteQueryRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::CompleteQueryResponse>> {
        T::complete_query(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn import_suggestion_deny_list_entries(
        &self,
        req: crate::model::ImportSuggestionDenyListEntriesRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
        T::import_suggestion_deny_list_entries(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn purge_suggestion_deny_list_entries(
        &self,
        req: crate::model::PurgeSuggestionDenyListEntriesRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
        T::purge_suggestion_deny_list_entries(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn import_completion_suggestions(
        &self,
        req: crate::model::ImportCompletionSuggestionsRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
        T::import_completion_suggestions(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn purge_completion_suggestions(
        &self,
        req: crate::model::PurgeCompletionSuggestionsRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
        T::purge_completion_suggestions(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn list_operations(
        &self,
        req: google_cloud_longrunning::model::ListOperationsRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::ListOperationsResponse>>
    {
        T::list_operations(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn get_operation(
        &self,
        req: google_cloud_longrunning::model::GetOperationRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
        T::get_operation(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn cancel_operation(
        &self,
        req: google_cloud_longrunning::model::CancelOperationRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<()>> {
        T::cancel_operation(self, req, options).await
    }

    fn get_polling_error_policy(
        &self,
        options: &crate::RequestOptions,
    ) -> std::sync::Arc<dyn google_cloud_gax::polling_error_policy::PollingErrorPolicy> {
        T::get_polling_error_policy(self, options)
    }

    fn get_polling_backoff_policy(
        &self,
        options: &crate::RequestOptions,
    ) -> std::sync::Arc<dyn google_cloud_gax::polling_backoff_policy::PollingBackoffPolicy> {
        T::get_polling_backoff_policy(self, options)
    }
}

/// A dyn-compatible, crate-private version of [super::ControlService].
#[cfg(feature = "control-service")]
#[async_trait::async_trait]
pub trait ControlService: std::fmt::Debug + Send + Sync {
    async fn create_control(
        &self,
        req: crate::model::CreateControlRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::Control>>;

    async fn delete_control(
        &self,
        req: crate::model::DeleteControlRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<()>>;

    async fn update_control(
        &self,
        req: crate::model::UpdateControlRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::Control>>;

    async fn get_control(
        &self,
        req: crate::model::GetControlRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::Control>>;

    async fn list_controls(
        &self,
        req: crate::model::ListControlsRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::ListControlsResponse>>;

    async fn list_operations(
        &self,
        req: google_cloud_longrunning::model::ListOperationsRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::ListOperationsResponse>>;

    async fn get_operation(
        &self,
        req: google_cloud_longrunning::model::GetOperationRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;

    async fn cancel_operation(
        &self,
        req: google_cloud_longrunning::model::CancelOperationRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<()>>;
}

/// All implementations of [super::ControlService] also implement [ControlService].
#[cfg(feature = "control-service")]
#[async_trait::async_trait]
impl<T: super::ControlService> ControlService for T {
    /// Forwards the call to the implementation provided by `T`.
    async fn create_control(
        &self,
        req: crate::model::CreateControlRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::Control>> {
        T::create_control(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn delete_control(
        &self,
        req: crate::model::DeleteControlRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<()>> {
        T::delete_control(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn update_control(
        &self,
        req: crate::model::UpdateControlRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::Control>> {
        T::update_control(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn get_control(
        &self,
        req: crate::model::GetControlRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::Control>> {
        T::get_control(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn list_controls(
        &self,
        req: crate::model::ListControlsRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::ListControlsResponse>> {
        T::list_controls(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn list_operations(
        &self,
        req: google_cloud_longrunning::model::ListOperationsRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::ListOperationsResponse>>
    {
        T::list_operations(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn get_operation(
        &self,
        req: google_cloud_longrunning::model::GetOperationRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
        T::get_operation(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn cancel_operation(
        &self,
        req: google_cloud_longrunning::model::CancelOperationRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<()>> {
        T::cancel_operation(self, req, options).await
    }
}

/// A dyn-compatible, crate-private version of [super::ConversationalSearchService].
#[cfg(feature = "conversational-search-service")]
#[async_trait::async_trait]
pub trait ConversationalSearchService: std::fmt::Debug + Send + Sync {
    async fn converse_conversation(
        &self,
        req: crate::model::ConverseConversationRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::ConverseConversationResponse>>;

    async fn create_conversation(
        &self,
        req: crate::model::CreateConversationRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::Conversation>>;

    async fn delete_conversation(
        &self,
        req: crate::model::DeleteConversationRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<()>>;

    async fn update_conversation(
        &self,
        req: crate::model::UpdateConversationRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::Conversation>>;

    async fn get_conversation(
        &self,
        req: crate::model::GetConversationRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::Conversation>>;

    async fn list_conversations(
        &self,
        req: crate::model::ListConversationsRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::ListConversationsResponse>>;

    async fn answer_query(
        &self,
        req: crate::model::AnswerQueryRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::AnswerQueryResponse>>;

    async fn get_answer(
        &self,
        req: crate::model::GetAnswerRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::Answer>>;

    async fn create_session(
        &self,
        req: crate::model::CreateSessionRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::Session>>;

    async fn delete_session(
        &self,
        req: crate::model::DeleteSessionRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<()>>;

    async fn update_session(
        &self,
        req: crate::model::UpdateSessionRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::Session>>;

    async fn get_session(
        &self,
        req: crate::model::GetSessionRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::Session>>;

    async fn list_sessions(
        &self,
        req: crate::model::ListSessionsRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::ListSessionsResponse>>;

    async fn list_operations(
        &self,
        req: google_cloud_longrunning::model::ListOperationsRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::ListOperationsResponse>>;

    async fn get_operation(
        &self,
        req: google_cloud_longrunning::model::GetOperationRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;

    async fn cancel_operation(
        &self,
        req: google_cloud_longrunning::model::CancelOperationRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<()>>;
}

/// All implementations of [super::ConversationalSearchService] also implement [ConversationalSearchService].
#[cfg(feature = "conversational-search-service")]
#[async_trait::async_trait]
impl<T: super::ConversationalSearchService> ConversationalSearchService for T {
    /// Forwards the call to the implementation provided by `T`.
    async fn converse_conversation(
        &self,
        req: crate::model::ConverseConversationRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::ConverseConversationResponse>> {
        T::converse_conversation(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn create_conversation(
        &self,
        req: crate::model::CreateConversationRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::Conversation>> {
        T::create_conversation(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn delete_conversation(
        &self,
        req: crate::model::DeleteConversationRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<()>> {
        T::delete_conversation(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn update_conversation(
        &self,
        req: crate::model::UpdateConversationRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::Conversation>> {
        T::update_conversation(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn get_conversation(
        &self,
        req: crate::model::GetConversationRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::Conversation>> {
        T::get_conversation(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn list_conversations(
        &self,
        req: crate::model::ListConversationsRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::ListConversationsResponse>> {
        T::list_conversations(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn answer_query(
        &self,
        req: crate::model::AnswerQueryRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::AnswerQueryResponse>> {
        T::answer_query(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn get_answer(
        &self,
        req: crate::model::GetAnswerRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::Answer>> {
        T::get_answer(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn create_session(
        &self,
        req: crate::model::CreateSessionRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::Session>> {
        T::create_session(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn delete_session(
        &self,
        req: crate::model::DeleteSessionRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<()>> {
        T::delete_session(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn update_session(
        &self,
        req: crate::model::UpdateSessionRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::Session>> {
        T::update_session(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn get_session(
        &self,
        req: crate::model::GetSessionRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::Session>> {
        T::get_session(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn list_sessions(
        &self,
        req: crate::model::ListSessionsRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::ListSessionsResponse>> {
        T::list_sessions(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn list_operations(
        &self,
        req: google_cloud_longrunning::model::ListOperationsRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::ListOperationsResponse>>
    {
        T::list_operations(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn get_operation(
        &self,
        req: google_cloud_longrunning::model::GetOperationRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
        T::get_operation(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn cancel_operation(
        &self,
        req: google_cloud_longrunning::model::CancelOperationRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<()>> {
        T::cancel_operation(self, req, options).await
    }
}

/// A dyn-compatible, crate-private version of [super::DataStoreService].
#[cfg(feature = "data-store-service")]
#[async_trait::async_trait]
pub trait DataStoreService: std::fmt::Debug + Send + Sync {
    async fn create_data_store(
        &self,
        req: crate::model::CreateDataStoreRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;

    async fn get_data_store(
        &self,
        req: crate::model::GetDataStoreRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::DataStore>>;

    async fn list_data_stores(
        &self,
        req: crate::model::ListDataStoresRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::ListDataStoresResponse>>;

    async fn delete_data_store(
        &self,
        req: crate::model::DeleteDataStoreRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;

    async fn update_data_store(
        &self,
        req: crate::model::UpdateDataStoreRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::DataStore>>;

    async fn list_operations(
        &self,
        req: google_cloud_longrunning::model::ListOperationsRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::ListOperationsResponse>>;

    async fn get_operation(
        &self,
        req: google_cloud_longrunning::model::GetOperationRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;

    async fn cancel_operation(
        &self,
        req: google_cloud_longrunning::model::CancelOperationRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<()>>;

    fn get_polling_error_policy(
        &self,
        options: &crate::RequestOptions,
    ) -> std::sync::Arc<dyn google_cloud_gax::polling_error_policy::PollingErrorPolicy>;

    fn get_polling_backoff_policy(
        &self,
        options: &crate::RequestOptions,
    ) -> std::sync::Arc<dyn google_cloud_gax::polling_backoff_policy::PollingBackoffPolicy>;
}

/// All implementations of [super::DataStoreService] also implement [DataStoreService].
#[cfg(feature = "data-store-service")]
#[async_trait::async_trait]
impl<T: super::DataStoreService> DataStoreService for T {
    /// Forwards the call to the implementation provided by `T`.
    async fn create_data_store(
        &self,
        req: crate::model::CreateDataStoreRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
        T::create_data_store(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn get_data_store(
        &self,
        req: crate::model::GetDataStoreRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::DataStore>> {
        T::get_data_store(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn list_data_stores(
        &self,
        req: crate::model::ListDataStoresRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::ListDataStoresResponse>> {
        T::list_data_stores(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn delete_data_store(
        &self,
        req: crate::model::DeleteDataStoreRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
        T::delete_data_store(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn update_data_store(
        &self,
        req: crate::model::UpdateDataStoreRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::DataStore>> {
        T::update_data_store(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn list_operations(
        &self,
        req: google_cloud_longrunning::model::ListOperationsRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::ListOperationsResponse>>
    {
        T::list_operations(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn get_operation(
        &self,
        req: google_cloud_longrunning::model::GetOperationRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
        T::get_operation(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn cancel_operation(
        &self,
        req: google_cloud_longrunning::model::CancelOperationRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<()>> {
        T::cancel_operation(self, req, options).await
    }

    fn get_polling_error_policy(
        &self,
        options: &crate::RequestOptions,
    ) -> std::sync::Arc<dyn google_cloud_gax::polling_error_policy::PollingErrorPolicy> {
        T::get_polling_error_policy(self, options)
    }

    fn get_polling_backoff_policy(
        &self,
        options: &crate::RequestOptions,
    ) -> std::sync::Arc<dyn google_cloud_gax::polling_backoff_policy::PollingBackoffPolicy> {
        T::get_polling_backoff_policy(self, options)
    }
}

/// A dyn-compatible, crate-private version of [super::DocumentService].
#[cfg(feature = "document-service")]
#[async_trait::async_trait]
pub trait DocumentService: std::fmt::Debug + Send + Sync {
    async fn get_document(
        &self,
        req: crate::model::GetDocumentRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::Document>>;

    async fn list_documents(
        &self,
        req: crate::model::ListDocumentsRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::ListDocumentsResponse>>;

    async fn create_document(
        &self,
        req: crate::model::CreateDocumentRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::Document>>;

    async fn update_document(
        &self,
        req: crate::model::UpdateDocumentRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::Document>>;

    async fn delete_document(
        &self,
        req: crate::model::DeleteDocumentRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<()>>;

    async fn import_documents(
        &self,
        req: crate::model::ImportDocumentsRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;

    async fn purge_documents(
        &self,
        req: crate::model::PurgeDocumentsRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;

    async fn batch_get_documents_metadata(
        &self,
        req: crate::model::BatchGetDocumentsMetadataRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::BatchGetDocumentsMetadataResponse>>;

    async fn list_operations(
        &self,
        req: google_cloud_longrunning::model::ListOperationsRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::ListOperationsResponse>>;

    async fn get_operation(
        &self,
        req: google_cloud_longrunning::model::GetOperationRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;

    async fn cancel_operation(
        &self,
        req: google_cloud_longrunning::model::CancelOperationRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<()>>;

    fn get_polling_error_policy(
        &self,
        options: &crate::RequestOptions,
    ) -> std::sync::Arc<dyn google_cloud_gax::polling_error_policy::PollingErrorPolicy>;

    fn get_polling_backoff_policy(
        &self,
        options: &crate::RequestOptions,
    ) -> std::sync::Arc<dyn google_cloud_gax::polling_backoff_policy::PollingBackoffPolicy>;
}

/// All implementations of [super::DocumentService] also implement [DocumentService].
#[cfg(feature = "document-service")]
#[async_trait::async_trait]
impl<T: super::DocumentService> DocumentService for T {
    /// Forwards the call to the implementation provided by `T`.
    async fn get_document(
        &self,
        req: crate::model::GetDocumentRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::Document>> {
        T::get_document(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn list_documents(
        &self,
        req: crate::model::ListDocumentsRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::ListDocumentsResponse>> {
        T::list_documents(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn create_document(
        &self,
        req: crate::model::CreateDocumentRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::Document>> {
        T::create_document(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn update_document(
        &self,
        req: crate::model::UpdateDocumentRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::Document>> {
        T::update_document(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn delete_document(
        &self,
        req: crate::model::DeleteDocumentRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<()>> {
        T::delete_document(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn import_documents(
        &self,
        req: crate::model::ImportDocumentsRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
        T::import_documents(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn purge_documents(
        &self,
        req: crate::model::PurgeDocumentsRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
        T::purge_documents(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn batch_get_documents_metadata(
        &self,
        req: crate::model::BatchGetDocumentsMetadataRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::BatchGetDocumentsMetadataResponse>> {
        T::batch_get_documents_metadata(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn list_operations(
        &self,
        req: google_cloud_longrunning::model::ListOperationsRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::ListOperationsResponse>>
    {
        T::list_operations(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn get_operation(
        &self,
        req: google_cloud_longrunning::model::GetOperationRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
        T::get_operation(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn cancel_operation(
        &self,
        req: google_cloud_longrunning::model::CancelOperationRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<()>> {
        T::cancel_operation(self, req, options).await
    }

    fn get_polling_error_policy(
        &self,
        options: &crate::RequestOptions,
    ) -> std::sync::Arc<dyn google_cloud_gax::polling_error_policy::PollingErrorPolicy> {
        T::get_polling_error_policy(self, options)
    }

    fn get_polling_backoff_policy(
        &self,
        options: &crate::RequestOptions,
    ) -> std::sync::Arc<dyn google_cloud_gax::polling_backoff_policy::PollingBackoffPolicy> {
        T::get_polling_backoff_policy(self, options)
    }
}

/// A dyn-compatible, crate-private version of [super::EngineService].
#[cfg(feature = "engine-service")]
#[async_trait::async_trait]
pub trait EngineService: std::fmt::Debug + Send + Sync {
    async fn create_engine(
        &self,
        req: crate::model::CreateEngineRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;

    async fn delete_engine(
        &self,
        req: crate::model::DeleteEngineRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;

    async fn update_engine(
        &self,
        req: crate::model::UpdateEngineRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::Engine>>;

    async fn get_engine(
        &self,
        req: crate::model::GetEngineRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::Engine>>;

    async fn list_engines(
        &self,
        req: crate::model::ListEnginesRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::ListEnginesResponse>>;

    async fn list_operations(
        &self,
        req: google_cloud_longrunning::model::ListOperationsRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::ListOperationsResponse>>;

    async fn get_operation(
        &self,
        req: google_cloud_longrunning::model::GetOperationRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;

    async fn cancel_operation(
        &self,
        req: google_cloud_longrunning::model::CancelOperationRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<()>>;

    fn get_polling_error_policy(
        &self,
        options: &crate::RequestOptions,
    ) -> std::sync::Arc<dyn google_cloud_gax::polling_error_policy::PollingErrorPolicy>;

    fn get_polling_backoff_policy(
        &self,
        options: &crate::RequestOptions,
    ) -> std::sync::Arc<dyn google_cloud_gax::polling_backoff_policy::PollingBackoffPolicy>;
}

/// All implementations of [super::EngineService] also implement [EngineService].
#[cfg(feature = "engine-service")]
#[async_trait::async_trait]
impl<T: super::EngineService> EngineService for T {
    /// Forwards the call to the implementation provided by `T`.
    async fn create_engine(
        &self,
        req: crate::model::CreateEngineRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
        T::create_engine(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn delete_engine(
        &self,
        req: crate::model::DeleteEngineRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
        T::delete_engine(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn update_engine(
        &self,
        req: crate::model::UpdateEngineRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::Engine>> {
        T::update_engine(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn get_engine(
        &self,
        req: crate::model::GetEngineRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::Engine>> {
        T::get_engine(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn list_engines(
        &self,
        req: crate::model::ListEnginesRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::ListEnginesResponse>> {
        T::list_engines(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn list_operations(
        &self,
        req: google_cloud_longrunning::model::ListOperationsRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::ListOperationsResponse>>
    {
        T::list_operations(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn get_operation(
        &self,
        req: google_cloud_longrunning::model::GetOperationRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
        T::get_operation(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn cancel_operation(
        &self,
        req: google_cloud_longrunning::model::CancelOperationRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<()>> {
        T::cancel_operation(self, req, options).await
    }

    fn get_polling_error_policy(
        &self,
        options: &crate::RequestOptions,
    ) -> std::sync::Arc<dyn google_cloud_gax::polling_error_policy::PollingErrorPolicy> {
        T::get_polling_error_policy(self, options)
    }

    fn get_polling_backoff_policy(
        &self,
        options: &crate::RequestOptions,
    ) -> std::sync::Arc<dyn google_cloud_gax::polling_backoff_policy::PollingBackoffPolicy> {
        T::get_polling_backoff_policy(self, options)
    }
}

/// A dyn-compatible, crate-private version of [super::GroundedGenerationService].
#[cfg(feature = "grounded-generation-service")]
#[async_trait::async_trait]
pub trait GroundedGenerationService: std::fmt::Debug + Send + Sync {
    async fn generate_grounded_content(
        &self,
        req: crate::model::GenerateGroundedContentRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::GenerateGroundedContentResponse>>;

    async fn check_grounding(
        &self,
        req: crate::model::CheckGroundingRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::CheckGroundingResponse>>;

    async fn list_operations(
        &self,
        req: google_cloud_longrunning::model::ListOperationsRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::ListOperationsResponse>>;

    async fn get_operation(
        &self,
        req: google_cloud_longrunning::model::GetOperationRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;

    async fn cancel_operation(
        &self,
        req: google_cloud_longrunning::model::CancelOperationRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<()>>;
}

/// All implementations of [super::GroundedGenerationService] also implement [GroundedGenerationService].
#[cfg(feature = "grounded-generation-service")]
#[async_trait::async_trait]
impl<T: super::GroundedGenerationService> GroundedGenerationService for T {
    /// Forwards the call to the implementation provided by `T`.
    async fn generate_grounded_content(
        &self,
        req: crate::model::GenerateGroundedContentRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::GenerateGroundedContentResponse>> {
        T::generate_grounded_content(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn check_grounding(
        &self,
        req: crate::model::CheckGroundingRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::CheckGroundingResponse>> {
        T::check_grounding(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn list_operations(
        &self,
        req: google_cloud_longrunning::model::ListOperationsRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::ListOperationsResponse>>
    {
        T::list_operations(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn get_operation(
        &self,
        req: google_cloud_longrunning::model::GetOperationRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
        T::get_operation(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn cancel_operation(
        &self,
        req: google_cloud_longrunning::model::CancelOperationRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<()>> {
        T::cancel_operation(self, req, options).await
    }
}

/// A dyn-compatible, crate-private version of [super::IdentityMappingStoreService].
#[cfg(feature = "identity-mapping-store-service")]
#[async_trait::async_trait]
pub trait IdentityMappingStoreService: std::fmt::Debug + Send + Sync {
    async fn create_identity_mapping_store(
        &self,
        req: crate::model::CreateIdentityMappingStoreRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::IdentityMappingStore>>;

    async fn get_identity_mapping_store(
        &self,
        req: crate::model::GetIdentityMappingStoreRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::IdentityMappingStore>>;

    async fn delete_identity_mapping_store(
        &self,
        req: crate::model::DeleteIdentityMappingStoreRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;

    async fn import_identity_mappings(
        &self,
        req: crate::model::ImportIdentityMappingsRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;

    async fn purge_identity_mappings(
        &self,
        req: crate::model::PurgeIdentityMappingsRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;

    async fn list_identity_mappings(
        &self,
        req: crate::model::ListIdentityMappingsRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::ListIdentityMappingsResponse>>;

    async fn list_identity_mapping_stores(
        &self,
        req: crate::model::ListIdentityMappingStoresRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::ListIdentityMappingStoresResponse>>;

    async fn list_operations(
        &self,
        req: google_cloud_longrunning::model::ListOperationsRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::ListOperationsResponse>>;

    async fn get_operation(
        &self,
        req: google_cloud_longrunning::model::GetOperationRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;

    async fn cancel_operation(
        &self,
        req: google_cloud_longrunning::model::CancelOperationRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<()>>;

    fn get_polling_error_policy(
        &self,
        options: &crate::RequestOptions,
    ) -> std::sync::Arc<dyn google_cloud_gax::polling_error_policy::PollingErrorPolicy>;

    fn get_polling_backoff_policy(
        &self,
        options: &crate::RequestOptions,
    ) -> std::sync::Arc<dyn google_cloud_gax::polling_backoff_policy::PollingBackoffPolicy>;
}

/// All implementations of [super::IdentityMappingStoreService] also implement [IdentityMappingStoreService].
#[cfg(feature = "identity-mapping-store-service")]
#[async_trait::async_trait]
impl<T: super::IdentityMappingStoreService> IdentityMappingStoreService for T {
    /// Forwards the call to the implementation provided by `T`.
    async fn create_identity_mapping_store(
        &self,
        req: crate::model::CreateIdentityMappingStoreRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::IdentityMappingStore>> {
        T::create_identity_mapping_store(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn get_identity_mapping_store(
        &self,
        req: crate::model::GetIdentityMappingStoreRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::IdentityMappingStore>> {
        T::get_identity_mapping_store(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn delete_identity_mapping_store(
        &self,
        req: crate::model::DeleteIdentityMappingStoreRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
        T::delete_identity_mapping_store(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn import_identity_mappings(
        &self,
        req: crate::model::ImportIdentityMappingsRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
        T::import_identity_mappings(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn purge_identity_mappings(
        &self,
        req: crate::model::PurgeIdentityMappingsRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
        T::purge_identity_mappings(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn list_identity_mappings(
        &self,
        req: crate::model::ListIdentityMappingsRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::ListIdentityMappingsResponse>> {
        T::list_identity_mappings(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn list_identity_mapping_stores(
        &self,
        req: crate::model::ListIdentityMappingStoresRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::ListIdentityMappingStoresResponse>> {
        T::list_identity_mapping_stores(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn list_operations(
        &self,
        req: google_cloud_longrunning::model::ListOperationsRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::ListOperationsResponse>>
    {
        T::list_operations(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn get_operation(
        &self,
        req: google_cloud_longrunning::model::GetOperationRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
        T::get_operation(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn cancel_operation(
        &self,
        req: google_cloud_longrunning::model::CancelOperationRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<()>> {
        T::cancel_operation(self, req, options).await
    }

    fn get_polling_error_policy(
        &self,
        options: &crate::RequestOptions,
    ) -> std::sync::Arc<dyn google_cloud_gax::polling_error_policy::PollingErrorPolicy> {
        T::get_polling_error_policy(self, options)
    }

    fn get_polling_backoff_policy(
        &self,
        options: &crate::RequestOptions,
    ) -> std::sync::Arc<dyn google_cloud_gax::polling_backoff_policy::PollingBackoffPolicy> {
        T::get_polling_backoff_policy(self, options)
    }
}

/// A dyn-compatible, crate-private version of [super::ProjectService].
#[cfg(feature = "project-service")]
#[async_trait::async_trait]
pub trait ProjectService: std::fmt::Debug + Send + Sync {
    async fn provision_project(
        &self,
        req: crate::model::ProvisionProjectRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;

    async fn list_operations(
        &self,
        req: google_cloud_longrunning::model::ListOperationsRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::ListOperationsResponse>>;

    async fn get_operation(
        &self,
        req: google_cloud_longrunning::model::GetOperationRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;

    async fn cancel_operation(
        &self,
        req: google_cloud_longrunning::model::CancelOperationRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<()>>;

    fn get_polling_error_policy(
        &self,
        options: &crate::RequestOptions,
    ) -> std::sync::Arc<dyn google_cloud_gax::polling_error_policy::PollingErrorPolicy>;

    fn get_polling_backoff_policy(
        &self,
        options: &crate::RequestOptions,
    ) -> std::sync::Arc<dyn google_cloud_gax::polling_backoff_policy::PollingBackoffPolicy>;
}

/// All implementations of [super::ProjectService] also implement [ProjectService].
#[cfg(feature = "project-service")]
#[async_trait::async_trait]
impl<T: super::ProjectService> ProjectService for T {
    /// Forwards the call to the implementation provided by `T`.
    async fn provision_project(
        &self,
        req: crate::model::ProvisionProjectRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
        T::provision_project(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn list_operations(
        &self,
        req: google_cloud_longrunning::model::ListOperationsRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::ListOperationsResponse>>
    {
        T::list_operations(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn get_operation(
        &self,
        req: google_cloud_longrunning::model::GetOperationRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
        T::get_operation(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn cancel_operation(
        &self,
        req: google_cloud_longrunning::model::CancelOperationRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<()>> {
        T::cancel_operation(self, req, options).await
    }

    fn get_polling_error_policy(
        &self,
        options: &crate::RequestOptions,
    ) -> std::sync::Arc<dyn google_cloud_gax::polling_error_policy::PollingErrorPolicy> {
        T::get_polling_error_policy(self, options)
    }

    fn get_polling_backoff_policy(
        &self,
        options: &crate::RequestOptions,
    ) -> std::sync::Arc<dyn google_cloud_gax::polling_backoff_policy::PollingBackoffPolicy> {
        T::get_polling_backoff_policy(self, options)
    }
}

/// A dyn-compatible, crate-private version of [super::RankService].
#[cfg(feature = "rank-service")]
#[async_trait::async_trait]
pub trait RankService: std::fmt::Debug + Send + Sync {
    async fn rank(
        &self,
        req: crate::model::RankRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::RankResponse>>;

    async fn list_operations(
        &self,
        req: google_cloud_longrunning::model::ListOperationsRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::ListOperationsResponse>>;

    async fn get_operation(
        &self,
        req: google_cloud_longrunning::model::GetOperationRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;

    async fn cancel_operation(
        &self,
        req: google_cloud_longrunning::model::CancelOperationRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<()>>;
}

/// All implementations of [super::RankService] also implement [RankService].
#[cfg(feature = "rank-service")]
#[async_trait::async_trait]
impl<T: super::RankService> RankService for T {
    /// Forwards the call to the implementation provided by `T`.
    async fn rank(
        &self,
        req: crate::model::RankRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::RankResponse>> {
        T::rank(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn list_operations(
        &self,
        req: google_cloud_longrunning::model::ListOperationsRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::ListOperationsResponse>>
    {
        T::list_operations(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn get_operation(
        &self,
        req: google_cloud_longrunning::model::GetOperationRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
        T::get_operation(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn cancel_operation(
        &self,
        req: google_cloud_longrunning::model::CancelOperationRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<()>> {
        T::cancel_operation(self, req, options).await
    }
}

/// A dyn-compatible, crate-private version of [super::RecommendationService].
#[cfg(feature = "recommendation-service")]
#[async_trait::async_trait]
pub trait RecommendationService: std::fmt::Debug + Send + Sync {
    async fn recommend(
        &self,
        req: crate::model::RecommendRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::RecommendResponse>>;

    async fn list_operations(
        &self,
        req: google_cloud_longrunning::model::ListOperationsRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::ListOperationsResponse>>;

    async fn get_operation(
        &self,
        req: google_cloud_longrunning::model::GetOperationRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;

    async fn cancel_operation(
        &self,
        req: google_cloud_longrunning::model::CancelOperationRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<()>>;
}

/// All implementations of [super::RecommendationService] also implement [RecommendationService].
#[cfg(feature = "recommendation-service")]
#[async_trait::async_trait]
impl<T: super::RecommendationService> RecommendationService for T {
    /// Forwards the call to the implementation provided by `T`.
    async fn recommend(
        &self,
        req: crate::model::RecommendRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::RecommendResponse>> {
        T::recommend(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn list_operations(
        &self,
        req: google_cloud_longrunning::model::ListOperationsRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::ListOperationsResponse>>
    {
        T::list_operations(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn get_operation(
        &self,
        req: google_cloud_longrunning::model::GetOperationRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
        T::get_operation(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn cancel_operation(
        &self,
        req: google_cloud_longrunning::model::CancelOperationRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<()>> {
        T::cancel_operation(self, req, options).await
    }
}

/// A dyn-compatible, crate-private version of [super::SchemaService].
#[cfg(feature = "schema-service")]
#[async_trait::async_trait]
pub trait SchemaService: std::fmt::Debug + Send + Sync {
    async fn get_schema(
        &self,
        req: crate::model::GetSchemaRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::Schema>>;

    async fn list_schemas(
        &self,
        req: crate::model::ListSchemasRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::ListSchemasResponse>>;

    async fn create_schema(
        &self,
        req: crate::model::CreateSchemaRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;

    async fn update_schema(
        &self,
        req: crate::model::UpdateSchemaRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;

    async fn delete_schema(
        &self,
        req: crate::model::DeleteSchemaRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;

    async fn list_operations(
        &self,
        req: google_cloud_longrunning::model::ListOperationsRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::ListOperationsResponse>>;

    async fn get_operation(
        &self,
        req: google_cloud_longrunning::model::GetOperationRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;

    async fn cancel_operation(
        &self,
        req: google_cloud_longrunning::model::CancelOperationRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<()>>;

    fn get_polling_error_policy(
        &self,
        options: &crate::RequestOptions,
    ) -> std::sync::Arc<dyn google_cloud_gax::polling_error_policy::PollingErrorPolicy>;

    fn get_polling_backoff_policy(
        &self,
        options: &crate::RequestOptions,
    ) -> std::sync::Arc<dyn google_cloud_gax::polling_backoff_policy::PollingBackoffPolicy>;
}

/// All implementations of [super::SchemaService] also implement [SchemaService].
#[cfg(feature = "schema-service")]
#[async_trait::async_trait]
impl<T: super::SchemaService> SchemaService for T {
    /// Forwards the call to the implementation provided by `T`.
    async fn get_schema(
        &self,
        req: crate::model::GetSchemaRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::Schema>> {
        T::get_schema(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn list_schemas(
        &self,
        req: crate::model::ListSchemasRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::ListSchemasResponse>> {
        T::list_schemas(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn create_schema(
        &self,
        req: crate::model::CreateSchemaRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
        T::create_schema(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn update_schema(
        &self,
        req: crate::model::UpdateSchemaRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
        T::update_schema(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn delete_schema(
        &self,
        req: crate::model::DeleteSchemaRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
        T::delete_schema(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn list_operations(
        &self,
        req: google_cloud_longrunning::model::ListOperationsRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::ListOperationsResponse>>
    {
        T::list_operations(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn get_operation(
        &self,
        req: google_cloud_longrunning::model::GetOperationRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
        T::get_operation(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn cancel_operation(
        &self,
        req: google_cloud_longrunning::model::CancelOperationRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<()>> {
        T::cancel_operation(self, req, options).await
    }

    fn get_polling_error_policy(
        &self,
        options: &crate::RequestOptions,
    ) -> std::sync::Arc<dyn google_cloud_gax::polling_error_policy::PollingErrorPolicy> {
        T::get_polling_error_policy(self, options)
    }

    fn get_polling_backoff_policy(
        &self,
        options: &crate::RequestOptions,
    ) -> std::sync::Arc<dyn google_cloud_gax::polling_backoff_policy::PollingBackoffPolicy> {
        T::get_polling_backoff_policy(self, options)
    }
}

/// A dyn-compatible, crate-private version of [super::SearchService].
#[cfg(feature = "search-service")]
#[async_trait::async_trait]
pub trait SearchService: std::fmt::Debug + Send + Sync {
    async fn search(
        &self,
        req: crate::model::SearchRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::SearchResponse>>;

    async fn search_lite(
        &self,
        req: crate::model::SearchRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::SearchResponse>>;

    async fn list_operations(
        &self,
        req: google_cloud_longrunning::model::ListOperationsRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::ListOperationsResponse>>;

    async fn get_operation(
        &self,
        req: google_cloud_longrunning::model::GetOperationRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;

    async fn cancel_operation(
        &self,
        req: google_cloud_longrunning::model::CancelOperationRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<()>>;
}

/// All implementations of [super::SearchService] also implement [SearchService].
#[cfg(feature = "search-service")]
#[async_trait::async_trait]
impl<T: super::SearchService> SearchService for T {
    /// Forwards the call to the implementation provided by `T`.
    async fn search(
        &self,
        req: crate::model::SearchRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::SearchResponse>> {
        T::search(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn search_lite(
        &self,
        req: crate::model::SearchRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::SearchResponse>> {
        T::search_lite(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn list_operations(
        &self,
        req: google_cloud_longrunning::model::ListOperationsRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::ListOperationsResponse>>
    {
        T::list_operations(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn get_operation(
        &self,
        req: google_cloud_longrunning::model::GetOperationRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
        T::get_operation(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn cancel_operation(
        &self,
        req: google_cloud_longrunning::model::CancelOperationRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<()>> {
        T::cancel_operation(self, req, options).await
    }
}

/// A dyn-compatible, crate-private version of [super::SearchTuningService].
#[cfg(feature = "search-tuning-service")]
#[async_trait::async_trait]
pub trait SearchTuningService: std::fmt::Debug + Send + Sync {
    async fn train_custom_model(
        &self,
        req: crate::model::TrainCustomModelRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;

    async fn list_custom_models(
        &self,
        req: crate::model::ListCustomModelsRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::ListCustomModelsResponse>>;

    async fn list_operations(
        &self,
        req: google_cloud_longrunning::model::ListOperationsRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::ListOperationsResponse>>;

    async fn get_operation(
        &self,
        req: google_cloud_longrunning::model::GetOperationRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;

    async fn cancel_operation(
        &self,
        req: google_cloud_longrunning::model::CancelOperationRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<()>>;

    fn get_polling_error_policy(
        &self,
        options: &crate::RequestOptions,
    ) -> std::sync::Arc<dyn google_cloud_gax::polling_error_policy::PollingErrorPolicy>;

    fn get_polling_backoff_policy(
        &self,
        options: &crate::RequestOptions,
    ) -> std::sync::Arc<dyn google_cloud_gax::polling_backoff_policy::PollingBackoffPolicy>;
}

/// All implementations of [super::SearchTuningService] also implement [SearchTuningService].
#[cfg(feature = "search-tuning-service")]
#[async_trait::async_trait]
impl<T: super::SearchTuningService> SearchTuningService for T {
    /// Forwards the call to the implementation provided by `T`.
    async fn train_custom_model(
        &self,
        req: crate::model::TrainCustomModelRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
        T::train_custom_model(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn list_custom_models(
        &self,
        req: crate::model::ListCustomModelsRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::ListCustomModelsResponse>> {
        T::list_custom_models(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn list_operations(
        &self,
        req: google_cloud_longrunning::model::ListOperationsRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::ListOperationsResponse>>
    {
        T::list_operations(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn get_operation(
        &self,
        req: google_cloud_longrunning::model::GetOperationRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
        T::get_operation(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn cancel_operation(
        &self,
        req: google_cloud_longrunning::model::CancelOperationRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<()>> {
        T::cancel_operation(self, req, options).await
    }

    fn get_polling_error_policy(
        &self,
        options: &crate::RequestOptions,
    ) -> std::sync::Arc<dyn google_cloud_gax::polling_error_policy::PollingErrorPolicy> {
        T::get_polling_error_policy(self, options)
    }

    fn get_polling_backoff_policy(
        &self,
        options: &crate::RequestOptions,
    ) -> std::sync::Arc<dyn google_cloud_gax::polling_backoff_policy::PollingBackoffPolicy> {
        T::get_polling_backoff_policy(self, options)
    }
}

/// A dyn-compatible, crate-private version of [super::ServingConfigService].
#[cfg(feature = "serving-config-service")]
#[async_trait::async_trait]
pub trait ServingConfigService: std::fmt::Debug + Send + Sync {
    async fn update_serving_config(
        &self,
        req: crate::model::UpdateServingConfigRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::ServingConfig>>;

    async fn list_operations(
        &self,
        req: google_cloud_longrunning::model::ListOperationsRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::ListOperationsResponse>>;

    async fn get_operation(
        &self,
        req: google_cloud_longrunning::model::GetOperationRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;

    async fn cancel_operation(
        &self,
        req: google_cloud_longrunning::model::CancelOperationRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<()>>;
}

/// All implementations of [super::ServingConfigService] also implement [ServingConfigService].
#[cfg(feature = "serving-config-service")]
#[async_trait::async_trait]
impl<T: super::ServingConfigService> ServingConfigService for T {
    /// Forwards the call to the implementation provided by `T`.
    async fn update_serving_config(
        &self,
        req: crate::model::UpdateServingConfigRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::ServingConfig>> {
        T::update_serving_config(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn list_operations(
        &self,
        req: google_cloud_longrunning::model::ListOperationsRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::ListOperationsResponse>>
    {
        T::list_operations(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn get_operation(
        &self,
        req: google_cloud_longrunning::model::GetOperationRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
        T::get_operation(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn cancel_operation(
        &self,
        req: google_cloud_longrunning::model::CancelOperationRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<()>> {
        T::cancel_operation(self, req, options).await
    }
}

/// A dyn-compatible, crate-private version of [super::SessionService].
#[cfg(feature = "session-service")]
#[async_trait::async_trait]
pub trait SessionService: std::fmt::Debug + Send + Sync {
    async fn create_session(
        &self,
        req: crate::model::CreateSessionRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::Session>>;

    async fn delete_session(
        &self,
        req: crate::model::DeleteSessionRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<()>>;

    async fn update_session(
        &self,
        req: crate::model::UpdateSessionRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::Session>>;

    async fn get_session(
        &self,
        req: crate::model::GetSessionRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::Session>>;

    async fn list_sessions(
        &self,
        req: crate::model::ListSessionsRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::ListSessionsResponse>>;

    async fn list_operations(
        &self,
        req: google_cloud_longrunning::model::ListOperationsRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::ListOperationsResponse>>;

    async fn get_operation(
        &self,
        req: google_cloud_longrunning::model::GetOperationRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;

    async fn cancel_operation(
        &self,
        req: google_cloud_longrunning::model::CancelOperationRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<()>>;
}

/// All implementations of [super::SessionService] also implement [SessionService].
#[cfg(feature = "session-service")]
#[async_trait::async_trait]
impl<T: super::SessionService> SessionService for T {
    /// Forwards the call to the implementation provided by `T`.
    async fn create_session(
        &self,
        req: crate::model::CreateSessionRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::Session>> {
        T::create_session(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn delete_session(
        &self,
        req: crate::model::DeleteSessionRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<()>> {
        T::delete_session(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn update_session(
        &self,
        req: crate::model::UpdateSessionRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::Session>> {
        T::update_session(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn get_session(
        &self,
        req: crate::model::GetSessionRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::Session>> {
        T::get_session(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn list_sessions(
        &self,
        req: crate::model::ListSessionsRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::ListSessionsResponse>> {
        T::list_sessions(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn list_operations(
        &self,
        req: google_cloud_longrunning::model::ListOperationsRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::ListOperationsResponse>>
    {
        T::list_operations(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn get_operation(
        &self,
        req: google_cloud_longrunning::model::GetOperationRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
        T::get_operation(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn cancel_operation(
        &self,
        req: google_cloud_longrunning::model::CancelOperationRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<()>> {
        T::cancel_operation(self, req, options).await
    }
}

/// A dyn-compatible, crate-private version of [super::SiteSearchEngineService].
#[cfg(feature = "site-search-engine-service")]
#[async_trait::async_trait]
pub trait SiteSearchEngineService: std::fmt::Debug + Send + Sync {
    async fn get_site_search_engine(
        &self,
        req: crate::model::GetSiteSearchEngineRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::SiteSearchEngine>>;

    async fn create_target_site(
        &self,
        req: crate::model::CreateTargetSiteRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;

    async fn batch_create_target_sites(
        &self,
        req: crate::model::BatchCreateTargetSitesRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;

    async fn get_target_site(
        &self,
        req: crate::model::GetTargetSiteRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::TargetSite>>;

    async fn update_target_site(
        &self,
        req: crate::model::UpdateTargetSiteRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;

    async fn delete_target_site(
        &self,
        req: crate::model::DeleteTargetSiteRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;

    async fn list_target_sites(
        &self,
        req: crate::model::ListTargetSitesRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::ListTargetSitesResponse>>;

    async fn create_sitemap(
        &self,
        req: crate::model::CreateSitemapRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;

    async fn delete_sitemap(
        &self,
        req: crate::model::DeleteSitemapRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;

    async fn fetch_sitemaps(
        &self,
        req: crate::model::FetchSitemapsRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::FetchSitemapsResponse>>;

    async fn enable_advanced_site_search(
        &self,
        req: crate::model::EnableAdvancedSiteSearchRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;

    async fn disable_advanced_site_search(
        &self,
        req: crate::model::DisableAdvancedSiteSearchRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;

    async fn recrawl_uris(
        &self,
        req: crate::model::RecrawlUrisRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;

    async fn batch_verify_target_sites(
        &self,
        req: crate::model::BatchVerifyTargetSitesRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;

    async fn fetch_domain_verification_status(
        &self,
        req: crate::model::FetchDomainVerificationStatusRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::FetchDomainVerificationStatusResponse>>;

    async fn list_operations(
        &self,
        req: google_cloud_longrunning::model::ListOperationsRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::ListOperationsResponse>>;

    async fn get_operation(
        &self,
        req: google_cloud_longrunning::model::GetOperationRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;

    async fn cancel_operation(
        &self,
        req: google_cloud_longrunning::model::CancelOperationRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<()>>;

    fn get_polling_error_policy(
        &self,
        options: &crate::RequestOptions,
    ) -> std::sync::Arc<dyn google_cloud_gax::polling_error_policy::PollingErrorPolicy>;

    fn get_polling_backoff_policy(
        &self,
        options: &crate::RequestOptions,
    ) -> std::sync::Arc<dyn google_cloud_gax::polling_backoff_policy::PollingBackoffPolicy>;
}

/// All implementations of [super::SiteSearchEngineService] also implement [SiteSearchEngineService].
#[cfg(feature = "site-search-engine-service")]
#[async_trait::async_trait]
impl<T: super::SiteSearchEngineService> SiteSearchEngineService for T {
    /// Forwards the call to the implementation provided by `T`.
    async fn get_site_search_engine(
        &self,
        req: crate::model::GetSiteSearchEngineRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::SiteSearchEngine>> {
        T::get_site_search_engine(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn create_target_site(
        &self,
        req: crate::model::CreateTargetSiteRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
        T::create_target_site(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn batch_create_target_sites(
        &self,
        req: crate::model::BatchCreateTargetSitesRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
        T::batch_create_target_sites(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn get_target_site(
        &self,
        req: crate::model::GetTargetSiteRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::TargetSite>> {
        T::get_target_site(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn update_target_site(
        &self,
        req: crate::model::UpdateTargetSiteRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
        T::update_target_site(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn delete_target_site(
        &self,
        req: crate::model::DeleteTargetSiteRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
        T::delete_target_site(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn list_target_sites(
        &self,
        req: crate::model::ListTargetSitesRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::ListTargetSitesResponse>> {
        T::list_target_sites(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn create_sitemap(
        &self,
        req: crate::model::CreateSitemapRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
        T::create_sitemap(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn delete_sitemap(
        &self,
        req: crate::model::DeleteSitemapRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
        T::delete_sitemap(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn fetch_sitemaps(
        &self,
        req: crate::model::FetchSitemapsRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::FetchSitemapsResponse>> {
        T::fetch_sitemaps(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn enable_advanced_site_search(
        &self,
        req: crate::model::EnableAdvancedSiteSearchRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
        T::enable_advanced_site_search(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn disable_advanced_site_search(
        &self,
        req: crate::model::DisableAdvancedSiteSearchRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
        T::disable_advanced_site_search(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn recrawl_uris(
        &self,
        req: crate::model::RecrawlUrisRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
        T::recrawl_uris(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn batch_verify_target_sites(
        &self,
        req: crate::model::BatchVerifyTargetSitesRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
        T::batch_verify_target_sites(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn fetch_domain_verification_status(
        &self,
        req: crate::model::FetchDomainVerificationStatusRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::FetchDomainVerificationStatusResponse>> {
        T::fetch_domain_verification_status(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn list_operations(
        &self,
        req: google_cloud_longrunning::model::ListOperationsRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::ListOperationsResponse>>
    {
        T::list_operations(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn get_operation(
        &self,
        req: google_cloud_longrunning::model::GetOperationRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
        T::get_operation(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn cancel_operation(
        &self,
        req: google_cloud_longrunning::model::CancelOperationRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<()>> {
        T::cancel_operation(self, req, options).await
    }

    fn get_polling_error_policy(
        &self,
        options: &crate::RequestOptions,
    ) -> std::sync::Arc<dyn google_cloud_gax::polling_error_policy::PollingErrorPolicy> {
        T::get_polling_error_policy(self, options)
    }

    fn get_polling_backoff_policy(
        &self,
        options: &crate::RequestOptions,
    ) -> std::sync::Arc<dyn google_cloud_gax::polling_backoff_policy::PollingBackoffPolicy> {
        T::get_polling_backoff_policy(self, options)
    }
}

/// A dyn-compatible, crate-private version of [super::UserEventService].
#[cfg(feature = "user-event-service")]
#[async_trait::async_trait]
pub trait UserEventService: std::fmt::Debug + Send + Sync {
    async fn write_user_event(
        &self,
        req: crate::model::WriteUserEventRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::UserEvent>>;

    async fn collect_user_event(
        &self,
        req: crate::model::CollectUserEventRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_api::model::HttpBody>>;

    async fn purge_user_events(
        &self,
        req: crate::model::PurgeUserEventsRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;

    async fn import_user_events(
        &self,
        req: crate::model::ImportUserEventsRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;

    async fn list_operations(
        &self,
        req: google_cloud_longrunning::model::ListOperationsRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::ListOperationsResponse>>;

    async fn get_operation(
        &self,
        req: google_cloud_longrunning::model::GetOperationRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;

    async fn cancel_operation(
        &self,
        req: google_cloud_longrunning::model::CancelOperationRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<()>>;

    fn get_polling_error_policy(
        &self,
        options: &crate::RequestOptions,
    ) -> std::sync::Arc<dyn google_cloud_gax::polling_error_policy::PollingErrorPolicy>;

    fn get_polling_backoff_policy(
        &self,
        options: &crate::RequestOptions,
    ) -> std::sync::Arc<dyn google_cloud_gax::polling_backoff_policy::PollingBackoffPolicy>;
}

/// All implementations of [super::UserEventService] also implement [UserEventService].
#[cfg(feature = "user-event-service")]
#[async_trait::async_trait]
impl<T: super::UserEventService> UserEventService for T {
    /// Forwards the call to the implementation provided by `T`.
    async fn write_user_event(
        &self,
        req: crate::model::WriteUserEventRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::UserEvent>> {
        T::write_user_event(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn collect_user_event(
        &self,
        req: crate::model::CollectUserEventRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_api::model::HttpBody>> {
        T::collect_user_event(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn purge_user_events(
        &self,
        req: crate::model::PurgeUserEventsRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
        T::purge_user_events(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn import_user_events(
        &self,
        req: crate::model::ImportUserEventsRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
        T::import_user_events(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn list_operations(
        &self,
        req: google_cloud_longrunning::model::ListOperationsRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::ListOperationsResponse>>
    {
        T::list_operations(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn get_operation(
        &self,
        req: google_cloud_longrunning::model::GetOperationRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
        T::get_operation(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn cancel_operation(
        &self,
        req: google_cloud_longrunning::model::CancelOperationRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<()>> {
        T::cancel_operation(self, req, options).await
    }

    fn get_polling_error_policy(
        &self,
        options: &crate::RequestOptions,
    ) -> std::sync::Arc<dyn google_cloud_gax::polling_error_policy::PollingErrorPolicy> {
        T::get_polling_error_policy(self, options)
    }

    fn get_polling_backoff_policy(
        &self,
        options: &crate::RequestOptions,
    ) -> std::sync::Arc<dyn google_cloud_gax::polling_backoff_policy::PollingBackoffPolicy> {
        T::get_polling_backoff_policy(self, options)
    }
}

/// A dyn-compatible, crate-private version of [super::UserLicenseService].
#[cfg(feature = "user-license-service")]
#[async_trait::async_trait]
pub trait UserLicenseService: std::fmt::Debug + Send + Sync {
    async fn list_user_licenses(
        &self,
        req: crate::model::ListUserLicensesRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::ListUserLicensesResponse>>;

    async fn batch_update_user_licenses(
        &self,
        req: crate::model::BatchUpdateUserLicensesRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;

    async fn list_operations(
        &self,
        req: google_cloud_longrunning::model::ListOperationsRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::ListOperationsResponse>>;

    async fn get_operation(
        &self,
        req: google_cloud_longrunning::model::GetOperationRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;

    async fn cancel_operation(
        &self,
        req: google_cloud_longrunning::model::CancelOperationRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<()>>;

    fn get_polling_error_policy(
        &self,
        options: &crate::RequestOptions,
    ) -> std::sync::Arc<dyn google_cloud_gax::polling_error_policy::PollingErrorPolicy>;

    fn get_polling_backoff_policy(
        &self,
        options: &crate::RequestOptions,
    ) -> std::sync::Arc<dyn google_cloud_gax::polling_backoff_policy::PollingBackoffPolicy>;
}

/// All implementations of [super::UserLicenseService] also implement [UserLicenseService].
#[cfg(feature = "user-license-service")]
#[async_trait::async_trait]
impl<T: super::UserLicenseService> UserLicenseService for T {
    /// Forwards the call to the implementation provided by `T`.
    async fn list_user_licenses(
        &self,
        req: crate::model::ListUserLicensesRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<crate::model::ListUserLicensesResponse>> {
        T::list_user_licenses(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn batch_update_user_licenses(
        &self,
        req: crate::model::BatchUpdateUserLicensesRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
        T::batch_update_user_licenses(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn list_operations(
        &self,
        req: google_cloud_longrunning::model::ListOperationsRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::ListOperationsResponse>>
    {
        T::list_operations(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn get_operation(
        &self,
        req: google_cloud_longrunning::model::GetOperationRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
        T::get_operation(self, req, options).await
    }

    /// Forwards the call to the implementation provided by `T`.
    async fn cancel_operation(
        &self,
        req: google_cloud_longrunning::model::CancelOperationRequest,
        options: crate::RequestOptions,
    ) -> crate::Result<crate::Response<()>> {
        T::cancel_operation(self, req, options).await
    }

    fn get_polling_error_policy(
        &self,
        options: &crate::RequestOptions,
    ) -> std::sync::Arc<dyn google_cloud_gax::polling_error_policy::PollingErrorPolicy> {
        T::get_polling_error_policy(self, options)
    }

    fn get_polling_backoff_policy(
        &self,
        options: &crate::RequestOptions,
    ) -> std::sync::Arc<dyn google_cloud_gax::polling_backoff_policy::PollingBackoffPolicy> {
        T::get_polling_backoff_policy(self, options)
    }
}