|
16 | 16 | from collections import OrderedDict |
17 | 17 | import functools |
18 | 18 | import re |
19 | | -from typing import Dict, Mapping, Optional, Sequence, Tuple, Type, Union |
| 19 | +from typing import ( |
| 20 | + Dict, |
| 21 | + Mapping, |
| 22 | + MutableMapping, |
| 23 | + MutableSequence, |
| 24 | + Optional, |
| 25 | + Sequence, |
| 26 | + Tuple, |
| 27 | + Type, |
| 28 | + Union, |
| 29 | +) |
20 | 30 |
|
21 | 31 | from google.api_core import exceptions as core_exceptions |
22 | 32 | from google.api_core import gapic_v1 |
@@ -180,9 +190,9 @@ def transport(self) -> CloudRedisTransport: |
180 | 190 | def __init__( |
181 | 191 | self, |
182 | 192 | *, |
183 | | - credentials: ga_credentials.Credentials = None, |
| 193 | + credentials: Optional[ga_credentials.Credentials] = None, |
184 | 194 | transport: Union[str, CloudRedisTransport] = "grpc_asyncio", |
185 | | - client_options: ClientOptions = None, |
| 195 | + client_options: Optional[ClientOptions] = None, |
186 | 196 | client_info: gapic_v1.client_info.ClientInfo = DEFAULT_CLIENT_INFO, |
187 | 197 | ) -> None: |
188 | 198 | """Instantiates the cloud redis client. |
@@ -226,11 +236,11 @@ def __init__( |
226 | 236 |
|
227 | 237 | async def list_instances( |
228 | 238 | self, |
229 | | - request: Union[cloud_redis.ListInstancesRequest, dict] = None, |
| 239 | + request: Optional[Union[cloud_redis.ListInstancesRequest, dict]] = None, |
230 | 240 | *, |
231 | | - parent: str = None, |
| 241 | + parent: Optional[str] = None, |
232 | 242 | retry: OptionalRetry = gapic_v1.method.DEFAULT, |
233 | | - timeout: float = None, |
| 243 | + timeout: Optional[float] = None, |
234 | 244 | metadata: Sequence[Tuple[str, str]] = (), |
235 | 245 | ) -> pagers.ListInstancesAsyncPager: |
236 | 246 | r"""Lists all Redis instances owned by a project in either the |
@@ -272,7 +282,7 @@ async def sample_list_instances(): |
272 | 282 | print(response) |
273 | 283 |
|
274 | 284 | Args: |
275 | | - request (Union[google.cloud.redis_v1.types.ListInstancesRequest, dict]): |
| 285 | + request (Optional[Union[google.cloud.redis_v1.types.ListInstancesRequest, dict]]): |
276 | 286 | The request object. Request for |
277 | 287 | [ListInstances][google.cloud.redis.v1.CloudRedis.ListInstances]. |
278 | 288 | parent (:class:`str`): |
@@ -352,11 +362,11 @@ async def sample_list_instances(): |
352 | 362 |
|
353 | 363 | async def get_instance( |
354 | 364 | self, |
355 | | - request: Union[cloud_redis.GetInstanceRequest, dict] = None, |
| 365 | + request: Optional[Union[cloud_redis.GetInstanceRequest, dict]] = None, |
356 | 366 | *, |
357 | | - name: str = None, |
| 367 | + name: Optional[str] = None, |
358 | 368 | retry: OptionalRetry = gapic_v1.method.DEFAULT, |
359 | | - timeout: float = None, |
| 369 | + timeout: Optional[float] = None, |
360 | 370 | metadata: Sequence[Tuple[str, str]] = (), |
361 | 371 | ) -> cloud_redis.Instance: |
362 | 372 | r"""Gets the details of a specific Redis instance. |
@@ -388,7 +398,7 @@ async def sample_get_instance(): |
388 | 398 | print(response) |
389 | 399 |
|
390 | 400 | Args: |
391 | | - request (Union[google.cloud.redis_v1.types.GetInstanceRequest, dict]): |
| 401 | + request (Optional[Union[google.cloud.redis_v1.types.GetInstanceRequest, dict]]): |
392 | 402 | The request object. Request for |
393 | 403 | [GetInstance][google.cloud.redis.v1.CloudRedis.GetInstance]. |
394 | 404 | name (:class:`str`): |
@@ -453,11 +463,11 @@ async def sample_get_instance(): |
453 | 463 |
|
454 | 464 | async def get_instance_auth_string( |
455 | 465 | self, |
456 | | - request: Union[cloud_redis.GetInstanceAuthStringRequest, dict] = None, |
| 466 | + request: Optional[Union[cloud_redis.GetInstanceAuthStringRequest, dict]] = None, |
457 | 467 | *, |
458 | | - name: str = None, |
| 468 | + name: Optional[str] = None, |
459 | 469 | retry: OptionalRetry = gapic_v1.method.DEFAULT, |
460 | | - timeout: float = None, |
| 470 | + timeout: Optional[float] = None, |
461 | 471 | metadata: Sequence[Tuple[str, str]] = (), |
462 | 472 | ) -> cloud_redis.InstanceAuthString: |
463 | 473 | r"""Gets the AUTH string for a Redis instance. If AUTH is |
@@ -492,7 +502,7 @@ async def sample_get_instance_auth_string(): |
492 | 502 | print(response) |
493 | 503 |
|
494 | 504 | Args: |
495 | | - request (Union[google.cloud.redis_v1.types.GetInstanceAuthStringRequest, dict]): |
| 505 | + request (Optional[Union[google.cloud.redis_v1.types.GetInstanceAuthStringRequest, dict]]): |
496 | 506 | The request object. Request for |
497 | 507 | [GetInstanceAuthString][google.cloud.redis.v1.CloudRedis.GetInstanceAuthString]. |
498 | 508 | name (:class:`str`): |
@@ -557,13 +567,13 @@ async def sample_get_instance_auth_string(): |
557 | 567 |
|
558 | 568 | async def create_instance( |
559 | 569 | self, |
560 | | - request: Union[cloud_redis.CreateInstanceRequest, dict] = None, |
| 570 | + request: Optional[Union[cloud_redis.CreateInstanceRequest, dict]] = None, |
561 | 571 | *, |
562 | | - parent: str = None, |
563 | | - instance_id: str = None, |
564 | | - instance: cloud_redis.Instance = None, |
| 572 | + parent: Optional[str] = None, |
| 573 | + instance_id: Optional[str] = None, |
| 574 | + instance: Optional[cloud_redis.Instance] = None, |
565 | 575 | retry: OptionalRetry = gapic_v1.method.DEFAULT, |
566 | | - timeout: float = None, |
| 576 | + timeout: Optional[float] = None, |
567 | 577 | metadata: Sequence[Tuple[str, str]] = (), |
568 | 578 | ) -> operation_async.AsyncOperation: |
569 | 579 | r"""Creates a Redis instance based on the specified tier and memory |
@@ -619,7 +629,7 @@ async def sample_create_instance(): |
619 | 629 | print(response) |
620 | 630 |
|
621 | 631 | Args: |
622 | | - request (Union[google.cloud.redis_v1.types.CreateInstanceRequest, dict]): |
| 632 | + request (Optional[Union[google.cloud.redis_v1.types.CreateInstanceRequest, dict]]): |
623 | 633 | The request object. Request for |
624 | 634 | [CreateInstance][google.cloud.redis.v1.CloudRedis.CreateInstance]. |
625 | 635 | parent (:class:`str`): |
@@ -721,12 +731,12 @@ async def sample_create_instance(): |
721 | 731 |
|
722 | 732 | async def update_instance( |
723 | 733 | self, |
724 | | - request: Union[cloud_redis.UpdateInstanceRequest, dict] = None, |
| 734 | + request: Optional[Union[cloud_redis.UpdateInstanceRequest, dict]] = None, |
725 | 735 | *, |
726 | | - update_mask: field_mask_pb2.FieldMask = None, |
727 | | - instance: cloud_redis.Instance = None, |
| 736 | + update_mask: Optional[field_mask_pb2.FieldMask] = None, |
| 737 | + instance: Optional[cloud_redis.Instance] = None, |
728 | 738 | retry: OptionalRetry = gapic_v1.method.DEFAULT, |
729 | | - timeout: float = None, |
| 739 | + timeout: Optional[float] = None, |
730 | 740 | metadata: Sequence[Tuple[str, str]] = (), |
731 | 741 | ) -> operation_async.AsyncOperation: |
732 | 742 | r"""Updates the metadata and configuration of a specific |
@@ -772,7 +782,7 @@ async def sample_update_instance(): |
772 | 782 | print(response) |
773 | 783 |
|
774 | 784 | Args: |
775 | | - request (Union[google.cloud.redis_v1.types.UpdateInstanceRequest, dict]): |
| 785 | + request (Optional[Union[google.cloud.redis_v1.types.UpdateInstanceRequest, dict]]): |
776 | 786 | The request object. Request for |
777 | 787 | [UpdateInstance][google.cloud.redis.v1.CloudRedis.UpdateInstance]. |
778 | 788 | update_mask (:class:`google.protobuf.field_mask_pb2.FieldMask`): |
@@ -868,12 +878,12 @@ async def sample_update_instance(): |
868 | 878 |
|
869 | 879 | async def upgrade_instance( |
870 | 880 | self, |
871 | | - request: Union[cloud_redis.UpgradeInstanceRequest, dict] = None, |
| 881 | + request: Optional[Union[cloud_redis.UpgradeInstanceRequest, dict]] = None, |
872 | 882 | *, |
873 | | - name: str = None, |
874 | | - redis_version: str = None, |
| 883 | + name: Optional[str] = None, |
| 884 | + redis_version: Optional[str] = None, |
875 | 885 | retry: OptionalRetry = gapic_v1.method.DEFAULT, |
876 | | - timeout: float = None, |
| 886 | + timeout: Optional[float] = None, |
877 | 887 | metadata: Sequence[Tuple[str, str]] = (), |
878 | 888 | ) -> operation_async.AsyncOperation: |
879 | 889 | r"""Upgrades Redis instance to the newer Redis version |
@@ -911,7 +921,7 @@ async def sample_upgrade_instance(): |
911 | 921 | print(response) |
912 | 922 |
|
913 | 923 | Args: |
914 | | - request (Union[google.cloud.redis_v1.types.UpgradeInstanceRequest, dict]): |
| 924 | + request (Optional[Union[google.cloud.redis_v1.types.UpgradeInstanceRequest, dict]]): |
915 | 925 | The request object. Request for |
916 | 926 | [UpgradeInstance][google.cloud.redis.v1.CloudRedis.UpgradeInstance]. |
917 | 927 | name (:class:`str`): |
@@ -998,12 +1008,12 @@ async def sample_upgrade_instance(): |
998 | 1008 |
|
999 | 1009 | async def import_instance( |
1000 | 1010 | self, |
1001 | | - request: Union[cloud_redis.ImportInstanceRequest, dict] = None, |
| 1011 | + request: Optional[Union[cloud_redis.ImportInstanceRequest, dict]] = None, |
1002 | 1012 | *, |
1003 | | - name: str = None, |
1004 | | - input_config: cloud_redis.InputConfig = None, |
| 1013 | + name: Optional[str] = None, |
| 1014 | + input_config: Optional[cloud_redis.InputConfig] = None, |
1005 | 1015 | retry: OptionalRetry = gapic_v1.method.DEFAULT, |
1006 | | - timeout: float = None, |
| 1016 | + timeout: Optional[float] = None, |
1007 | 1017 | metadata: Sequence[Tuple[str, str]] = (), |
1008 | 1018 | ) -> operation_async.AsyncOperation: |
1009 | 1019 | r"""Import a Redis RDB snapshot file from Cloud Storage |
@@ -1051,7 +1061,7 @@ async def sample_import_instance(): |
1051 | 1061 | print(response) |
1052 | 1062 |
|
1053 | 1063 | Args: |
1054 | | - request (Union[google.cloud.redis_v1.types.ImportInstanceRequest, dict]): |
| 1064 | + request (Optional[Union[google.cloud.redis_v1.types.ImportInstanceRequest, dict]]): |
1055 | 1065 | The request object. Request for |
1056 | 1066 | [Import][google.cloud.redis.v1.CloudRedis.ImportInstance]. |
1057 | 1067 | name (:class:`str`): |
@@ -1138,12 +1148,12 @@ async def sample_import_instance(): |
1138 | 1148 |
|
1139 | 1149 | async def export_instance( |
1140 | 1150 | self, |
1141 | | - request: Union[cloud_redis.ExportInstanceRequest, dict] = None, |
| 1151 | + request: Optional[Union[cloud_redis.ExportInstanceRequest, dict]] = None, |
1142 | 1152 | *, |
1143 | | - name: str = None, |
1144 | | - output_config: cloud_redis.OutputConfig = None, |
| 1153 | + name: Optional[str] = None, |
| 1154 | + output_config: Optional[cloud_redis.OutputConfig] = None, |
1145 | 1155 | retry: OptionalRetry = gapic_v1.method.DEFAULT, |
1146 | | - timeout: float = None, |
| 1156 | + timeout: Optional[float] = None, |
1147 | 1157 | metadata: Sequence[Tuple[str, str]] = (), |
1148 | 1158 | ) -> operation_async.AsyncOperation: |
1149 | 1159 | r"""Export Redis instance data into a Redis RDB format |
@@ -1187,7 +1197,7 @@ async def sample_export_instance(): |
1187 | 1197 | print(response) |
1188 | 1198 |
|
1189 | 1199 | Args: |
1190 | | - request (Union[google.cloud.redis_v1.types.ExportInstanceRequest, dict]): |
| 1200 | + request (Optional[Union[google.cloud.redis_v1.types.ExportInstanceRequest, dict]]): |
1191 | 1201 | The request object. Request for |
1192 | 1202 | [Export][google.cloud.redis.v1.CloudRedis.ExportInstance]. |
1193 | 1203 | name (:class:`str`): |
@@ -1274,12 +1284,14 @@ async def sample_export_instance(): |
1274 | 1284 |
|
1275 | 1285 | async def failover_instance( |
1276 | 1286 | self, |
1277 | | - request: Union[cloud_redis.FailoverInstanceRequest, dict] = None, |
| 1287 | + request: Optional[Union[cloud_redis.FailoverInstanceRequest, dict]] = None, |
1278 | 1288 | *, |
1279 | | - name: str = None, |
1280 | | - data_protection_mode: cloud_redis.FailoverInstanceRequest.DataProtectionMode = None, |
| 1289 | + name: Optional[str] = None, |
| 1290 | + data_protection_mode: Optional[ |
| 1291 | + cloud_redis.FailoverInstanceRequest.DataProtectionMode |
| 1292 | + ] = None, |
1281 | 1293 | retry: OptionalRetry = gapic_v1.method.DEFAULT, |
1282 | | - timeout: float = None, |
| 1294 | + timeout: Optional[float] = None, |
1283 | 1295 | metadata: Sequence[Tuple[str, str]] = (), |
1284 | 1296 | ) -> operation_async.AsyncOperation: |
1285 | 1297 | r"""Initiates a failover of the primary node to current |
@@ -1317,7 +1329,7 @@ async def sample_failover_instance(): |
1317 | 1329 | print(response) |
1318 | 1330 |
|
1319 | 1331 | Args: |
1320 | | - request (Union[google.cloud.redis_v1.types.FailoverInstanceRequest, dict]): |
| 1332 | + request (Optional[Union[google.cloud.redis_v1.types.FailoverInstanceRequest, dict]]): |
1321 | 1333 | The request object. Request for |
1322 | 1334 | [Failover][google.cloud.redis.v1.CloudRedis.FailoverInstance]. |
1323 | 1335 | name (:class:`str`): |
@@ -1405,11 +1417,11 @@ async def sample_failover_instance(): |
1405 | 1417 |
|
1406 | 1418 | async def delete_instance( |
1407 | 1419 | self, |
1408 | | - request: Union[cloud_redis.DeleteInstanceRequest, dict] = None, |
| 1420 | + request: Optional[Union[cloud_redis.DeleteInstanceRequest, dict]] = None, |
1409 | 1421 | *, |
1410 | | - name: str = None, |
| 1422 | + name: Optional[str] = None, |
1411 | 1423 | retry: OptionalRetry = gapic_v1.method.DEFAULT, |
1412 | | - timeout: float = None, |
| 1424 | + timeout: Optional[float] = None, |
1413 | 1425 | metadata: Sequence[Tuple[str, str]] = (), |
1414 | 1426 | ) -> operation_async.AsyncOperation: |
1415 | 1427 | r"""Deletes a specific Redis instance. Instance stops |
@@ -1446,7 +1458,7 @@ async def sample_delete_instance(): |
1446 | 1458 | print(response) |
1447 | 1459 |
|
1448 | 1460 | Args: |
1449 | | - request (Union[google.cloud.redis_v1.types.DeleteInstanceRequest, dict]): |
| 1461 | + request (Optional[Union[google.cloud.redis_v1.types.DeleteInstanceRequest, dict]]): |
1450 | 1462 | The request object. Request for |
1451 | 1463 | [DeleteInstance][google.cloud.redis.v1.CloudRedis.DeleteInstance]. |
1452 | 1464 | name (:class:`str`): |
@@ -1531,13 +1543,15 @@ async def sample_delete_instance(): |
1531 | 1543 |
|
1532 | 1544 | async def reschedule_maintenance( |
1533 | 1545 | self, |
1534 | | - request: Union[cloud_redis.RescheduleMaintenanceRequest, dict] = None, |
| 1546 | + request: Optional[Union[cloud_redis.RescheduleMaintenanceRequest, dict]] = None, |
1535 | 1547 | *, |
1536 | | - name: str = None, |
1537 | | - reschedule_type: cloud_redis.RescheduleMaintenanceRequest.RescheduleType = None, |
1538 | | - schedule_time: timestamp_pb2.Timestamp = None, |
| 1548 | + name: Optional[str] = None, |
| 1549 | + reschedule_type: Optional[ |
| 1550 | + cloud_redis.RescheduleMaintenanceRequest.RescheduleType |
| 1551 | + ] = None, |
| 1552 | + schedule_time: Optional[timestamp_pb2.Timestamp] = None, |
1539 | 1553 | retry: OptionalRetry = gapic_v1.method.DEFAULT, |
1540 | | - timeout: float = None, |
| 1554 | + timeout: Optional[float] = None, |
1541 | 1555 | metadata: Sequence[Tuple[str, str]] = (), |
1542 | 1556 | ) -> operation_async.AsyncOperation: |
1543 | 1557 | r"""Reschedule maintenance for a given instance in a |
@@ -1575,7 +1589,7 @@ async def sample_reschedule_maintenance(): |
1575 | 1589 | print(response) |
1576 | 1590 |
|
1577 | 1591 | Args: |
1578 | | - request (Union[google.cloud.redis_v1.types.RescheduleMaintenanceRequest, dict]): |
| 1592 | + request (Optional[Union[google.cloud.redis_v1.types.RescheduleMaintenanceRequest, dict]]): |
1579 | 1593 | The request object. Request for |
1580 | 1594 | [RescheduleMaintenance][google.cloud.redis.v1.CloudRedis.RescheduleMaintenance]. |
1581 | 1595 | name (:class:`str`): |
|
0 commit comments