google_cloud_dataproc_v1/
stub.rs

1// Copyright 2025 Google LLC
2//
3// Licensed under the Apache License, Version 2.0 (the "License");
4// you may not use this file except in compliance with the License.
5// You may obtain a copy of the License at
6//
7//     https://www.apache.org/licenses/LICENSE-2.0
8//
9// Unless required by applicable law or agreed to in writing, software
10// distributed under the License is distributed on an "AS IS" BASIS,
11// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12// See the License for the specific language governing permissions and
13// limitations under the License.
14//
15// Code generated by sidekick. DO NOT EDIT.
16
17//! Traits to mock the clients in this library.
18//!
19//! Application developers may need to mock the clients in this library to test
20//! how their application works with different (and sometimes hard to trigger)
21//! client and service behavior. Such test can define mocks implementing the
22//! trait(s) defined in this module, initialize the client with an instance of
23//! this mock in their tests, and verify their application responds as expected.
24
25#![allow(rustdoc::broken_intra_doc_links)]
26
27pub(crate) mod dynamic;
28
29/// Defines the trait used to implement [super::client::AutoscalingPolicyService].
30///
31/// Application developers may need to implement this trait to mock
32/// `client::AutoscalingPolicyService`.  In other use-cases, application developers only
33/// use `client::AutoscalingPolicyService` and need not be concerned with this trait or
34/// its implementations.
35///
36/// Services gain new RPCs routinely. Consequently, this trait gains new methods
37/// too. To avoid breaking applications the trait provides a default
38/// implementation of each method. Most of these implementations just return an
39/// error.
40pub trait AutoscalingPolicyService: std::fmt::Debug + Send + Sync {
41    /// Implements [super::client::AutoscalingPolicyService::create_autoscaling_policy].
42    fn create_autoscaling_policy(
43        &self,
44        _req: crate::model::CreateAutoscalingPolicyRequest,
45        _options: gax::options::RequestOptions,
46    ) -> impl std::future::Future<
47        Output = crate::Result<gax::response::Response<crate::model::AutoscalingPolicy>>,
48    > + Send {
49        gaxi::unimplemented::unimplemented_stub()
50    }
51
52    /// Implements [super::client::AutoscalingPolicyService::update_autoscaling_policy].
53    fn update_autoscaling_policy(
54        &self,
55        _req: crate::model::UpdateAutoscalingPolicyRequest,
56        _options: gax::options::RequestOptions,
57    ) -> impl std::future::Future<
58        Output = crate::Result<gax::response::Response<crate::model::AutoscalingPolicy>>,
59    > + Send {
60        gaxi::unimplemented::unimplemented_stub()
61    }
62
63    /// Implements [super::client::AutoscalingPolicyService::get_autoscaling_policy].
64    fn get_autoscaling_policy(
65        &self,
66        _req: crate::model::GetAutoscalingPolicyRequest,
67        _options: gax::options::RequestOptions,
68    ) -> impl std::future::Future<
69        Output = crate::Result<gax::response::Response<crate::model::AutoscalingPolicy>>,
70    > + Send {
71        gaxi::unimplemented::unimplemented_stub()
72    }
73
74    /// Implements [super::client::AutoscalingPolicyService::list_autoscaling_policies].
75    fn list_autoscaling_policies(
76        &self,
77        _req: crate::model::ListAutoscalingPoliciesRequest,
78        _options: gax::options::RequestOptions,
79    ) -> impl std::future::Future<
80        Output = crate::Result<
81            gax::response::Response<crate::model::ListAutoscalingPoliciesResponse>,
82        >,
83    > + Send {
84        gaxi::unimplemented::unimplemented_stub()
85    }
86
87    /// Implements [super::client::AutoscalingPolicyService::delete_autoscaling_policy].
88    fn delete_autoscaling_policy(
89        &self,
90        _req: crate::model::DeleteAutoscalingPolicyRequest,
91        _options: gax::options::RequestOptions,
92    ) -> impl std::future::Future<Output = crate::Result<gax::response::Response<()>>> + Send {
93        gaxi::unimplemented::unimplemented_stub()
94    }
95
96    /// Implements [super::client::AutoscalingPolicyService::set_iam_policy].
97    fn set_iam_policy(
98        &self,
99        _req: iam_v1::model::SetIamPolicyRequest,
100        _options: gax::options::RequestOptions,
101    ) -> impl std::future::Future<
102        Output = crate::Result<gax::response::Response<iam_v1::model::Policy>>,
103    > + Send {
104        gaxi::unimplemented::unimplemented_stub()
105    }
106
107    /// Implements [super::client::AutoscalingPolicyService::get_iam_policy].
108    fn get_iam_policy(
109        &self,
110        _req: iam_v1::model::GetIamPolicyRequest,
111        _options: gax::options::RequestOptions,
112    ) -> impl std::future::Future<
113        Output = crate::Result<gax::response::Response<iam_v1::model::Policy>>,
114    > + Send {
115        gaxi::unimplemented::unimplemented_stub()
116    }
117
118    /// Implements [super::client::AutoscalingPolicyService::test_iam_permissions].
119    fn test_iam_permissions(
120        &self,
121        _req: iam_v1::model::TestIamPermissionsRequest,
122        _options: gax::options::RequestOptions,
123    ) -> impl std::future::Future<
124        Output = crate::Result<gax::response::Response<iam_v1::model::TestIamPermissionsResponse>>,
125    > + Send {
126        gaxi::unimplemented::unimplemented_stub()
127    }
128
129    /// Implements [super::client::AutoscalingPolicyService::list_operations].
130    fn list_operations(
131        &self,
132        _req: longrunning::model::ListOperationsRequest,
133        _options: gax::options::RequestOptions,
134    ) -> impl std::future::Future<
135        Output = crate::Result<gax::response::Response<longrunning::model::ListOperationsResponse>>,
136    > + Send {
137        gaxi::unimplemented::unimplemented_stub()
138    }
139
140    /// Implements [super::client::AutoscalingPolicyService::get_operation].
141    fn get_operation(
142        &self,
143        _req: longrunning::model::GetOperationRequest,
144        _options: gax::options::RequestOptions,
145    ) -> impl std::future::Future<
146        Output = crate::Result<gax::response::Response<longrunning::model::Operation>>,
147    > + Send {
148        gaxi::unimplemented::unimplemented_stub()
149    }
150
151    /// Implements [super::client::AutoscalingPolicyService::delete_operation].
152    fn delete_operation(
153        &self,
154        _req: longrunning::model::DeleteOperationRequest,
155        _options: gax::options::RequestOptions,
156    ) -> impl std::future::Future<Output = crate::Result<gax::response::Response<()>>> + Send {
157        gaxi::unimplemented::unimplemented_stub()
158    }
159
160    /// Implements [super::client::AutoscalingPolicyService::cancel_operation].
161    fn cancel_operation(
162        &self,
163        _req: longrunning::model::CancelOperationRequest,
164        _options: gax::options::RequestOptions,
165    ) -> impl std::future::Future<Output = crate::Result<gax::response::Response<()>>> + Send {
166        gaxi::unimplemented::unimplemented_stub()
167    }
168}
169
170/// Defines the trait used to implement [super::client::BatchController].
171///
172/// Application developers may need to implement this trait to mock
173/// `client::BatchController`.  In other use-cases, application developers only
174/// use `client::BatchController` and need not be concerned with this trait or
175/// its implementations.
176///
177/// Services gain new RPCs routinely. Consequently, this trait gains new methods
178/// too. To avoid breaking applications the trait provides a default
179/// implementation of each method. Most of these implementations just return an
180/// error.
181pub trait BatchController: std::fmt::Debug + Send + Sync {
182    /// Implements [super::client::BatchController::create_batch].
183    fn create_batch(
184        &self,
185        _req: crate::model::CreateBatchRequest,
186        _options: gax::options::RequestOptions,
187    ) -> impl std::future::Future<
188        Output = crate::Result<gax::response::Response<longrunning::model::Operation>>,
189    > + Send {
190        gaxi::unimplemented::unimplemented_stub()
191    }
192
193    /// Implements [super::client::BatchController::get_batch].
194    fn get_batch(
195        &self,
196        _req: crate::model::GetBatchRequest,
197        _options: gax::options::RequestOptions,
198    ) -> impl std::future::Future<
199        Output = crate::Result<gax::response::Response<crate::model::Batch>>,
200    > + Send {
201        gaxi::unimplemented::unimplemented_stub()
202    }
203
204    /// Implements [super::client::BatchController::list_batches].
205    fn list_batches(
206        &self,
207        _req: crate::model::ListBatchesRequest,
208        _options: gax::options::RequestOptions,
209    ) -> impl std::future::Future<
210        Output = crate::Result<gax::response::Response<crate::model::ListBatchesResponse>>,
211    > + Send {
212        gaxi::unimplemented::unimplemented_stub()
213    }
214
215    /// Implements [super::client::BatchController::delete_batch].
216    fn delete_batch(
217        &self,
218        _req: crate::model::DeleteBatchRequest,
219        _options: gax::options::RequestOptions,
220    ) -> impl std::future::Future<Output = crate::Result<gax::response::Response<()>>> + Send {
221        gaxi::unimplemented::unimplemented_stub()
222    }
223
224    /// Implements [super::client::BatchController::set_iam_policy].
225    fn set_iam_policy(
226        &self,
227        _req: iam_v1::model::SetIamPolicyRequest,
228        _options: gax::options::RequestOptions,
229    ) -> impl std::future::Future<
230        Output = crate::Result<gax::response::Response<iam_v1::model::Policy>>,
231    > + Send {
232        gaxi::unimplemented::unimplemented_stub()
233    }
234
235    /// Implements [super::client::BatchController::get_iam_policy].
236    fn get_iam_policy(
237        &self,
238        _req: iam_v1::model::GetIamPolicyRequest,
239        _options: gax::options::RequestOptions,
240    ) -> impl std::future::Future<
241        Output = crate::Result<gax::response::Response<iam_v1::model::Policy>>,
242    > + Send {
243        gaxi::unimplemented::unimplemented_stub()
244    }
245
246    /// Implements [super::client::BatchController::test_iam_permissions].
247    fn test_iam_permissions(
248        &self,
249        _req: iam_v1::model::TestIamPermissionsRequest,
250        _options: gax::options::RequestOptions,
251    ) -> impl std::future::Future<
252        Output = crate::Result<gax::response::Response<iam_v1::model::TestIamPermissionsResponse>>,
253    > + Send {
254        gaxi::unimplemented::unimplemented_stub()
255    }
256
257    /// Implements [super::client::BatchController::list_operations].
258    fn list_operations(
259        &self,
260        _req: longrunning::model::ListOperationsRequest,
261        _options: gax::options::RequestOptions,
262    ) -> impl std::future::Future<
263        Output = crate::Result<gax::response::Response<longrunning::model::ListOperationsResponse>>,
264    > + Send {
265        gaxi::unimplemented::unimplemented_stub()
266    }
267
268    /// Implements [super::client::BatchController::get_operation].
269    fn get_operation(
270        &self,
271        _req: longrunning::model::GetOperationRequest,
272        _options: gax::options::RequestOptions,
273    ) -> impl std::future::Future<
274        Output = crate::Result<gax::response::Response<longrunning::model::Operation>>,
275    > + Send {
276        gaxi::unimplemented::unimplemented_stub()
277    }
278
279    /// Implements [super::client::BatchController::delete_operation].
280    fn delete_operation(
281        &self,
282        _req: longrunning::model::DeleteOperationRequest,
283        _options: gax::options::RequestOptions,
284    ) -> impl std::future::Future<Output = crate::Result<gax::response::Response<()>>> + Send {
285        gaxi::unimplemented::unimplemented_stub()
286    }
287
288    /// Implements [super::client::BatchController::cancel_operation].
289    fn cancel_operation(
290        &self,
291        _req: longrunning::model::CancelOperationRequest,
292        _options: gax::options::RequestOptions,
293    ) -> impl std::future::Future<Output = crate::Result<gax::response::Response<()>>> + Send {
294        gaxi::unimplemented::unimplemented_stub()
295    }
296
297    /// Returns the polling error policy.
298    ///
299    /// When mocking, this method is typically irrelevant. Do not try to verify
300    /// it is called by your mocks.
301    fn get_polling_error_policy(
302        &self,
303        _options: &gax::options::RequestOptions,
304    ) -> std::sync::Arc<dyn gax::polling_error_policy::PollingErrorPolicy> {
305        std::sync::Arc::new(gax::polling_error_policy::Aip194Strict)
306    }
307
308    /// Returns the polling backoff policy.
309    ///
310    /// When mocking, this method is typically irrelevant. Do not try to verify
311    /// it is called by your mocks.
312    fn get_polling_backoff_policy(
313        &self,
314        _options: &gax::options::RequestOptions,
315    ) -> std::sync::Arc<dyn gax::polling_backoff_policy::PollingBackoffPolicy> {
316        std::sync::Arc::new(gax::exponential_backoff::ExponentialBackoff::default())
317    }
318}
319
320/// Defines the trait used to implement [super::client::ClusterController].
321///
322/// Application developers may need to implement this trait to mock
323/// `client::ClusterController`.  In other use-cases, application developers only
324/// use `client::ClusterController` and need not be concerned with this trait or
325/// its implementations.
326///
327/// Services gain new RPCs routinely. Consequently, this trait gains new methods
328/// too. To avoid breaking applications the trait provides a default
329/// implementation of each method. Most of these implementations just return an
330/// error.
331pub trait ClusterController: std::fmt::Debug + Send + Sync {
332    /// Implements [super::client::ClusterController::create_cluster].
333    fn create_cluster(
334        &self,
335        _req: crate::model::CreateClusterRequest,
336        _options: gax::options::RequestOptions,
337    ) -> impl std::future::Future<
338        Output = crate::Result<gax::response::Response<longrunning::model::Operation>>,
339    > + Send {
340        gaxi::unimplemented::unimplemented_stub()
341    }
342
343    /// Implements [super::client::ClusterController::update_cluster].
344    fn update_cluster(
345        &self,
346        _req: crate::model::UpdateClusterRequest,
347        _options: gax::options::RequestOptions,
348    ) -> impl std::future::Future<
349        Output = crate::Result<gax::response::Response<longrunning::model::Operation>>,
350    > + Send {
351        gaxi::unimplemented::unimplemented_stub()
352    }
353
354    /// Implements [super::client::ClusterController::stop_cluster].
355    fn stop_cluster(
356        &self,
357        _req: crate::model::StopClusterRequest,
358        _options: gax::options::RequestOptions,
359    ) -> impl std::future::Future<
360        Output = crate::Result<gax::response::Response<longrunning::model::Operation>>,
361    > + Send {
362        gaxi::unimplemented::unimplemented_stub()
363    }
364
365    /// Implements [super::client::ClusterController::start_cluster].
366    fn start_cluster(
367        &self,
368        _req: crate::model::StartClusterRequest,
369        _options: gax::options::RequestOptions,
370    ) -> impl std::future::Future<
371        Output = crate::Result<gax::response::Response<longrunning::model::Operation>>,
372    > + Send {
373        gaxi::unimplemented::unimplemented_stub()
374    }
375
376    /// Implements [super::client::ClusterController::delete_cluster].
377    fn delete_cluster(
378        &self,
379        _req: crate::model::DeleteClusterRequest,
380        _options: gax::options::RequestOptions,
381    ) -> impl std::future::Future<
382        Output = crate::Result<gax::response::Response<longrunning::model::Operation>>,
383    > + Send {
384        gaxi::unimplemented::unimplemented_stub()
385    }
386
387    /// Implements [super::client::ClusterController::get_cluster].
388    fn get_cluster(
389        &self,
390        _req: crate::model::GetClusterRequest,
391        _options: gax::options::RequestOptions,
392    ) -> impl std::future::Future<
393        Output = crate::Result<gax::response::Response<crate::model::Cluster>>,
394    > + Send {
395        gaxi::unimplemented::unimplemented_stub()
396    }
397
398    /// Implements [super::client::ClusterController::list_clusters].
399    fn list_clusters(
400        &self,
401        _req: crate::model::ListClustersRequest,
402        _options: gax::options::RequestOptions,
403    ) -> impl std::future::Future<
404        Output = crate::Result<gax::response::Response<crate::model::ListClustersResponse>>,
405    > + Send {
406        gaxi::unimplemented::unimplemented_stub()
407    }
408
409    /// Implements [super::client::ClusterController::diagnose_cluster].
410    fn diagnose_cluster(
411        &self,
412        _req: crate::model::DiagnoseClusterRequest,
413        _options: gax::options::RequestOptions,
414    ) -> impl std::future::Future<
415        Output = crate::Result<gax::response::Response<longrunning::model::Operation>>,
416    > + Send {
417        gaxi::unimplemented::unimplemented_stub()
418    }
419
420    /// Implements [super::client::ClusterController::set_iam_policy].
421    fn set_iam_policy(
422        &self,
423        _req: iam_v1::model::SetIamPolicyRequest,
424        _options: gax::options::RequestOptions,
425    ) -> impl std::future::Future<
426        Output = crate::Result<gax::response::Response<iam_v1::model::Policy>>,
427    > + Send {
428        gaxi::unimplemented::unimplemented_stub()
429    }
430
431    /// Implements [super::client::ClusterController::get_iam_policy].
432    fn get_iam_policy(
433        &self,
434        _req: iam_v1::model::GetIamPolicyRequest,
435        _options: gax::options::RequestOptions,
436    ) -> impl std::future::Future<
437        Output = crate::Result<gax::response::Response<iam_v1::model::Policy>>,
438    > + Send {
439        gaxi::unimplemented::unimplemented_stub()
440    }
441
442    /// Implements [super::client::ClusterController::test_iam_permissions].
443    fn test_iam_permissions(
444        &self,
445        _req: iam_v1::model::TestIamPermissionsRequest,
446        _options: gax::options::RequestOptions,
447    ) -> impl std::future::Future<
448        Output = crate::Result<gax::response::Response<iam_v1::model::TestIamPermissionsResponse>>,
449    > + Send {
450        gaxi::unimplemented::unimplemented_stub()
451    }
452
453    /// Implements [super::client::ClusterController::list_operations].
454    fn list_operations(
455        &self,
456        _req: longrunning::model::ListOperationsRequest,
457        _options: gax::options::RequestOptions,
458    ) -> impl std::future::Future<
459        Output = crate::Result<gax::response::Response<longrunning::model::ListOperationsResponse>>,
460    > + Send {
461        gaxi::unimplemented::unimplemented_stub()
462    }
463
464    /// Implements [super::client::ClusterController::get_operation].
465    fn get_operation(
466        &self,
467        _req: longrunning::model::GetOperationRequest,
468        _options: gax::options::RequestOptions,
469    ) -> impl std::future::Future<
470        Output = crate::Result<gax::response::Response<longrunning::model::Operation>>,
471    > + Send {
472        gaxi::unimplemented::unimplemented_stub()
473    }
474
475    /// Implements [super::client::ClusterController::delete_operation].
476    fn delete_operation(
477        &self,
478        _req: longrunning::model::DeleteOperationRequest,
479        _options: gax::options::RequestOptions,
480    ) -> impl std::future::Future<Output = crate::Result<gax::response::Response<()>>> + Send {
481        gaxi::unimplemented::unimplemented_stub()
482    }
483
484    /// Implements [super::client::ClusterController::cancel_operation].
485    fn cancel_operation(
486        &self,
487        _req: longrunning::model::CancelOperationRequest,
488        _options: gax::options::RequestOptions,
489    ) -> impl std::future::Future<Output = crate::Result<gax::response::Response<()>>> + Send {
490        gaxi::unimplemented::unimplemented_stub()
491    }
492
493    /// Returns the polling error policy.
494    ///
495    /// When mocking, this method is typically irrelevant. Do not try to verify
496    /// it is called by your mocks.
497    fn get_polling_error_policy(
498        &self,
499        _options: &gax::options::RequestOptions,
500    ) -> std::sync::Arc<dyn gax::polling_error_policy::PollingErrorPolicy> {
501        std::sync::Arc::new(gax::polling_error_policy::Aip194Strict)
502    }
503
504    /// Returns the polling backoff policy.
505    ///
506    /// When mocking, this method is typically irrelevant. Do not try to verify
507    /// it is called by your mocks.
508    fn get_polling_backoff_policy(
509        &self,
510        _options: &gax::options::RequestOptions,
511    ) -> std::sync::Arc<dyn gax::polling_backoff_policy::PollingBackoffPolicy> {
512        std::sync::Arc::new(gax::exponential_backoff::ExponentialBackoff::default())
513    }
514}
515
516/// Defines the trait used to implement [super::client::JobController].
517///
518/// Application developers may need to implement this trait to mock
519/// `client::JobController`.  In other use-cases, application developers only
520/// use `client::JobController` and need not be concerned with this trait or
521/// its implementations.
522///
523/// Services gain new RPCs routinely. Consequently, this trait gains new methods
524/// too. To avoid breaking applications the trait provides a default
525/// implementation of each method. Most of these implementations just return an
526/// error.
527pub trait JobController: std::fmt::Debug + Send + Sync {
528    /// Implements [super::client::JobController::submit_job].
529    fn submit_job(
530        &self,
531        _req: crate::model::SubmitJobRequest,
532        _options: gax::options::RequestOptions,
533    ) -> impl std::future::Future<Output = crate::Result<gax::response::Response<crate::model::Job>>>
534    + Send {
535        gaxi::unimplemented::unimplemented_stub()
536    }
537
538    /// Implements [super::client::JobController::submit_job_as_operation].
539    fn submit_job_as_operation(
540        &self,
541        _req: crate::model::SubmitJobRequest,
542        _options: gax::options::RequestOptions,
543    ) -> impl std::future::Future<
544        Output = crate::Result<gax::response::Response<longrunning::model::Operation>>,
545    > + Send {
546        gaxi::unimplemented::unimplemented_stub()
547    }
548
549    /// Implements [super::client::JobController::get_job].
550    fn get_job(
551        &self,
552        _req: crate::model::GetJobRequest,
553        _options: gax::options::RequestOptions,
554    ) -> impl std::future::Future<Output = crate::Result<gax::response::Response<crate::model::Job>>>
555    + Send {
556        gaxi::unimplemented::unimplemented_stub()
557    }
558
559    /// Implements [super::client::JobController::list_jobs].
560    fn list_jobs(
561        &self,
562        _req: crate::model::ListJobsRequest,
563        _options: gax::options::RequestOptions,
564    ) -> impl std::future::Future<
565        Output = crate::Result<gax::response::Response<crate::model::ListJobsResponse>>,
566    > + Send {
567        gaxi::unimplemented::unimplemented_stub()
568    }
569
570    /// Implements [super::client::JobController::update_job].
571    fn update_job(
572        &self,
573        _req: crate::model::UpdateJobRequest,
574        _options: gax::options::RequestOptions,
575    ) -> impl std::future::Future<Output = crate::Result<gax::response::Response<crate::model::Job>>>
576    + Send {
577        gaxi::unimplemented::unimplemented_stub()
578    }
579
580    /// Implements [super::client::JobController::cancel_job].
581    fn cancel_job(
582        &self,
583        _req: crate::model::CancelJobRequest,
584        _options: gax::options::RequestOptions,
585    ) -> impl std::future::Future<Output = crate::Result<gax::response::Response<crate::model::Job>>>
586    + Send {
587        gaxi::unimplemented::unimplemented_stub()
588    }
589
590    /// Implements [super::client::JobController::delete_job].
591    fn delete_job(
592        &self,
593        _req: crate::model::DeleteJobRequest,
594        _options: gax::options::RequestOptions,
595    ) -> impl std::future::Future<Output = crate::Result<gax::response::Response<()>>> + Send {
596        gaxi::unimplemented::unimplemented_stub()
597    }
598
599    /// Implements [super::client::JobController::set_iam_policy].
600    fn set_iam_policy(
601        &self,
602        _req: iam_v1::model::SetIamPolicyRequest,
603        _options: gax::options::RequestOptions,
604    ) -> impl std::future::Future<
605        Output = crate::Result<gax::response::Response<iam_v1::model::Policy>>,
606    > + Send {
607        gaxi::unimplemented::unimplemented_stub()
608    }
609
610    /// Implements [super::client::JobController::get_iam_policy].
611    fn get_iam_policy(
612        &self,
613        _req: iam_v1::model::GetIamPolicyRequest,
614        _options: gax::options::RequestOptions,
615    ) -> impl std::future::Future<
616        Output = crate::Result<gax::response::Response<iam_v1::model::Policy>>,
617    > + Send {
618        gaxi::unimplemented::unimplemented_stub()
619    }
620
621    /// Implements [super::client::JobController::test_iam_permissions].
622    fn test_iam_permissions(
623        &self,
624        _req: iam_v1::model::TestIamPermissionsRequest,
625        _options: gax::options::RequestOptions,
626    ) -> impl std::future::Future<
627        Output = crate::Result<gax::response::Response<iam_v1::model::TestIamPermissionsResponse>>,
628    > + Send {
629        gaxi::unimplemented::unimplemented_stub()
630    }
631
632    /// Implements [super::client::JobController::list_operations].
633    fn list_operations(
634        &self,
635        _req: longrunning::model::ListOperationsRequest,
636        _options: gax::options::RequestOptions,
637    ) -> impl std::future::Future<
638        Output = crate::Result<gax::response::Response<longrunning::model::ListOperationsResponse>>,
639    > + Send {
640        gaxi::unimplemented::unimplemented_stub()
641    }
642
643    /// Implements [super::client::JobController::get_operation].
644    fn get_operation(
645        &self,
646        _req: longrunning::model::GetOperationRequest,
647        _options: gax::options::RequestOptions,
648    ) -> impl std::future::Future<
649        Output = crate::Result<gax::response::Response<longrunning::model::Operation>>,
650    > + Send {
651        gaxi::unimplemented::unimplemented_stub()
652    }
653
654    /// Implements [super::client::JobController::delete_operation].
655    fn delete_operation(
656        &self,
657        _req: longrunning::model::DeleteOperationRequest,
658        _options: gax::options::RequestOptions,
659    ) -> impl std::future::Future<Output = crate::Result<gax::response::Response<()>>> + Send {
660        gaxi::unimplemented::unimplemented_stub()
661    }
662
663    /// Implements [super::client::JobController::cancel_operation].
664    fn cancel_operation(
665        &self,
666        _req: longrunning::model::CancelOperationRequest,
667        _options: gax::options::RequestOptions,
668    ) -> impl std::future::Future<Output = crate::Result<gax::response::Response<()>>> + Send {
669        gaxi::unimplemented::unimplemented_stub()
670    }
671
672    /// Returns the polling error policy.
673    ///
674    /// When mocking, this method is typically irrelevant. Do not try to verify
675    /// it is called by your mocks.
676    fn get_polling_error_policy(
677        &self,
678        _options: &gax::options::RequestOptions,
679    ) -> std::sync::Arc<dyn gax::polling_error_policy::PollingErrorPolicy> {
680        std::sync::Arc::new(gax::polling_error_policy::Aip194Strict)
681    }
682
683    /// Returns the polling backoff policy.
684    ///
685    /// When mocking, this method is typically irrelevant. Do not try to verify
686    /// it is called by your mocks.
687    fn get_polling_backoff_policy(
688        &self,
689        _options: &gax::options::RequestOptions,
690    ) -> std::sync::Arc<dyn gax::polling_backoff_policy::PollingBackoffPolicy> {
691        std::sync::Arc::new(gax::exponential_backoff::ExponentialBackoff::default())
692    }
693}
694
695/// Defines the trait used to implement [super::client::NodeGroupController].
696///
697/// Application developers may need to implement this trait to mock
698/// `client::NodeGroupController`.  In other use-cases, application developers only
699/// use `client::NodeGroupController` and need not be concerned with this trait or
700/// its implementations.
701///
702/// Services gain new RPCs routinely. Consequently, this trait gains new methods
703/// too. To avoid breaking applications the trait provides a default
704/// implementation of each method. Most of these implementations just return an
705/// error.
706pub trait NodeGroupController: std::fmt::Debug + Send + Sync {
707    /// Implements [super::client::NodeGroupController::create_node_group].
708    fn create_node_group(
709        &self,
710        _req: crate::model::CreateNodeGroupRequest,
711        _options: gax::options::RequestOptions,
712    ) -> impl std::future::Future<
713        Output = crate::Result<gax::response::Response<longrunning::model::Operation>>,
714    > + Send {
715        gaxi::unimplemented::unimplemented_stub()
716    }
717
718    /// Implements [super::client::NodeGroupController::resize_node_group].
719    fn resize_node_group(
720        &self,
721        _req: crate::model::ResizeNodeGroupRequest,
722        _options: gax::options::RequestOptions,
723    ) -> impl std::future::Future<
724        Output = crate::Result<gax::response::Response<longrunning::model::Operation>>,
725    > + Send {
726        gaxi::unimplemented::unimplemented_stub()
727    }
728
729    /// Implements [super::client::NodeGroupController::get_node_group].
730    fn get_node_group(
731        &self,
732        _req: crate::model::GetNodeGroupRequest,
733        _options: gax::options::RequestOptions,
734    ) -> impl std::future::Future<
735        Output = crate::Result<gax::response::Response<crate::model::NodeGroup>>,
736    > + Send {
737        gaxi::unimplemented::unimplemented_stub()
738    }
739
740    /// Implements [super::client::NodeGroupController::set_iam_policy].
741    fn set_iam_policy(
742        &self,
743        _req: iam_v1::model::SetIamPolicyRequest,
744        _options: gax::options::RequestOptions,
745    ) -> impl std::future::Future<
746        Output = crate::Result<gax::response::Response<iam_v1::model::Policy>>,
747    > + Send {
748        gaxi::unimplemented::unimplemented_stub()
749    }
750
751    /// Implements [super::client::NodeGroupController::get_iam_policy].
752    fn get_iam_policy(
753        &self,
754        _req: iam_v1::model::GetIamPolicyRequest,
755        _options: gax::options::RequestOptions,
756    ) -> impl std::future::Future<
757        Output = crate::Result<gax::response::Response<iam_v1::model::Policy>>,
758    > + Send {
759        gaxi::unimplemented::unimplemented_stub()
760    }
761
762    /// Implements [super::client::NodeGroupController::test_iam_permissions].
763    fn test_iam_permissions(
764        &self,
765        _req: iam_v1::model::TestIamPermissionsRequest,
766        _options: gax::options::RequestOptions,
767    ) -> impl std::future::Future<
768        Output = crate::Result<gax::response::Response<iam_v1::model::TestIamPermissionsResponse>>,
769    > + Send {
770        gaxi::unimplemented::unimplemented_stub()
771    }
772
773    /// Implements [super::client::NodeGroupController::list_operations].
774    fn list_operations(
775        &self,
776        _req: longrunning::model::ListOperationsRequest,
777        _options: gax::options::RequestOptions,
778    ) -> impl std::future::Future<
779        Output = crate::Result<gax::response::Response<longrunning::model::ListOperationsResponse>>,
780    > + Send {
781        gaxi::unimplemented::unimplemented_stub()
782    }
783
784    /// Implements [super::client::NodeGroupController::get_operation].
785    fn get_operation(
786        &self,
787        _req: longrunning::model::GetOperationRequest,
788        _options: gax::options::RequestOptions,
789    ) -> impl std::future::Future<
790        Output = crate::Result<gax::response::Response<longrunning::model::Operation>>,
791    > + Send {
792        gaxi::unimplemented::unimplemented_stub()
793    }
794
795    /// Implements [super::client::NodeGroupController::delete_operation].
796    fn delete_operation(
797        &self,
798        _req: longrunning::model::DeleteOperationRequest,
799        _options: gax::options::RequestOptions,
800    ) -> impl std::future::Future<Output = crate::Result<gax::response::Response<()>>> + Send {
801        gaxi::unimplemented::unimplemented_stub()
802    }
803
804    /// Implements [super::client::NodeGroupController::cancel_operation].
805    fn cancel_operation(
806        &self,
807        _req: longrunning::model::CancelOperationRequest,
808        _options: gax::options::RequestOptions,
809    ) -> impl std::future::Future<Output = crate::Result<gax::response::Response<()>>> + Send {
810        gaxi::unimplemented::unimplemented_stub()
811    }
812
813    /// Returns the polling error policy.
814    ///
815    /// When mocking, this method is typically irrelevant. Do not try to verify
816    /// it is called by your mocks.
817    fn get_polling_error_policy(
818        &self,
819        _options: &gax::options::RequestOptions,
820    ) -> std::sync::Arc<dyn gax::polling_error_policy::PollingErrorPolicy> {
821        std::sync::Arc::new(gax::polling_error_policy::Aip194Strict)
822    }
823
824    /// Returns the polling backoff policy.
825    ///
826    /// When mocking, this method is typically irrelevant. Do not try to verify
827    /// it is called by your mocks.
828    fn get_polling_backoff_policy(
829        &self,
830        _options: &gax::options::RequestOptions,
831    ) -> std::sync::Arc<dyn gax::polling_backoff_policy::PollingBackoffPolicy> {
832        std::sync::Arc::new(gax::exponential_backoff::ExponentialBackoff::default())
833    }
834}
835
836/// Defines the trait used to implement [super::client::SessionTemplateController].
837///
838/// Application developers may need to implement this trait to mock
839/// `client::SessionTemplateController`.  In other use-cases, application developers only
840/// use `client::SessionTemplateController` and need not be concerned with this trait or
841/// its implementations.
842///
843/// Services gain new RPCs routinely. Consequently, this trait gains new methods
844/// too. To avoid breaking applications the trait provides a default
845/// implementation of each method. Most of these implementations just return an
846/// error.
847pub trait SessionTemplateController: std::fmt::Debug + Send + Sync {
848    /// Implements [super::client::SessionTemplateController::create_session_template].
849    fn create_session_template(
850        &self,
851        _req: crate::model::CreateSessionTemplateRequest,
852        _options: gax::options::RequestOptions,
853    ) -> impl std::future::Future<
854        Output = crate::Result<gax::response::Response<crate::model::SessionTemplate>>,
855    > + Send {
856        gaxi::unimplemented::unimplemented_stub()
857    }
858
859    /// Implements [super::client::SessionTemplateController::update_session_template].
860    fn update_session_template(
861        &self,
862        _req: crate::model::UpdateSessionTemplateRequest,
863        _options: gax::options::RequestOptions,
864    ) -> impl std::future::Future<
865        Output = crate::Result<gax::response::Response<crate::model::SessionTemplate>>,
866    > + Send {
867        gaxi::unimplemented::unimplemented_stub()
868    }
869
870    /// Implements [super::client::SessionTemplateController::get_session_template].
871    fn get_session_template(
872        &self,
873        _req: crate::model::GetSessionTemplateRequest,
874        _options: gax::options::RequestOptions,
875    ) -> impl std::future::Future<
876        Output = crate::Result<gax::response::Response<crate::model::SessionTemplate>>,
877    > + Send {
878        gaxi::unimplemented::unimplemented_stub()
879    }
880
881    /// Implements [super::client::SessionTemplateController::list_session_templates].
882    fn list_session_templates(
883        &self,
884        _req: crate::model::ListSessionTemplatesRequest,
885        _options: gax::options::RequestOptions,
886    ) -> impl std::future::Future<
887        Output = crate::Result<gax::response::Response<crate::model::ListSessionTemplatesResponse>>,
888    > + Send {
889        gaxi::unimplemented::unimplemented_stub()
890    }
891
892    /// Implements [super::client::SessionTemplateController::delete_session_template].
893    fn delete_session_template(
894        &self,
895        _req: crate::model::DeleteSessionTemplateRequest,
896        _options: gax::options::RequestOptions,
897    ) -> impl std::future::Future<Output = crate::Result<gax::response::Response<()>>> + Send {
898        gaxi::unimplemented::unimplemented_stub()
899    }
900
901    /// Implements [super::client::SessionTemplateController::set_iam_policy].
902    fn set_iam_policy(
903        &self,
904        _req: iam_v1::model::SetIamPolicyRequest,
905        _options: gax::options::RequestOptions,
906    ) -> impl std::future::Future<
907        Output = crate::Result<gax::response::Response<iam_v1::model::Policy>>,
908    > + Send {
909        gaxi::unimplemented::unimplemented_stub()
910    }
911
912    /// Implements [super::client::SessionTemplateController::get_iam_policy].
913    fn get_iam_policy(
914        &self,
915        _req: iam_v1::model::GetIamPolicyRequest,
916        _options: gax::options::RequestOptions,
917    ) -> impl std::future::Future<
918        Output = crate::Result<gax::response::Response<iam_v1::model::Policy>>,
919    > + Send {
920        gaxi::unimplemented::unimplemented_stub()
921    }
922
923    /// Implements [super::client::SessionTemplateController::test_iam_permissions].
924    fn test_iam_permissions(
925        &self,
926        _req: iam_v1::model::TestIamPermissionsRequest,
927        _options: gax::options::RequestOptions,
928    ) -> impl std::future::Future<
929        Output = crate::Result<gax::response::Response<iam_v1::model::TestIamPermissionsResponse>>,
930    > + Send {
931        gaxi::unimplemented::unimplemented_stub()
932    }
933
934    /// Implements [super::client::SessionTemplateController::list_operations].
935    fn list_operations(
936        &self,
937        _req: longrunning::model::ListOperationsRequest,
938        _options: gax::options::RequestOptions,
939    ) -> impl std::future::Future<
940        Output = crate::Result<gax::response::Response<longrunning::model::ListOperationsResponse>>,
941    > + Send {
942        gaxi::unimplemented::unimplemented_stub()
943    }
944
945    /// Implements [super::client::SessionTemplateController::get_operation].
946    fn get_operation(
947        &self,
948        _req: longrunning::model::GetOperationRequest,
949        _options: gax::options::RequestOptions,
950    ) -> impl std::future::Future<
951        Output = crate::Result<gax::response::Response<longrunning::model::Operation>>,
952    > + Send {
953        gaxi::unimplemented::unimplemented_stub()
954    }
955
956    /// Implements [super::client::SessionTemplateController::delete_operation].
957    fn delete_operation(
958        &self,
959        _req: longrunning::model::DeleteOperationRequest,
960        _options: gax::options::RequestOptions,
961    ) -> impl std::future::Future<Output = crate::Result<gax::response::Response<()>>> + Send {
962        gaxi::unimplemented::unimplemented_stub()
963    }
964
965    /// Implements [super::client::SessionTemplateController::cancel_operation].
966    fn cancel_operation(
967        &self,
968        _req: longrunning::model::CancelOperationRequest,
969        _options: gax::options::RequestOptions,
970    ) -> impl std::future::Future<Output = crate::Result<gax::response::Response<()>>> + Send {
971        gaxi::unimplemented::unimplemented_stub()
972    }
973}
974
975/// Defines the trait used to implement [super::client::SessionController].
976///
977/// Application developers may need to implement this trait to mock
978/// `client::SessionController`.  In other use-cases, application developers only
979/// use `client::SessionController` and need not be concerned with this trait or
980/// its implementations.
981///
982/// Services gain new RPCs routinely. Consequently, this trait gains new methods
983/// too. To avoid breaking applications the trait provides a default
984/// implementation of each method. Most of these implementations just return an
985/// error.
986pub trait SessionController: std::fmt::Debug + Send + Sync {
987    /// Implements [super::client::SessionController::create_session].
988    fn create_session(
989        &self,
990        _req: crate::model::CreateSessionRequest,
991        _options: gax::options::RequestOptions,
992    ) -> impl std::future::Future<
993        Output = crate::Result<gax::response::Response<longrunning::model::Operation>>,
994    > + Send {
995        gaxi::unimplemented::unimplemented_stub()
996    }
997
998    /// Implements [super::client::SessionController::get_session].
999    fn get_session(
1000        &self,
1001        _req: crate::model::GetSessionRequest,
1002        _options: gax::options::RequestOptions,
1003    ) -> impl std::future::Future<
1004        Output = crate::Result<gax::response::Response<crate::model::Session>>,
1005    > + Send {
1006        gaxi::unimplemented::unimplemented_stub()
1007    }
1008
1009    /// Implements [super::client::SessionController::list_sessions].
1010    fn list_sessions(
1011        &self,
1012        _req: crate::model::ListSessionsRequest,
1013        _options: gax::options::RequestOptions,
1014    ) -> impl std::future::Future<
1015        Output = crate::Result<gax::response::Response<crate::model::ListSessionsResponse>>,
1016    > + Send {
1017        gaxi::unimplemented::unimplemented_stub()
1018    }
1019
1020    /// Implements [super::client::SessionController::terminate_session].
1021    fn terminate_session(
1022        &self,
1023        _req: crate::model::TerminateSessionRequest,
1024        _options: gax::options::RequestOptions,
1025    ) -> impl std::future::Future<
1026        Output = crate::Result<gax::response::Response<longrunning::model::Operation>>,
1027    > + Send {
1028        gaxi::unimplemented::unimplemented_stub()
1029    }
1030
1031    /// Implements [super::client::SessionController::delete_session].
1032    fn delete_session(
1033        &self,
1034        _req: crate::model::DeleteSessionRequest,
1035        _options: gax::options::RequestOptions,
1036    ) -> impl std::future::Future<
1037        Output = crate::Result<gax::response::Response<longrunning::model::Operation>>,
1038    > + Send {
1039        gaxi::unimplemented::unimplemented_stub()
1040    }
1041
1042    /// Implements [super::client::SessionController::set_iam_policy].
1043    fn set_iam_policy(
1044        &self,
1045        _req: iam_v1::model::SetIamPolicyRequest,
1046        _options: gax::options::RequestOptions,
1047    ) -> impl std::future::Future<
1048        Output = crate::Result<gax::response::Response<iam_v1::model::Policy>>,
1049    > + Send {
1050        gaxi::unimplemented::unimplemented_stub()
1051    }
1052
1053    /// Implements [super::client::SessionController::get_iam_policy].
1054    fn get_iam_policy(
1055        &self,
1056        _req: iam_v1::model::GetIamPolicyRequest,
1057        _options: gax::options::RequestOptions,
1058    ) -> impl std::future::Future<
1059        Output = crate::Result<gax::response::Response<iam_v1::model::Policy>>,
1060    > + Send {
1061        gaxi::unimplemented::unimplemented_stub()
1062    }
1063
1064    /// Implements [super::client::SessionController::test_iam_permissions].
1065    fn test_iam_permissions(
1066        &self,
1067        _req: iam_v1::model::TestIamPermissionsRequest,
1068        _options: gax::options::RequestOptions,
1069    ) -> impl std::future::Future<
1070        Output = crate::Result<gax::response::Response<iam_v1::model::TestIamPermissionsResponse>>,
1071    > + Send {
1072        gaxi::unimplemented::unimplemented_stub()
1073    }
1074
1075    /// Implements [super::client::SessionController::list_operations].
1076    fn list_operations(
1077        &self,
1078        _req: longrunning::model::ListOperationsRequest,
1079        _options: gax::options::RequestOptions,
1080    ) -> impl std::future::Future<
1081        Output = crate::Result<gax::response::Response<longrunning::model::ListOperationsResponse>>,
1082    > + Send {
1083        gaxi::unimplemented::unimplemented_stub()
1084    }
1085
1086    /// Implements [super::client::SessionController::get_operation].
1087    fn get_operation(
1088        &self,
1089        _req: longrunning::model::GetOperationRequest,
1090        _options: gax::options::RequestOptions,
1091    ) -> impl std::future::Future<
1092        Output = crate::Result<gax::response::Response<longrunning::model::Operation>>,
1093    > + Send {
1094        gaxi::unimplemented::unimplemented_stub()
1095    }
1096
1097    /// Implements [super::client::SessionController::delete_operation].
1098    fn delete_operation(
1099        &self,
1100        _req: longrunning::model::DeleteOperationRequest,
1101        _options: gax::options::RequestOptions,
1102    ) -> impl std::future::Future<Output = crate::Result<gax::response::Response<()>>> + Send {
1103        gaxi::unimplemented::unimplemented_stub()
1104    }
1105
1106    /// Implements [super::client::SessionController::cancel_operation].
1107    fn cancel_operation(
1108        &self,
1109        _req: longrunning::model::CancelOperationRequest,
1110        _options: gax::options::RequestOptions,
1111    ) -> impl std::future::Future<Output = crate::Result<gax::response::Response<()>>> + Send {
1112        gaxi::unimplemented::unimplemented_stub()
1113    }
1114
1115    /// Returns the polling error policy.
1116    ///
1117    /// When mocking, this method is typically irrelevant. Do not try to verify
1118    /// it is called by your mocks.
1119    fn get_polling_error_policy(
1120        &self,
1121        _options: &gax::options::RequestOptions,
1122    ) -> std::sync::Arc<dyn gax::polling_error_policy::PollingErrorPolicy> {
1123        std::sync::Arc::new(gax::polling_error_policy::Aip194Strict)
1124    }
1125
1126    /// Returns the polling backoff policy.
1127    ///
1128    /// When mocking, this method is typically irrelevant. Do not try to verify
1129    /// it is called by your mocks.
1130    fn get_polling_backoff_policy(
1131        &self,
1132        _options: &gax::options::RequestOptions,
1133    ) -> std::sync::Arc<dyn gax::polling_backoff_policy::PollingBackoffPolicy> {
1134        std::sync::Arc::new(gax::exponential_backoff::ExponentialBackoff::default())
1135    }
1136}
1137
1138/// Defines the trait used to implement [super::client::WorkflowTemplateService].
1139///
1140/// Application developers may need to implement this trait to mock
1141/// `client::WorkflowTemplateService`.  In other use-cases, application developers only
1142/// use `client::WorkflowTemplateService` and need not be concerned with this trait or
1143/// its implementations.
1144///
1145/// Services gain new RPCs routinely. Consequently, this trait gains new methods
1146/// too. To avoid breaking applications the trait provides a default
1147/// implementation of each method. Most of these implementations just return an
1148/// error.
1149pub trait WorkflowTemplateService: std::fmt::Debug + Send + Sync {
1150    /// Implements [super::client::WorkflowTemplateService::create_workflow_template].
1151    fn create_workflow_template(
1152        &self,
1153        _req: crate::model::CreateWorkflowTemplateRequest,
1154        _options: gax::options::RequestOptions,
1155    ) -> impl std::future::Future<
1156        Output = crate::Result<gax::response::Response<crate::model::WorkflowTemplate>>,
1157    > + Send {
1158        gaxi::unimplemented::unimplemented_stub()
1159    }
1160
1161    /// Implements [super::client::WorkflowTemplateService::get_workflow_template].
1162    fn get_workflow_template(
1163        &self,
1164        _req: crate::model::GetWorkflowTemplateRequest,
1165        _options: gax::options::RequestOptions,
1166    ) -> impl std::future::Future<
1167        Output = crate::Result<gax::response::Response<crate::model::WorkflowTemplate>>,
1168    > + Send {
1169        gaxi::unimplemented::unimplemented_stub()
1170    }
1171
1172    /// Implements [super::client::WorkflowTemplateService::instantiate_workflow_template].
1173    fn instantiate_workflow_template(
1174        &self,
1175        _req: crate::model::InstantiateWorkflowTemplateRequest,
1176        _options: gax::options::RequestOptions,
1177    ) -> impl std::future::Future<
1178        Output = crate::Result<gax::response::Response<longrunning::model::Operation>>,
1179    > + Send {
1180        gaxi::unimplemented::unimplemented_stub()
1181    }
1182
1183    /// Implements [super::client::WorkflowTemplateService::instantiate_inline_workflow_template].
1184    fn instantiate_inline_workflow_template(
1185        &self,
1186        _req: crate::model::InstantiateInlineWorkflowTemplateRequest,
1187        _options: gax::options::RequestOptions,
1188    ) -> impl std::future::Future<
1189        Output = crate::Result<gax::response::Response<longrunning::model::Operation>>,
1190    > + Send {
1191        gaxi::unimplemented::unimplemented_stub()
1192    }
1193
1194    /// Implements [super::client::WorkflowTemplateService::update_workflow_template].
1195    fn update_workflow_template(
1196        &self,
1197        _req: crate::model::UpdateWorkflowTemplateRequest,
1198        _options: gax::options::RequestOptions,
1199    ) -> impl std::future::Future<
1200        Output = crate::Result<gax::response::Response<crate::model::WorkflowTemplate>>,
1201    > + Send {
1202        gaxi::unimplemented::unimplemented_stub()
1203    }
1204
1205    /// Implements [super::client::WorkflowTemplateService::list_workflow_templates].
1206    fn list_workflow_templates(
1207        &self,
1208        _req: crate::model::ListWorkflowTemplatesRequest,
1209        _options: gax::options::RequestOptions,
1210    ) -> impl std::future::Future<
1211        Output = crate::Result<
1212            gax::response::Response<crate::model::ListWorkflowTemplatesResponse>,
1213        >,
1214    > + Send {
1215        gaxi::unimplemented::unimplemented_stub()
1216    }
1217
1218    /// Implements [super::client::WorkflowTemplateService::delete_workflow_template].
1219    fn delete_workflow_template(
1220        &self,
1221        _req: crate::model::DeleteWorkflowTemplateRequest,
1222        _options: gax::options::RequestOptions,
1223    ) -> impl std::future::Future<Output = crate::Result<gax::response::Response<()>>> + Send {
1224        gaxi::unimplemented::unimplemented_stub()
1225    }
1226
1227    /// Implements [super::client::WorkflowTemplateService::set_iam_policy].
1228    fn set_iam_policy(
1229        &self,
1230        _req: iam_v1::model::SetIamPolicyRequest,
1231        _options: gax::options::RequestOptions,
1232    ) -> impl std::future::Future<
1233        Output = crate::Result<gax::response::Response<iam_v1::model::Policy>>,
1234    > + Send {
1235        gaxi::unimplemented::unimplemented_stub()
1236    }
1237
1238    /// Implements [super::client::WorkflowTemplateService::get_iam_policy].
1239    fn get_iam_policy(
1240        &self,
1241        _req: iam_v1::model::GetIamPolicyRequest,
1242        _options: gax::options::RequestOptions,
1243    ) -> impl std::future::Future<
1244        Output = crate::Result<gax::response::Response<iam_v1::model::Policy>>,
1245    > + Send {
1246        gaxi::unimplemented::unimplemented_stub()
1247    }
1248
1249    /// Implements [super::client::WorkflowTemplateService::test_iam_permissions].
1250    fn test_iam_permissions(
1251        &self,
1252        _req: iam_v1::model::TestIamPermissionsRequest,
1253        _options: gax::options::RequestOptions,
1254    ) -> impl std::future::Future<
1255        Output = crate::Result<gax::response::Response<iam_v1::model::TestIamPermissionsResponse>>,
1256    > + Send {
1257        gaxi::unimplemented::unimplemented_stub()
1258    }
1259
1260    /// Implements [super::client::WorkflowTemplateService::list_operations].
1261    fn list_operations(
1262        &self,
1263        _req: longrunning::model::ListOperationsRequest,
1264        _options: gax::options::RequestOptions,
1265    ) -> impl std::future::Future<
1266        Output = crate::Result<gax::response::Response<longrunning::model::ListOperationsResponse>>,
1267    > + Send {
1268        gaxi::unimplemented::unimplemented_stub()
1269    }
1270
1271    /// Implements [super::client::WorkflowTemplateService::get_operation].
1272    fn get_operation(
1273        &self,
1274        _req: longrunning::model::GetOperationRequest,
1275        _options: gax::options::RequestOptions,
1276    ) -> impl std::future::Future<
1277        Output = crate::Result<gax::response::Response<longrunning::model::Operation>>,
1278    > + Send {
1279        gaxi::unimplemented::unimplemented_stub()
1280    }
1281
1282    /// Implements [super::client::WorkflowTemplateService::delete_operation].
1283    fn delete_operation(
1284        &self,
1285        _req: longrunning::model::DeleteOperationRequest,
1286        _options: gax::options::RequestOptions,
1287    ) -> impl std::future::Future<Output = crate::Result<gax::response::Response<()>>> + Send {
1288        gaxi::unimplemented::unimplemented_stub()
1289    }
1290
1291    /// Implements [super::client::WorkflowTemplateService::cancel_operation].
1292    fn cancel_operation(
1293        &self,
1294        _req: longrunning::model::CancelOperationRequest,
1295        _options: gax::options::RequestOptions,
1296    ) -> impl std::future::Future<Output = crate::Result<gax::response::Response<()>>> + Send {
1297        gaxi::unimplemented::unimplemented_stub()
1298    }
1299
1300    /// Returns the polling error policy.
1301    ///
1302    /// When mocking, this method is typically irrelevant. Do not try to verify
1303    /// it is called by your mocks.
1304    fn get_polling_error_policy(
1305        &self,
1306        _options: &gax::options::RequestOptions,
1307    ) -> std::sync::Arc<dyn gax::polling_error_policy::PollingErrorPolicy> {
1308        std::sync::Arc::new(gax::polling_error_policy::Aip194Strict)
1309    }
1310
1311    /// Returns the polling backoff policy.
1312    ///
1313    /// When mocking, this method is typically irrelevant. Do not try to verify
1314    /// it is called by your mocks.
1315    fn get_polling_backoff_policy(
1316        &self,
1317        _options: &gax::options::RequestOptions,
1318    ) -> std::sync::Arc<dyn gax::polling_backoff_policy::PollingBackoffPolicy> {
1319        std::sync::Arc::new(gax::exponential_backoff::ExponentialBackoff::default())
1320    }
1321}
google_cloud_dataproc_v1/stub.rs

google_cloud_dataproc_v1/
stub.rs
