|
19 | 19 | from typing import Dict, Sequence, Tuple, Type, Union |
20 | 20 | import pkg_resources |
21 | 21 |
|
22 | | -import google.api_core.client_options as ClientOptions # type: ignore |
| 22 | +from google.api_core.client_options import ClientOptions # type: ignore |
23 | 23 | from google.api_core import exceptions as core_exceptions # type: ignore |
24 | 24 | from google.api_core import gapic_v1 # type: ignore |
25 | 25 | from google.api_core import retry as retries # type: ignore |
26 | 26 | from google.auth import credentials as ga_credentials # type: ignore |
27 | 27 | from google.oauth2 import service_account # type: ignore |
28 | 28 |
|
| 29 | +OptionalRetry = Union[retries.Retry, object] |
| 30 | + |
29 | 31 | from google.api_core import operation # type: ignore |
30 | 32 | from google.api_core import operation_async # type: ignore |
31 | 33 | from google.cloud.networkconnectivity_v1.services.hub_service import pagers |
@@ -182,17 +184,17 @@ def __init__( |
182 | 184 |
|
183 | 185 | async def list_hubs( |
184 | 186 | self, |
185 | | - request: hub.ListHubsRequest = None, |
| 187 | + request: Union[hub.ListHubsRequest, dict] = None, |
186 | 188 | *, |
187 | 189 | parent: str = None, |
188 | | - retry: retries.Retry = gapic_v1.method.DEFAULT, |
| 190 | + retry: OptionalRetry = gapic_v1.method.DEFAULT, |
189 | 191 | timeout: float = None, |
190 | 192 | metadata: Sequence[Tuple[str, str]] = (), |
191 | 193 | ) -> pagers.ListHubsAsyncPager: |
192 | 194 | r"""Lists hubs in a given project. |
193 | 195 |
|
194 | 196 | Args: |
195 | | - request (:class:`google.cloud.networkconnectivity_v1.types.ListHubsRequest`): |
| 197 | + request (Union[google.cloud.networkconnectivity_v1.types.ListHubsRequest, dict]): |
196 | 198 | The request object. Request for |
197 | 199 | [HubService.ListHubs][google.cloud.networkconnectivity.v1.HubService.ListHubs] |
198 | 200 | method. |
@@ -262,17 +264,17 @@ async def list_hubs( |
262 | 264 |
|
263 | 265 | async def get_hub( |
264 | 266 | self, |
265 | | - request: hub.GetHubRequest = None, |
| 267 | + request: Union[hub.GetHubRequest, dict] = None, |
266 | 268 | *, |
267 | 269 | name: str = None, |
268 | | - retry: retries.Retry = gapic_v1.method.DEFAULT, |
| 270 | + retry: OptionalRetry = gapic_v1.method.DEFAULT, |
269 | 271 | timeout: float = None, |
270 | 272 | metadata: Sequence[Tuple[str, str]] = (), |
271 | 273 | ) -> hub.Hub: |
272 | 274 | r"""Gets details about the specified hub. |
273 | 275 |
|
274 | 276 | Args: |
275 | | - request (:class:`google.cloud.networkconnectivity_v1.types.GetHubRequest`): |
| 277 | + request (Union[google.cloud.networkconnectivity_v1.types.GetHubRequest, dict]): |
276 | 278 | The request object. Request for |
277 | 279 | [HubService.GetHub][google.cloud.networkconnectivity.v1.HubService.GetHub] |
278 | 280 | method. |
@@ -338,19 +340,19 @@ async def get_hub( |
338 | 340 |
|
339 | 341 | async def create_hub( |
340 | 342 | self, |
341 | | - request: gcn_hub.CreateHubRequest = None, |
| 343 | + request: Union[gcn_hub.CreateHubRequest, dict] = None, |
342 | 344 | *, |
343 | 345 | parent: str = None, |
344 | 346 | hub: gcn_hub.Hub = None, |
345 | 347 | hub_id: str = None, |
346 | | - retry: retries.Retry = gapic_v1.method.DEFAULT, |
| 348 | + retry: OptionalRetry = gapic_v1.method.DEFAULT, |
347 | 349 | timeout: float = None, |
348 | 350 | metadata: Sequence[Tuple[str, str]] = (), |
349 | 351 | ) -> operation_async.AsyncOperation: |
350 | 352 | r"""Creates a new hub in the specified project. |
351 | 353 |
|
352 | 354 | Args: |
353 | | - request (:class:`google.cloud.networkconnectivity_v1.types.CreateHubRequest`): |
| 355 | + request (Union[google.cloud.networkconnectivity_v1.types.CreateHubRequest, dict]): |
354 | 356 | The request object. Request for |
355 | 357 | [HubService.CreateHub][google.cloud.networkconnectivity.v1.HubService.CreateHub] |
356 | 358 | method. |
@@ -440,19 +442,19 @@ async def create_hub( |
440 | 442 |
|
441 | 443 | async def update_hub( |
442 | 444 | self, |
443 | | - request: gcn_hub.UpdateHubRequest = None, |
| 445 | + request: Union[gcn_hub.UpdateHubRequest, dict] = None, |
444 | 446 | *, |
445 | 447 | hub: gcn_hub.Hub = None, |
446 | 448 | update_mask: field_mask_pb2.FieldMask = None, |
447 | | - retry: retries.Retry = gapic_v1.method.DEFAULT, |
| 449 | + retry: OptionalRetry = gapic_v1.method.DEFAULT, |
448 | 450 | timeout: float = None, |
449 | 451 | metadata: Sequence[Tuple[str, str]] = (), |
450 | 452 | ) -> operation_async.AsyncOperation: |
451 | 453 | r"""Updates the description and/or labels of the |
452 | 454 | specified hub. |
453 | 455 |
|
454 | 456 | Args: |
455 | | - request (:class:`google.cloud.networkconnectivity_v1.types.UpdateHubRequest`): |
| 457 | + request (Union[google.cloud.networkconnectivity_v1.types.UpdateHubRequest, dict]): |
456 | 458 | The request object. Request for |
457 | 459 | [HubService.UpdateHub][google.cloud.networkconnectivity.v1.HubService.UpdateHub] |
458 | 460 | method. |
@@ -539,17 +541,17 @@ async def update_hub( |
539 | 541 |
|
540 | 542 | async def delete_hub( |
541 | 543 | self, |
542 | | - request: hub.DeleteHubRequest = None, |
| 544 | + request: Union[hub.DeleteHubRequest, dict] = None, |
543 | 545 | *, |
544 | 546 | name: str = None, |
545 | | - retry: retries.Retry = gapic_v1.method.DEFAULT, |
| 547 | + retry: OptionalRetry = gapic_v1.method.DEFAULT, |
546 | 548 | timeout: float = None, |
547 | 549 | metadata: Sequence[Tuple[str, str]] = (), |
548 | 550 | ) -> operation_async.AsyncOperation: |
549 | 551 | r"""Deletes the specified hub. |
550 | 552 |
|
551 | 553 | Args: |
552 | | - request (:class:`google.cloud.networkconnectivity_v1.types.DeleteHubRequest`): |
| 554 | + request (Union[google.cloud.networkconnectivity_v1.types.DeleteHubRequest, dict]): |
553 | 555 | The request object. The request for |
554 | 556 | [HubService.DeleteHub][google.cloud.networkconnectivity.v1.HubService.DeleteHub]. |
555 | 557 | name (:class:`str`): |
@@ -631,18 +633,18 @@ async def delete_hub( |
631 | 633 |
|
632 | 634 | async def list_spokes( |
633 | 635 | self, |
634 | | - request: hub.ListSpokesRequest = None, |
| 636 | + request: Union[hub.ListSpokesRequest, dict] = None, |
635 | 637 | *, |
636 | 638 | parent: str = None, |
637 | | - retry: retries.Retry = gapic_v1.method.DEFAULT, |
| 639 | + retry: OptionalRetry = gapic_v1.method.DEFAULT, |
638 | 640 | timeout: float = None, |
639 | 641 | metadata: Sequence[Tuple[str, str]] = (), |
640 | 642 | ) -> pagers.ListSpokesAsyncPager: |
641 | 643 | r"""Lists the spokes in the specified project and |
642 | 644 | location. |
643 | 645 |
|
644 | 646 | Args: |
645 | | - request (:class:`google.cloud.networkconnectivity_v1.types.ListSpokesRequest`): |
| 647 | + request (Union[google.cloud.networkconnectivity_v1.types.ListSpokesRequest, dict]): |
646 | 648 | The request object. The request for |
647 | 649 | [HubService.ListSpokes][google.cloud.networkconnectivity.v1.HubService.ListSpokes]. |
648 | 650 | parent (:class:`str`): |
@@ -710,17 +712,17 @@ async def list_spokes( |
710 | 712 |
|
711 | 713 | async def get_spoke( |
712 | 714 | self, |
713 | | - request: hub.GetSpokeRequest = None, |
| 715 | + request: Union[hub.GetSpokeRequest, dict] = None, |
714 | 716 | *, |
715 | 717 | name: str = None, |
716 | | - retry: retries.Retry = gapic_v1.method.DEFAULT, |
| 718 | + retry: OptionalRetry = gapic_v1.method.DEFAULT, |
717 | 719 | timeout: float = None, |
718 | 720 | metadata: Sequence[Tuple[str, str]] = (), |
719 | 721 | ) -> hub.Spoke: |
720 | 722 | r"""Gets details about the specified spoke. |
721 | 723 |
|
722 | 724 | Args: |
723 | | - request (:class:`google.cloud.networkconnectivity_v1.types.GetSpokeRequest`): |
| 725 | + request (Union[google.cloud.networkconnectivity_v1.types.GetSpokeRequest, dict]): |
724 | 726 | The request object. The request for |
725 | 727 | [HubService.GetSpoke][google.cloud.networkconnectivity.v1.HubService.GetSpoke]. |
726 | 728 | name (:class:`str`): |
@@ -789,20 +791,20 @@ async def get_spoke( |
789 | 791 |
|
790 | 792 | async def create_spoke( |
791 | 793 | self, |
792 | | - request: hub.CreateSpokeRequest = None, |
| 794 | + request: Union[hub.CreateSpokeRequest, dict] = None, |
793 | 795 | *, |
794 | 796 | parent: str = None, |
795 | 797 | spoke: hub.Spoke = None, |
796 | 798 | spoke_id: str = None, |
797 | | - retry: retries.Retry = gapic_v1.method.DEFAULT, |
| 799 | + retry: OptionalRetry = gapic_v1.method.DEFAULT, |
798 | 800 | timeout: float = None, |
799 | 801 | metadata: Sequence[Tuple[str, str]] = (), |
800 | 802 | ) -> operation_async.AsyncOperation: |
801 | 803 | r"""Creates a spoke in the specified project and |
802 | 804 | location. |
803 | 805 |
|
804 | 806 | Args: |
805 | | - request (:class:`google.cloud.networkconnectivity_v1.types.CreateSpokeRequest`): |
| 807 | + request (Union[google.cloud.networkconnectivity_v1.types.CreateSpokeRequest, dict]): |
806 | 808 | The request object. The request for |
807 | 809 | [HubService.CreateSpoke][google.cloud.networkconnectivity.v1.HubService.CreateSpoke]. |
808 | 810 | parent (:class:`str`): |
@@ -897,18 +899,18 @@ async def create_spoke( |
897 | 899 |
|
898 | 900 | async def update_spoke( |
899 | 901 | self, |
900 | | - request: hub.UpdateSpokeRequest = None, |
| 902 | + request: Union[hub.UpdateSpokeRequest, dict] = None, |
901 | 903 | *, |
902 | 904 | spoke: hub.Spoke = None, |
903 | 905 | update_mask: field_mask_pb2.FieldMask = None, |
904 | | - retry: retries.Retry = gapic_v1.method.DEFAULT, |
| 906 | + retry: OptionalRetry = gapic_v1.method.DEFAULT, |
905 | 907 | timeout: float = None, |
906 | 908 | metadata: Sequence[Tuple[str, str]] = (), |
907 | 909 | ) -> operation_async.AsyncOperation: |
908 | 910 | r"""Updates the parameters of the specified spoke. |
909 | 911 |
|
910 | 912 | Args: |
911 | | - request (:class:`google.cloud.networkconnectivity_v1.types.UpdateSpokeRequest`): |
| 913 | + request (Union[google.cloud.networkconnectivity_v1.types.UpdateSpokeRequest, dict]): |
912 | 914 | The request object. Request for |
913 | 915 | [HubService.UpdateSpoke][google.cloud.networkconnectivity.v1.HubService.UpdateSpoke] |
914 | 916 | method. |
@@ -1003,17 +1005,17 @@ async def update_spoke( |
1003 | 1005 |
|
1004 | 1006 | async def delete_spoke( |
1005 | 1007 | self, |
1006 | | - request: hub.DeleteSpokeRequest = None, |
| 1008 | + request: Union[hub.DeleteSpokeRequest, dict] = None, |
1007 | 1009 | *, |
1008 | 1010 | name: str = None, |
1009 | | - retry: retries.Retry = gapic_v1.method.DEFAULT, |
| 1011 | + retry: OptionalRetry = gapic_v1.method.DEFAULT, |
1010 | 1012 | timeout: float = None, |
1011 | 1013 | metadata: Sequence[Tuple[str, str]] = (), |
1012 | 1014 | ) -> operation_async.AsyncOperation: |
1013 | 1015 | r"""Deletes the specified spoke. |
1014 | 1016 |
|
1015 | 1017 | Args: |
1016 | | - request (:class:`google.cloud.networkconnectivity_v1.types.DeleteSpokeRequest`): |
| 1018 | + request (Union[google.cloud.networkconnectivity_v1.types.DeleteSpokeRequest, dict]): |
1017 | 1019 | The request object. The request for |
1018 | 1020 | [HubService.DeleteSpoke][google.cloud.networkconnectivity.v1.HubService.DeleteSpoke]. |
1019 | 1021 | name (:class:`str`): |
|
0 commit comments