#[async_trait::async_trait]
pub trait DatastoreAdmin: std::fmt::Debug + Send + Sync {
async fn export_entities(
&self,
req: crate::model::ExportEntitiesRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;
async fn import_entities(
&self,
req: crate::model::ImportEntitiesRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;
async fn create_index(
&self,
req: crate::model::CreateIndexRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;
async fn delete_index(
&self,
req: crate::model::DeleteIndexRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;
async fn get_index(
&self,
req: crate::model::GetIndexRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::Index>>;
async fn list_indexes(
&self,
req: crate::model::ListIndexesRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::ListIndexesResponse>>;
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 delete_operation(
&self,
req: google_cloud_longrunning::model::DeleteOperationRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<()>>;
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>;
}
#[async_trait::async_trait]
impl<T: super::DatastoreAdmin> DatastoreAdmin for T {
async fn export_entities(
&self,
req: crate::model::ExportEntitiesRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
T::export_entities(self, req, options).await
}
async fn import_entities(
&self,
req: crate::model::ImportEntitiesRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
T::import_entities(self, req, options).await
}
async fn create_index(
&self,
req: crate::model::CreateIndexRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
T::create_index(self, req, options).await
}
async fn delete_index(
&self,
req: crate::model::DeleteIndexRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
T::delete_index(self, req, options).await
}
async fn get_index(
&self,
req: crate::model::GetIndexRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::Index>> {
T::get_index(self, req, options).await
}
async fn list_indexes(
&self,
req: crate::model::ListIndexesRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::ListIndexesResponse>> {
T::list_indexes(self, req, options).await
}
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
}
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
}
async fn delete_operation(
&self,
req: google_cloud_longrunning::model::DeleteOperationRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<()>> {
T::delete_operation(self, req, options).await
}
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)
}
}