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