use crate::Result;
#[derive(Clone, Debug)]
pub struct CompanyService<T>
where
T: super::stub::CompanyService + std::fmt::Debug + Send + Sync,
{
inner: T,
}
impl<T> CompanyService<T>
where
T: super::stub::CompanyService + std::fmt::Debug + Send + Sync,
{
pub fn new(inner: T) -> Self {
Self { inner }
}
}
impl<T> super::stub::CompanyService for CompanyService<T>
where
T: super::stub::CompanyService + std::fmt::Debug + Send + Sync,
{
#[tracing::instrument(ret)]
async fn create_company(
&self,
req: crate::model::CreateCompanyRequest,
options: crate::RequestOptions,
) -> Result<crate::Response<crate::model::Company>> {
self.inner.create_company(req, options).await
}
#[tracing::instrument(ret)]
async fn get_company(
&self,
req: crate::model::GetCompanyRequest,
options: crate::RequestOptions,
) -> Result<crate::Response<crate::model::Company>> {
self.inner.get_company(req, options).await
}
#[tracing::instrument(ret)]
async fn update_company(
&self,
req: crate::model::UpdateCompanyRequest,
options: crate::RequestOptions,
) -> Result<crate::Response<crate::model::Company>> {
self.inner.update_company(req, options).await
}
#[tracing::instrument(ret)]
async fn delete_company(
&self,
req: crate::model::DeleteCompanyRequest,
options: crate::RequestOptions,
) -> Result<crate::Response<()>> {
self.inner.delete_company(req, options).await
}
#[tracing::instrument(ret)]
async fn list_companies(
&self,
req: crate::model::ListCompaniesRequest,
options: crate::RequestOptions,
) -> Result<crate::Response<crate::model::ListCompaniesResponse>> {
self.inner.list_companies(req, options).await
}
#[tracing::instrument(ret)]
async fn get_operation(
&self,
req: google_cloud_longrunning::model::GetOperationRequest,
options: crate::RequestOptions,
) -> Result<crate::Response<google_cloud_longrunning::model::Operation>> {
self.inner.get_operation(req, options).await
}
}
#[derive(Clone, Debug)]
pub struct Completion<T>
where
T: super::stub::Completion + std::fmt::Debug + Send + Sync,
{
inner: T,
}
impl<T> Completion<T>
where
T: super::stub::Completion + std::fmt::Debug + Send + Sync,
{
pub fn new(inner: T) -> Self {
Self { inner }
}
}
impl<T> super::stub::Completion for Completion<T>
where
T: super::stub::Completion + std::fmt::Debug + Send + Sync,
{
#[tracing::instrument(ret)]
async fn complete_query(
&self,
req: crate::model::CompleteQueryRequest,
options: crate::RequestOptions,
) -> Result<crate::Response<crate::model::CompleteQueryResponse>> {
self.inner.complete_query(req, options).await
}
#[tracing::instrument(ret)]
async fn get_operation(
&self,
req: google_cloud_longrunning::model::GetOperationRequest,
options: crate::RequestOptions,
) -> Result<crate::Response<google_cloud_longrunning::model::Operation>> {
self.inner.get_operation(req, options).await
}
}
#[derive(Clone, Debug)]
pub struct EventService<T>
where
T: super::stub::EventService + std::fmt::Debug + Send + Sync,
{
inner: T,
}
impl<T> EventService<T>
where
T: super::stub::EventService + std::fmt::Debug + Send + Sync,
{
pub fn new(inner: T) -> Self {
Self { inner }
}
}
impl<T> super::stub::EventService for EventService<T>
where
T: super::stub::EventService + std::fmt::Debug + Send + Sync,
{
#[tracing::instrument(ret)]
async fn create_client_event(
&self,
req: crate::model::CreateClientEventRequest,
options: crate::RequestOptions,
) -> Result<crate::Response<crate::model::ClientEvent>> {
self.inner.create_client_event(req, options).await
}
#[tracing::instrument(ret)]
async fn get_operation(
&self,
req: google_cloud_longrunning::model::GetOperationRequest,
options: crate::RequestOptions,
) -> Result<crate::Response<google_cloud_longrunning::model::Operation>> {
self.inner.get_operation(req, options).await
}
}
#[derive(Clone, Debug)]
pub struct JobService<T>
where
T: super::stub::JobService + std::fmt::Debug + Send + Sync,
{
inner: T,
}
impl<T> JobService<T>
where
T: super::stub::JobService + std::fmt::Debug + Send + Sync,
{
pub fn new(inner: T) -> Self {
Self { inner }
}
}
impl<T> super::stub::JobService for JobService<T>
where
T: super::stub::JobService + std::fmt::Debug + Send + Sync,
{
#[tracing::instrument(ret)]
async fn create_job(
&self,
req: crate::model::CreateJobRequest,
options: crate::RequestOptions,
) -> Result<crate::Response<crate::model::Job>> {
self.inner.create_job(req, options).await
}
#[tracing::instrument(ret)]
async fn batch_create_jobs(
&self,
req: crate::model::BatchCreateJobsRequest,
options: crate::RequestOptions,
) -> Result<crate::Response<google_cloud_longrunning::model::Operation>> {
self.inner.batch_create_jobs(req, options).await
}
#[tracing::instrument(ret)]
async fn get_job(
&self,
req: crate::model::GetJobRequest,
options: crate::RequestOptions,
) -> Result<crate::Response<crate::model::Job>> {
self.inner.get_job(req, options).await
}
#[tracing::instrument(ret)]
async fn update_job(
&self,
req: crate::model::UpdateJobRequest,
options: crate::RequestOptions,
) -> Result<crate::Response<crate::model::Job>> {
self.inner.update_job(req, options).await
}
#[tracing::instrument(ret)]
async fn batch_update_jobs(
&self,
req: crate::model::BatchUpdateJobsRequest,
options: crate::RequestOptions,
) -> Result<crate::Response<google_cloud_longrunning::model::Operation>> {
self.inner.batch_update_jobs(req, options).await
}
#[tracing::instrument(ret)]
async fn delete_job(
&self,
req: crate::model::DeleteJobRequest,
options: crate::RequestOptions,
) -> Result<crate::Response<()>> {
self.inner.delete_job(req, options).await
}
#[tracing::instrument(ret)]
async fn batch_delete_jobs(
&self,
req: crate::model::BatchDeleteJobsRequest,
options: crate::RequestOptions,
) -> Result<crate::Response<google_cloud_longrunning::model::Operation>> {
self.inner.batch_delete_jobs(req, options).await
}
#[tracing::instrument(ret)]
async fn list_jobs(
&self,
req: crate::model::ListJobsRequest,
options: crate::RequestOptions,
) -> Result<crate::Response<crate::model::ListJobsResponse>> {
self.inner.list_jobs(req, options).await
}
#[tracing::instrument(ret)]
async fn search_jobs(
&self,
req: crate::model::SearchJobsRequest,
options: crate::RequestOptions,
) -> Result<crate::Response<crate::model::SearchJobsResponse>> {
self.inner.search_jobs(req, options).await
}
#[tracing::instrument(ret)]
async fn search_jobs_for_alert(
&self,
req: crate::model::SearchJobsRequest,
options: crate::RequestOptions,
) -> Result<crate::Response<crate::model::SearchJobsResponse>> {
self.inner.search_jobs_for_alert(req, options).await
}
#[tracing::instrument(ret)]
async fn get_operation(
&self,
req: google_cloud_longrunning::model::GetOperationRequest,
options: crate::RequestOptions,
) -> Result<crate::Response<google_cloud_longrunning::model::Operation>> {
self.inner.get_operation(req, options).await
}
fn get_polling_error_policy(
&self,
options: &crate::RequestOptions,
) -> std::sync::Arc<dyn google_cloud_gax::polling_error_policy::PollingErrorPolicy> {
self.inner.get_polling_error_policy(options)
}
fn get_polling_backoff_policy(
&self,
options: &crate::RequestOptions,
) -> std::sync::Arc<dyn google_cloud_gax::polling_backoff_policy::PollingBackoffPolicy> {
self.inner.get_polling_backoff_policy(options)
}
}
#[derive(Clone, Debug)]
pub struct TenantService<T>
where
T: super::stub::TenantService + std::fmt::Debug + Send + Sync,
{
inner: T,
}
impl<T> TenantService<T>
where
T: super::stub::TenantService + std::fmt::Debug + Send + Sync,
{
pub fn new(inner: T) -> Self {
Self { inner }
}
}
impl<T> super::stub::TenantService for TenantService<T>
where
T: super::stub::TenantService + std::fmt::Debug + Send + Sync,
{
#[tracing::instrument(ret)]
async fn create_tenant(
&self,
req: crate::model::CreateTenantRequest,
options: crate::RequestOptions,
) -> Result<crate::Response<crate::model::Tenant>> {
self.inner.create_tenant(req, options).await
}
#[tracing::instrument(ret)]
async fn get_tenant(
&self,
req: crate::model::GetTenantRequest,
options: crate::RequestOptions,
) -> Result<crate::Response<crate::model::Tenant>> {
self.inner.get_tenant(req, options).await
}
#[tracing::instrument(ret)]
async fn update_tenant(
&self,
req: crate::model::UpdateTenantRequest,
options: crate::RequestOptions,
) -> Result<crate::Response<crate::model::Tenant>> {
self.inner.update_tenant(req, options).await
}
#[tracing::instrument(ret)]
async fn delete_tenant(
&self,
req: crate::model::DeleteTenantRequest,
options: crate::RequestOptions,
) -> Result<crate::Response<()>> {
self.inner.delete_tenant(req, options).await
}
#[tracing::instrument(ret)]
async fn list_tenants(
&self,
req: crate::model::ListTenantsRequest,
options: crate::RequestOptions,
) -> Result<crate::Response<crate::model::ListTenantsResponse>> {
self.inner.list_tenants(req, options).await
}
#[tracing::instrument(ret)]
async fn get_operation(
&self,
req: google_cloud_longrunning::model::GetOperationRequest,
options: crate::RequestOptions,
) -> Result<crate::Response<google_cloud_longrunning::model::Operation>> {
self.inner.get_operation(req, options).await
}
}