google_cloud_bigquery_migration_v2/builder.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
17pub mod migration_service {
18 use crate::Result;
19
20 /// A builder for [MigrationService][crate::client::MigrationService].
21 ///
22 /// ```
23 /// # async fn sample() -> gax::client_builder::Result<()> {
24 /// # use google_cloud_bigquery_migration_v2::*;
25 /// # use builder::migration_service::ClientBuilder;
26 /// # use client::MigrationService;
27 /// let builder : ClientBuilder = MigrationService::builder();
28 /// let client = builder
29 /// .with_endpoint("https://bigquerymigration.googleapis.com")
30 /// .build().await?;
31 /// # Ok(()) }
32 /// ```
33 pub type ClientBuilder =
34 gax::client_builder::ClientBuilder<client::Factory, gaxi::options::Credentials>;
35
36 pub(crate) mod client {
37 use super::super::super::client::MigrationService;
38 pub struct Factory;
39 impl gax::client_builder::internal::ClientFactory for Factory {
40 type Client = MigrationService;
41 type Credentials = gaxi::options::Credentials;
42 async fn build(
43 self,
44 config: gaxi::options::ClientConfig,
45 ) -> gax::client_builder::Result<Self::Client> {
46 Self::Client::new(config).await
47 }
48 }
49 }
50
51 /// Common implementation for [crate::client::MigrationService] request builders.
52 #[derive(Clone, Debug)]
53 pub(crate) struct RequestBuilder<R: std::default::Default> {
54 stub: std::sync::Arc<dyn super::super::stub::dynamic::MigrationService>,
55 request: R,
56 options: gax::options::RequestOptions,
57 }
58
59 impl<R> RequestBuilder<R>
60 where
61 R: std::default::Default,
62 {
63 pub(crate) fn new(
64 stub: std::sync::Arc<dyn super::super::stub::dynamic::MigrationService>,
65 ) -> Self {
66 Self {
67 stub,
68 request: R::default(),
69 options: gax::options::RequestOptions::default(),
70 }
71 }
72 }
73
74 /// The request builder for [MigrationService::create_migration_workflow][crate::client::MigrationService::create_migration_workflow] calls.
75 ///
76 /// # Example
77 /// ```
78 /// # use google_cloud_bigquery_migration_v2::builder::migration_service::CreateMigrationWorkflow;
79 /// # async fn sample() -> gax::Result<()> {
80 ///
81 /// let builder = prepare_request_builder();
82 /// let response = builder.send().await?;
83 /// # Ok(()) }
84 ///
85 /// fn prepare_request_builder() -> CreateMigrationWorkflow {
86 /// # panic!();
87 /// // ... details omitted ...
88 /// }
89 /// ```
90 #[derive(Clone, Debug)]
91 pub struct CreateMigrationWorkflow(
92 RequestBuilder<crate::model::CreateMigrationWorkflowRequest>,
93 );
94
95 impl CreateMigrationWorkflow {
96 pub(crate) fn new(
97 stub: std::sync::Arc<dyn super::super::stub::dynamic::MigrationService>,
98 ) -> Self {
99 Self(RequestBuilder::new(stub))
100 }
101
102 /// Sets the full request, replacing any prior values.
103 pub fn with_request<V: Into<crate::model::CreateMigrationWorkflowRequest>>(
104 mut self,
105 v: V,
106 ) -> Self {
107 self.0.request = v.into();
108 self
109 }
110
111 /// Sets all the options, replacing any prior values.
112 pub fn with_options<V: Into<gax::options::RequestOptions>>(mut self, v: V) -> Self {
113 self.0.options = v.into();
114 self
115 }
116
117 /// Sends the request.
118 pub async fn send(self) -> Result<crate::model::MigrationWorkflow> {
119 (*self.0.stub)
120 .create_migration_workflow(self.0.request, self.0.options)
121 .await
122 .map(gax::response::Response::into_body)
123 }
124
125 /// Sets the value of [parent][crate::model::CreateMigrationWorkflowRequest::parent].
126 ///
127 /// This is a **required** field for requests.
128 pub fn set_parent<T: Into<std::string::String>>(mut self, v: T) -> Self {
129 self.0.request.parent = v.into();
130 self
131 }
132
133 /// Sets the value of [migration_workflow][crate::model::CreateMigrationWorkflowRequest::migration_workflow].
134 ///
135 /// This is a **required** field for requests.
136 pub fn set_migration_workflow<T>(mut self, v: T) -> Self
137 where
138 T: std::convert::Into<crate::model::MigrationWorkflow>,
139 {
140 self.0.request.migration_workflow = std::option::Option::Some(v.into());
141 self
142 }
143
144 /// Sets or clears the value of [migration_workflow][crate::model::CreateMigrationWorkflowRequest::migration_workflow].
145 ///
146 /// This is a **required** field for requests.
147 pub fn set_or_clear_migration_workflow<T>(mut self, v: std::option::Option<T>) -> Self
148 where
149 T: std::convert::Into<crate::model::MigrationWorkflow>,
150 {
151 self.0.request.migration_workflow = v.map(|x| x.into());
152 self
153 }
154 }
155
156 #[doc(hidden)]
157 impl gax::options::internal::RequestBuilder for CreateMigrationWorkflow {
158 fn request_options(&mut self) -> &mut gax::options::RequestOptions {
159 &mut self.0.options
160 }
161 }
162
163 /// The request builder for [MigrationService::get_migration_workflow][crate::client::MigrationService::get_migration_workflow] calls.
164 ///
165 /// # Example
166 /// ```
167 /// # use google_cloud_bigquery_migration_v2::builder::migration_service::GetMigrationWorkflow;
168 /// # async fn sample() -> gax::Result<()> {
169 ///
170 /// let builder = prepare_request_builder();
171 /// let response = builder.send().await?;
172 /// # Ok(()) }
173 ///
174 /// fn prepare_request_builder() -> GetMigrationWorkflow {
175 /// # panic!();
176 /// // ... details omitted ...
177 /// }
178 /// ```
179 #[derive(Clone, Debug)]
180 pub struct GetMigrationWorkflow(RequestBuilder<crate::model::GetMigrationWorkflowRequest>);
181
182 impl GetMigrationWorkflow {
183 pub(crate) fn new(
184 stub: std::sync::Arc<dyn super::super::stub::dynamic::MigrationService>,
185 ) -> Self {
186 Self(RequestBuilder::new(stub))
187 }
188
189 /// Sets the full request, replacing any prior values.
190 pub fn with_request<V: Into<crate::model::GetMigrationWorkflowRequest>>(
191 mut self,
192 v: V,
193 ) -> Self {
194 self.0.request = v.into();
195 self
196 }
197
198 /// Sets all the options, replacing any prior values.
199 pub fn with_options<V: Into<gax::options::RequestOptions>>(mut self, v: V) -> Self {
200 self.0.options = v.into();
201 self
202 }
203
204 /// Sends the request.
205 pub async fn send(self) -> Result<crate::model::MigrationWorkflow> {
206 (*self.0.stub)
207 .get_migration_workflow(self.0.request, self.0.options)
208 .await
209 .map(gax::response::Response::into_body)
210 }
211
212 /// Sets the value of [name][crate::model::GetMigrationWorkflowRequest::name].
213 ///
214 /// This is a **required** field for requests.
215 pub fn set_name<T: Into<std::string::String>>(mut self, v: T) -> Self {
216 self.0.request.name = v.into();
217 self
218 }
219
220 /// Sets the value of [read_mask][crate::model::GetMigrationWorkflowRequest::read_mask].
221 pub fn set_read_mask<T>(mut self, v: T) -> Self
222 where
223 T: std::convert::Into<wkt::FieldMask>,
224 {
225 self.0.request.read_mask = std::option::Option::Some(v.into());
226 self
227 }
228
229 /// Sets or clears the value of [read_mask][crate::model::GetMigrationWorkflowRequest::read_mask].
230 pub fn set_or_clear_read_mask<T>(mut self, v: std::option::Option<T>) -> Self
231 where
232 T: std::convert::Into<wkt::FieldMask>,
233 {
234 self.0.request.read_mask = v.map(|x| x.into());
235 self
236 }
237 }
238
239 #[doc(hidden)]
240 impl gax::options::internal::RequestBuilder for GetMigrationWorkflow {
241 fn request_options(&mut self) -> &mut gax::options::RequestOptions {
242 &mut self.0.options
243 }
244 }
245
246 /// The request builder for [MigrationService::list_migration_workflows][crate::client::MigrationService::list_migration_workflows] calls.
247 ///
248 /// # Example
249 /// ```
250 /// # use google_cloud_bigquery_migration_v2::builder::migration_service::ListMigrationWorkflows;
251 /// # async fn sample() -> gax::Result<()> {
252 /// use gax::paginator::ItemPaginator;
253 ///
254 /// let builder = prepare_request_builder();
255 /// let mut items = builder.by_item();
256 /// while let Some(result) = items.next().await {
257 /// let item = result?;
258 /// }
259 /// # Ok(()) }
260 ///
261 /// fn prepare_request_builder() -> ListMigrationWorkflows {
262 /// # panic!();
263 /// // ... details omitted ...
264 /// }
265 /// ```
266 #[derive(Clone, Debug)]
267 pub struct ListMigrationWorkflows(RequestBuilder<crate::model::ListMigrationWorkflowsRequest>);
268
269 impl ListMigrationWorkflows {
270 pub(crate) fn new(
271 stub: std::sync::Arc<dyn super::super::stub::dynamic::MigrationService>,
272 ) -> Self {
273 Self(RequestBuilder::new(stub))
274 }
275
276 /// Sets the full request, replacing any prior values.
277 pub fn with_request<V: Into<crate::model::ListMigrationWorkflowsRequest>>(
278 mut self,
279 v: V,
280 ) -> Self {
281 self.0.request = v.into();
282 self
283 }
284
285 /// Sets all the options, replacing any prior values.
286 pub fn with_options<V: Into<gax::options::RequestOptions>>(mut self, v: V) -> Self {
287 self.0.options = v.into();
288 self
289 }
290
291 /// Sends the request.
292 pub async fn send(self) -> Result<crate::model::ListMigrationWorkflowsResponse> {
293 (*self.0.stub)
294 .list_migration_workflows(self.0.request, self.0.options)
295 .await
296 .map(gax::response::Response::into_body)
297 }
298
299 /// Streams each page in the collection.
300 pub fn by_page(
301 self,
302 ) -> impl gax::paginator::Paginator<
303 crate::model::ListMigrationWorkflowsResponse,
304 gax::error::Error,
305 > {
306 use std::clone::Clone;
307 let token = self.0.request.page_token.clone();
308 let execute = move |token: String| {
309 let mut builder = self.clone();
310 builder.0.request = builder.0.request.set_page_token(token);
311 builder.send()
312 };
313 gax::paginator::internal::new_paginator(token, execute)
314 }
315
316 /// Streams each item in the collection.
317 pub fn by_item(
318 self,
319 ) -> impl gax::paginator::ItemPaginator<
320 crate::model::ListMigrationWorkflowsResponse,
321 gax::error::Error,
322 > {
323 use gax::paginator::Paginator;
324 self.by_page().items()
325 }
326
327 /// Sets the value of [parent][crate::model::ListMigrationWorkflowsRequest::parent].
328 ///
329 /// This is a **required** field for requests.
330 pub fn set_parent<T: Into<std::string::String>>(mut self, v: T) -> Self {
331 self.0.request.parent = v.into();
332 self
333 }
334
335 /// Sets the value of [read_mask][crate::model::ListMigrationWorkflowsRequest::read_mask].
336 pub fn set_read_mask<T>(mut self, v: T) -> Self
337 where
338 T: std::convert::Into<wkt::FieldMask>,
339 {
340 self.0.request.read_mask = std::option::Option::Some(v.into());
341 self
342 }
343
344 /// Sets or clears the value of [read_mask][crate::model::ListMigrationWorkflowsRequest::read_mask].
345 pub fn set_or_clear_read_mask<T>(mut self, v: std::option::Option<T>) -> Self
346 where
347 T: std::convert::Into<wkt::FieldMask>,
348 {
349 self.0.request.read_mask = v.map(|x| x.into());
350 self
351 }
352
353 /// Sets the value of [page_size][crate::model::ListMigrationWorkflowsRequest::page_size].
354 pub fn set_page_size<T: Into<i32>>(mut self, v: T) -> Self {
355 self.0.request.page_size = v.into();
356 self
357 }
358
359 /// Sets the value of [page_token][crate::model::ListMigrationWorkflowsRequest::page_token].
360 pub fn set_page_token<T: Into<std::string::String>>(mut self, v: T) -> Self {
361 self.0.request.page_token = v.into();
362 self
363 }
364 }
365
366 #[doc(hidden)]
367 impl gax::options::internal::RequestBuilder for ListMigrationWorkflows {
368 fn request_options(&mut self) -> &mut gax::options::RequestOptions {
369 &mut self.0.options
370 }
371 }
372
373 /// The request builder for [MigrationService::delete_migration_workflow][crate::client::MigrationService::delete_migration_workflow] calls.
374 ///
375 /// # Example
376 /// ```
377 /// # use google_cloud_bigquery_migration_v2::builder::migration_service::DeleteMigrationWorkflow;
378 /// # async fn sample() -> gax::Result<()> {
379 ///
380 /// let builder = prepare_request_builder();
381 /// let response = builder.send().await?;
382 /// # Ok(()) }
383 ///
384 /// fn prepare_request_builder() -> DeleteMigrationWorkflow {
385 /// # panic!();
386 /// // ... details omitted ...
387 /// }
388 /// ```
389 #[derive(Clone, Debug)]
390 pub struct DeleteMigrationWorkflow(
391 RequestBuilder<crate::model::DeleteMigrationWorkflowRequest>,
392 );
393
394 impl DeleteMigrationWorkflow {
395 pub(crate) fn new(
396 stub: std::sync::Arc<dyn super::super::stub::dynamic::MigrationService>,
397 ) -> Self {
398 Self(RequestBuilder::new(stub))
399 }
400
401 /// Sets the full request, replacing any prior values.
402 pub fn with_request<V: Into<crate::model::DeleteMigrationWorkflowRequest>>(
403 mut self,
404 v: V,
405 ) -> Self {
406 self.0.request = v.into();
407 self
408 }
409
410 /// Sets all the options, replacing any prior values.
411 pub fn with_options<V: Into<gax::options::RequestOptions>>(mut self, v: V) -> Self {
412 self.0.options = v.into();
413 self
414 }
415
416 /// Sends the request.
417 pub async fn send(self) -> Result<()> {
418 (*self.0.stub)
419 .delete_migration_workflow(self.0.request, self.0.options)
420 .await
421 .map(gax::response::Response::into_body)
422 }
423
424 /// Sets the value of [name][crate::model::DeleteMigrationWorkflowRequest::name].
425 ///
426 /// This is a **required** field for requests.
427 pub fn set_name<T: Into<std::string::String>>(mut self, v: T) -> Self {
428 self.0.request.name = v.into();
429 self
430 }
431 }
432
433 #[doc(hidden)]
434 impl gax::options::internal::RequestBuilder for DeleteMigrationWorkflow {
435 fn request_options(&mut self) -> &mut gax::options::RequestOptions {
436 &mut self.0.options
437 }
438 }
439
440 /// The request builder for [MigrationService::start_migration_workflow][crate::client::MigrationService::start_migration_workflow] calls.
441 ///
442 /// # Example
443 /// ```
444 /// # use google_cloud_bigquery_migration_v2::builder::migration_service::StartMigrationWorkflow;
445 /// # async fn sample() -> gax::Result<()> {
446 ///
447 /// let builder = prepare_request_builder();
448 /// let response = builder.send().await?;
449 /// # Ok(()) }
450 ///
451 /// fn prepare_request_builder() -> StartMigrationWorkflow {
452 /// # panic!();
453 /// // ... details omitted ...
454 /// }
455 /// ```
456 #[derive(Clone, Debug)]
457 pub struct StartMigrationWorkflow(RequestBuilder<crate::model::StartMigrationWorkflowRequest>);
458
459 impl StartMigrationWorkflow {
460 pub(crate) fn new(
461 stub: std::sync::Arc<dyn super::super::stub::dynamic::MigrationService>,
462 ) -> Self {
463 Self(RequestBuilder::new(stub))
464 }
465
466 /// Sets the full request, replacing any prior values.
467 pub fn with_request<V: Into<crate::model::StartMigrationWorkflowRequest>>(
468 mut self,
469 v: V,
470 ) -> Self {
471 self.0.request = v.into();
472 self
473 }
474
475 /// Sets all the options, replacing any prior values.
476 pub fn with_options<V: Into<gax::options::RequestOptions>>(mut self, v: V) -> Self {
477 self.0.options = v.into();
478 self
479 }
480
481 /// Sends the request.
482 pub async fn send(self) -> Result<()> {
483 (*self.0.stub)
484 .start_migration_workflow(self.0.request, self.0.options)
485 .await
486 .map(gax::response::Response::into_body)
487 }
488
489 /// Sets the value of [name][crate::model::StartMigrationWorkflowRequest::name].
490 ///
491 /// This is a **required** field for requests.
492 pub fn set_name<T: Into<std::string::String>>(mut self, v: T) -> Self {
493 self.0.request.name = v.into();
494 self
495 }
496 }
497
498 #[doc(hidden)]
499 impl gax::options::internal::RequestBuilder for StartMigrationWorkflow {
500 fn request_options(&mut self) -> &mut gax::options::RequestOptions {
501 &mut self.0.options
502 }
503 }
504
505 /// The request builder for [MigrationService::get_migration_subtask][crate::client::MigrationService::get_migration_subtask] calls.
506 ///
507 /// # Example
508 /// ```
509 /// # use google_cloud_bigquery_migration_v2::builder::migration_service::GetMigrationSubtask;
510 /// # async fn sample() -> gax::Result<()> {
511 ///
512 /// let builder = prepare_request_builder();
513 /// let response = builder.send().await?;
514 /// # Ok(()) }
515 ///
516 /// fn prepare_request_builder() -> GetMigrationSubtask {
517 /// # panic!();
518 /// // ... details omitted ...
519 /// }
520 /// ```
521 #[derive(Clone, Debug)]
522 pub struct GetMigrationSubtask(RequestBuilder<crate::model::GetMigrationSubtaskRequest>);
523
524 impl GetMigrationSubtask {
525 pub(crate) fn new(
526 stub: std::sync::Arc<dyn super::super::stub::dynamic::MigrationService>,
527 ) -> Self {
528 Self(RequestBuilder::new(stub))
529 }
530
531 /// Sets the full request, replacing any prior values.
532 pub fn with_request<V: Into<crate::model::GetMigrationSubtaskRequest>>(
533 mut self,
534 v: V,
535 ) -> Self {
536 self.0.request = v.into();
537 self
538 }
539
540 /// Sets all the options, replacing any prior values.
541 pub fn with_options<V: Into<gax::options::RequestOptions>>(mut self, v: V) -> Self {
542 self.0.options = v.into();
543 self
544 }
545
546 /// Sends the request.
547 pub async fn send(self) -> Result<crate::model::MigrationSubtask> {
548 (*self.0.stub)
549 .get_migration_subtask(self.0.request, self.0.options)
550 .await
551 .map(gax::response::Response::into_body)
552 }
553
554 /// Sets the value of [name][crate::model::GetMigrationSubtaskRequest::name].
555 ///
556 /// This is a **required** field for requests.
557 pub fn set_name<T: Into<std::string::String>>(mut self, v: T) -> Self {
558 self.0.request.name = v.into();
559 self
560 }
561
562 /// Sets the value of [read_mask][crate::model::GetMigrationSubtaskRequest::read_mask].
563 pub fn set_read_mask<T>(mut self, v: T) -> Self
564 where
565 T: std::convert::Into<wkt::FieldMask>,
566 {
567 self.0.request.read_mask = std::option::Option::Some(v.into());
568 self
569 }
570
571 /// Sets or clears the value of [read_mask][crate::model::GetMigrationSubtaskRequest::read_mask].
572 pub fn set_or_clear_read_mask<T>(mut self, v: std::option::Option<T>) -> Self
573 where
574 T: std::convert::Into<wkt::FieldMask>,
575 {
576 self.0.request.read_mask = v.map(|x| x.into());
577 self
578 }
579 }
580
581 #[doc(hidden)]
582 impl gax::options::internal::RequestBuilder for GetMigrationSubtask {
583 fn request_options(&mut self) -> &mut gax::options::RequestOptions {
584 &mut self.0.options
585 }
586 }
587
588 /// The request builder for [MigrationService::list_migration_subtasks][crate::client::MigrationService::list_migration_subtasks] calls.
589 ///
590 /// # Example
591 /// ```
592 /// # use google_cloud_bigquery_migration_v2::builder::migration_service::ListMigrationSubtasks;
593 /// # async fn sample() -> gax::Result<()> {
594 /// use gax::paginator::ItemPaginator;
595 ///
596 /// let builder = prepare_request_builder();
597 /// let mut items = builder.by_item();
598 /// while let Some(result) = items.next().await {
599 /// let item = result?;
600 /// }
601 /// # Ok(()) }
602 ///
603 /// fn prepare_request_builder() -> ListMigrationSubtasks {
604 /// # panic!();
605 /// // ... details omitted ...
606 /// }
607 /// ```
608 #[derive(Clone, Debug)]
609 pub struct ListMigrationSubtasks(RequestBuilder<crate::model::ListMigrationSubtasksRequest>);
610
611 impl ListMigrationSubtasks {
612 pub(crate) fn new(
613 stub: std::sync::Arc<dyn super::super::stub::dynamic::MigrationService>,
614 ) -> Self {
615 Self(RequestBuilder::new(stub))
616 }
617
618 /// Sets the full request, replacing any prior values.
619 pub fn with_request<V: Into<crate::model::ListMigrationSubtasksRequest>>(
620 mut self,
621 v: V,
622 ) -> Self {
623 self.0.request = v.into();
624 self
625 }
626
627 /// Sets all the options, replacing any prior values.
628 pub fn with_options<V: Into<gax::options::RequestOptions>>(mut self, v: V) -> Self {
629 self.0.options = v.into();
630 self
631 }
632
633 /// Sends the request.
634 pub async fn send(self) -> Result<crate::model::ListMigrationSubtasksResponse> {
635 (*self.0.stub)
636 .list_migration_subtasks(self.0.request, self.0.options)
637 .await
638 .map(gax::response::Response::into_body)
639 }
640
641 /// Streams each page in the collection.
642 pub fn by_page(
643 self,
644 ) -> impl gax::paginator::Paginator<crate::model::ListMigrationSubtasksResponse, gax::error::Error>
645 {
646 use std::clone::Clone;
647 let token = self.0.request.page_token.clone();
648 let execute = move |token: String| {
649 let mut builder = self.clone();
650 builder.0.request = builder.0.request.set_page_token(token);
651 builder.send()
652 };
653 gax::paginator::internal::new_paginator(token, execute)
654 }
655
656 /// Streams each item in the collection.
657 pub fn by_item(
658 self,
659 ) -> impl gax::paginator::ItemPaginator<
660 crate::model::ListMigrationSubtasksResponse,
661 gax::error::Error,
662 > {
663 use gax::paginator::Paginator;
664 self.by_page().items()
665 }
666
667 /// Sets the value of [parent][crate::model::ListMigrationSubtasksRequest::parent].
668 ///
669 /// This is a **required** field for requests.
670 pub fn set_parent<T: Into<std::string::String>>(mut self, v: T) -> Self {
671 self.0.request.parent = v.into();
672 self
673 }
674
675 /// Sets the value of [read_mask][crate::model::ListMigrationSubtasksRequest::read_mask].
676 pub fn set_read_mask<T>(mut self, v: T) -> Self
677 where
678 T: std::convert::Into<wkt::FieldMask>,
679 {
680 self.0.request.read_mask = std::option::Option::Some(v.into());
681 self
682 }
683
684 /// Sets or clears the value of [read_mask][crate::model::ListMigrationSubtasksRequest::read_mask].
685 pub fn set_or_clear_read_mask<T>(mut self, v: std::option::Option<T>) -> Self
686 where
687 T: std::convert::Into<wkt::FieldMask>,
688 {
689 self.0.request.read_mask = v.map(|x| x.into());
690 self
691 }
692
693 /// Sets the value of [page_size][crate::model::ListMigrationSubtasksRequest::page_size].
694 pub fn set_page_size<T: Into<i32>>(mut self, v: T) -> Self {
695 self.0.request.page_size = v.into();
696 self
697 }
698
699 /// Sets the value of [page_token][crate::model::ListMigrationSubtasksRequest::page_token].
700 pub fn set_page_token<T: Into<std::string::String>>(mut self, v: T) -> Self {
701 self.0.request.page_token = v.into();
702 self
703 }
704
705 /// Sets the value of [filter][crate::model::ListMigrationSubtasksRequest::filter].
706 pub fn set_filter<T: Into<std::string::String>>(mut self, v: T) -> Self {
707 self.0.request.filter = v.into();
708 self
709 }
710 }
711
712 #[doc(hidden)]
713 impl gax::options::internal::RequestBuilder for ListMigrationSubtasks {
714 fn request_options(&mut self) -> &mut gax::options::RequestOptions {
715 &mut self.0.options
716 }
717 }
718}