1"""Generated client library for storage version v1.""" 2# NOTE: This file is autogenerated and should not be edited by hand. 3from apitools.base.py import base_api 4from samples.storage_sample.storage_v1 import storage_v1_messages as messages 5 6 7class StorageV1(base_api.BaseApiClient): 8 """Generated client library for service storage version v1.""" 9 10 MESSAGES_MODULE = messages 11 BASE_URL = u'https://www.googleapis.com/storage/v1/' 12 MTLS_BASE_URL = u'https://www.mtls.googleapis.com/storage/v1/' 13 14 _PACKAGE = u'storage' 15 _SCOPES = [u'https://www.googleapis.com/auth/cloud-platform', u'https://www.googleapis.com/auth/cloud-platform.read-only', u'https://www.googleapis.com/auth/devstorage.full_control', u'https://www.googleapis.com/auth/devstorage.read_only', u'https://www.googleapis.com/auth/devstorage.read_write'] 16 _VERSION = u'v1' 17 _CLIENT_ID = '1042881264118.apps.googleusercontent.com' 18 _CLIENT_SECRET = 'x_Tw5K8nnjoRAqULM9PFAC2b' 19 _USER_AGENT = 'x_Tw5K8nnjoRAqULM9PFAC2b' 20 _CLIENT_CLASS_NAME = u'StorageV1' 21 _URL_VERSION = u'v1' 22 _API_KEY = None 23 24 def __init__(self, url='', credentials=None, 25 get_credentials=True, http=None, model=None, 26 log_request=False, log_response=False, 27 credentials_args=None, default_global_params=None, 28 additional_http_headers=None, response_encoding=None): 29 """Create a new storage handle.""" 30 url = url or self.BASE_URL 31 super(StorageV1, self).__init__( 32 url, credentials=credentials, 33 get_credentials=get_credentials, http=http, model=model, 34 log_request=log_request, log_response=log_response, 35 credentials_args=credentials_args, 36 default_global_params=default_global_params, 37 additional_http_headers=additional_http_headers, 38 response_encoding=response_encoding) 39 self.bucketAccessControls = self.BucketAccessControlsService(self) 40 self.buckets = self.BucketsService(self) 41 self.channels = self.ChannelsService(self) 42 self.defaultObjectAccessControls = self.DefaultObjectAccessControlsService(self) 43 self.notifications = self.NotificationsService(self) 44 self.objectAccessControls = self.ObjectAccessControlsService(self) 45 self.objects = self.ObjectsService(self) 46 47 class BucketAccessControlsService(base_api.BaseApiService): 48 """Service class for the bucketAccessControls resource.""" 49 50 _NAME = u'bucketAccessControls' 51 52 def __init__(self, client): 53 super(StorageV1.BucketAccessControlsService, self).__init__(client) 54 self._upload_configs = { 55 } 56 57 def Delete(self, request, global_params=None): 58 r"""Permanently deletes the ACL entry for the specified entity on the specified bucket. 59 60 Args: 61 request: (StorageBucketAccessControlsDeleteRequest) input message 62 global_params: (StandardQueryParameters, default: None) global arguments 63 Returns: 64 (StorageBucketAccessControlsDeleteResponse) The response message. 65 """ 66 config = self.GetMethodConfig('Delete') 67 return self._RunMethod( 68 config, request, global_params=global_params) 69 70 Delete.method_config = lambda: base_api.ApiMethodInfo( 71 http_method=u'DELETE', 72 method_id=u'storage.bucketAccessControls.delete', 73 ordered_params=[u'bucket', u'entity'], 74 path_params=[u'bucket', u'entity'], 75 query_params=[], 76 relative_path=u'b/{bucket}/acl/{entity}', 77 request_field='', 78 request_type_name=u'StorageBucketAccessControlsDeleteRequest', 79 response_type_name=u'StorageBucketAccessControlsDeleteResponse', 80 supports_download=False, 81 ) 82 83 def Get(self, request, global_params=None): 84 r"""Returns the ACL entry for the specified entity on the specified bucket. 85 86 Args: 87 request: (StorageBucketAccessControlsGetRequest) input message 88 global_params: (StandardQueryParameters, default: None) global arguments 89 Returns: 90 (BucketAccessControl) The response message. 91 """ 92 config = self.GetMethodConfig('Get') 93 return self._RunMethod( 94 config, request, global_params=global_params) 95 96 Get.method_config = lambda: base_api.ApiMethodInfo( 97 http_method=u'GET', 98 method_id=u'storage.bucketAccessControls.get', 99 ordered_params=[u'bucket', u'entity'], 100 path_params=[u'bucket', u'entity'], 101 query_params=[], 102 relative_path=u'b/{bucket}/acl/{entity}', 103 request_field='', 104 request_type_name=u'StorageBucketAccessControlsGetRequest', 105 response_type_name=u'BucketAccessControl', 106 supports_download=False, 107 ) 108 109 def Insert(self, request, global_params=None): 110 r"""Creates a new ACL entry on the specified bucket. 111 112 Args: 113 request: (BucketAccessControl) input message 114 global_params: (StandardQueryParameters, default: None) global arguments 115 Returns: 116 (BucketAccessControl) The response message. 117 """ 118 config = self.GetMethodConfig('Insert') 119 return self._RunMethod( 120 config, request, global_params=global_params) 121 122 Insert.method_config = lambda: base_api.ApiMethodInfo( 123 http_method=u'POST', 124 method_id=u'storage.bucketAccessControls.insert', 125 ordered_params=[u'bucket'], 126 path_params=[u'bucket'], 127 query_params=[], 128 relative_path=u'b/{bucket}/acl', 129 request_field='<request>', 130 request_type_name=u'BucketAccessControl', 131 response_type_name=u'BucketAccessControl', 132 supports_download=False, 133 ) 134 135 def List(self, request, global_params=None): 136 r"""Retrieves ACL entries on the specified bucket. 137 138 Args: 139 request: (StorageBucketAccessControlsListRequest) input message 140 global_params: (StandardQueryParameters, default: None) global arguments 141 Returns: 142 (BucketAccessControls) The response message. 143 """ 144 config = self.GetMethodConfig('List') 145 return self._RunMethod( 146 config, request, global_params=global_params) 147 148 List.method_config = lambda: base_api.ApiMethodInfo( 149 http_method=u'GET', 150 method_id=u'storage.bucketAccessControls.list', 151 ordered_params=[u'bucket'], 152 path_params=[u'bucket'], 153 query_params=[], 154 relative_path=u'b/{bucket}/acl', 155 request_field='', 156 request_type_name=u'StorageBucketAccessControlsListRequest', 157 response_type_name=u'BucketAccessControls', 158 supports_download=False, 159 ) 160 161 def Patch(self, request, global_params=None): 162 r"""Updates an ACL entry on the specified bucket. This method supports patch semantics. 163 164 Args: 165 request: (BucketAccessControl) input message 166 global_params: (StandardQueryParameters, default: None) global arguments 167 Returns: 168 (BucketAccessControl) The response message. 169 """ 170 config = self.GetMethodConfig('Patch') 171 return self._RunMethod( 172 config, request, global_params=global_params) 173 174 Patch.method_config = lambda: base_api.ApiMethodInfo( 175 http_method=u'PATCH', 176 method_id=u'storage.bucketAccessControls.patch', 177 ordered_params=[u'bucket', u'entity'], 178 path_params=[u'bucket', u'entity'], 179 query_params=[], 180 relative_path=u'b/{bucket}/acl/{entity}', 181 request_field='<request>', 182 request_type_name=u'BucketAccessControl', 183 response_type_name=u'BucketAccessControl', 184 supports_download=False, 185 ) 186 187 def Update(self, request, global_params=None): 188 r"""Updates an ACL entry on the specified bucket. 189 190 Args: 191 request: (BucketAccessControl) input message 192 global_params: (StandardQueryParameters, default: None) global arguments 193 Returns: 194 (BucketAccessControl) The response message. 195 """ 196 config = self.GetMethodConfig('Update') 197 return self._RunMethod( 198 config, request, global_params=global_params) 199 200 Update.method_config = lambda: base_api.ApiMethodInfo( 201 http_method=u'PUT', 202 method_id=u'storage.bucketAccessControls.update', 203 ordered_params=[u'bucket', u'entity'], 204 path_params=[u'bucket', u'entity'], 205 query_params=[], 206 relative_path=u'b/{bucket}/acl/{entity}', 207 request_field='<request>', 208 request_type_name=u'BucketAccessControl', 209 response_type_name=u'BucketAccessControl', 210 supports_download=False, 211 ) 212 213 class BucketsService(base_api.BaseApiService): 214 """Service class for the buckets resource.""" 215 216 _NAME = u'buckets' 217 218 def __init__(self, client): 219 super(StorageV1.BucketsService, self).__init__(client) 220 self._upload_configs = { 221 } 222 223 def Delete(self, request, global_params=None): 224 r"""Permanently deletes an empty bucket. 225 226 Args: 227 request: (StorageBucketsDeleteRequest) input message 228 global_params: (StandardQueryParameters, default: None) global arguments 229 Returns: 230 (StorageBucketsDeleteResponse) The response message. 231 """ 232 config = self.GetMethodConfig('Delete') 233 return self._RunMethod( 234 config, request, global_params=global_params) 235 236 Delete.method_config = lambda: base_api.ApiMethodInfo( 237 http_method=u'DELETE', 238 method_id=u'storage.buckets.delete', 239 ordered_params=[u'bucket'], 240 path_params=[u'bucket'], 241 query_params=[u'ifMetagenerationMatch', u'ifMetagenerationNotMatch'], 242 relative_path=u'b/{bucket}', 243 request_field='', 244 request_type_name=u'StorageBucketsDeleteRequest', 245 response_type_name=u'StorageBucketsDeleteResponse', 246 supports_download=False, 247 ) 248 249 def Get(self, request, global_params=None): 250 r"""Returns metadata for the specified bucket. 251 252 Args: 253 request: (StorageBucketsGetRequest) input message 254 global_params: (StandardQueryParameters, default: None) global arguments 255 Returns: 256 (Bucket) The response message. 257 """ 258 config = self.GetMethodConfig('Get') 259 return self._RunMethod( 260 config, request, global_params=global_params) 261 262 Get.method_config = lambda: base_api.ApiMethodInfo( 263 http_method=u'GET', 264 method_id=u'storage.buckets.get', 265 ordered_params=[u'bucket'], 266 path_params=[u'bucket'], 267 query_params=[u'ifMetagenerationMatch', u'ifMetagenerationNotMatch', u'projection'], 268 relative_path=u'b/{bucket}', 269 request_field='', 270 request_type_name=u'StorageBucketsGetRequest', 271 response_type_name=u'Bucket', 272 supports_download=False, 273 ) 274 275 def GetIamPolicy(self, request, global_params=None): 276 r"""Returns an IAM policy for the specified bucket. 277 278 Args: 279 request: (StorageBucketsGetIamPolicyRequest) input message 280 global_params: (StandardQueryParameters, default: None) global arguments 281 Returns: 282 (Policy) The response message. 283 """ 284 config = self.GetMethodConfig('GetIamPolicy') 285 return self._RunMethod( 286 config, request, global_params=global_params) 287 288 GetIamPolicy.method_config = lambda: base_api.ApiMethodInfo( 289 http_method=u'GET', 290 method_id=u'storage.buckets.getIamPolicy', 291 ordered_params=[u'bucket'], 292 path_params=[u'bucket'], 293 query_params=[], 294 relative_path=u'b/{bucket}/iam', 295 request_field='', 296 request_type_name=u'StorageBucketsGetIamPolicyRequest', 297 response_type_name=u'Policy', 298 supports_download=False, 299 ) 300 301 def Insert(self, request, global_params=None): 302 r"""Creates a new bucket. 303 304 Args: 305 request: (StorageBucketsInsertRequest) input message 306 global_params: (StandardQueryParameters, default: None) global arguments 307 Returns: 308 (Bucket) The response message. 309 """ 310 config = self.GetMethodConfig('Insert') 311 return self._RunMethod( 312 config, request, global_params=global_params) 313 314 Insert.method_config = lambda: base_api.ApiMethodInfo( 315 http_method=u'POST', 316 method_id=u'storage.buckets.insert', 317 ordered_params=[u'project'], 318 path_params=[], 319 query_params=[u'predefinedAcl', u'predefinedDefaultObjectAcl', u'project', u'projection'], 320 relative_path=u'b', 321 request_field=u'bucket', 322 request_type_name=u'StorageBucketsInsertRequest', 323 response_type_name=u'Bucket', 324 supports_download=False, 325 ) 326 327 def List(self, request, global_params=None): 328 r"""Retrieves a list of buckets for a given project. 329 330 Args: 331 request: (StorageBucketsListRequest) input message 332 global_params: (StandardQueryParameters, default: None) global arguments 333 Returns: 334 (Buckets) The response message. 335 """ 336 config = self.GetMethodConfig('List') 337 return self._RunMethod( 338 config, request, global_params=global_params) 339 340 List.method_config = lambda: base_api.ApiMethodInfo( 341 http_method=u'GET', 342 method_id=u'storage.buckets.list', 343 ordered_params=[u'project'], 344 path_params=[], 345 query_params=[u'maxResults', u'pageToken', u'prefix', u'project', u'projection'], 346 relative_path=u'b', 347 request_field='', 348 request_type_name=u'StorageBucketsListRequest', 349 response_type_name=u'Buckets', 350 supports_download=False, 351 ) 352 353 def Patch(self, request, global_params=None): 354 r"""Updates a bucket. This method supports patch semantics. 355 356 Args: 357 request: (StorageBucketsPatchRequest) input message 358 global_params: (StandardQueryParameters, default: None) global arguments 359 Returns: 360 (Bucket) The response message. 361 """ 362 config = self.GetMethodConfig('Patch') 363 return self._RunMethod( 364 config, request, global_params=global_params) 365 366 Patch.method_config = lambda: base_api.ApiMethodInfo( 367 http_method=u'PATCH', 368 method_id=u'storage.buckets.patch', 369 ordered_params=[u'bucket'], 370 path_params=[u'bucket'], 371 query_params=[u'ifMetagenerationMatch', u'ifMetagenerationNotMatch', u'predefinedAcl', u'predefinedDefaultObjectAcl', u'projection'], 372 relative_path=u'b/{bucket}', 373 request_field=u'bucketResource', 374 request_type_name=u'StorageBucketsPatchRequest', 375 response_type_name=u'Bucket', 376 supports_download=False, 377 ) 378 379 def SetIamPolicy(self, request, global_params=None): 380 r"""Updates an IAM policy for the specified bucket. 381 382 Args: 383 request: (StorageBucketsSetIamPolicyRequest) input message 384 global_params: (StandardQueryParameters, default: None) global arguments 385 Returns: 386 (Policy) The response message. 387 """ 388 config = self.GetMethodConfig('SetIamPolicy') 389 return self._RunMethod( 390 config, request, global_params=global_params) 391 392 SetIamPolicy.method_config = lambda: base_api.ApiMethodInfo( 393 http_method=u'PUT', 394 method_id=u'storage.buckets.setIamPolicy', 395 ordered_params=[u'bucket'], 396 path_params=[u'bucket'], 397 query_params=[], 398 relative_path=u'b/{bucket}/iam', 399 request_field=u'policy', 400 request_type_name=u'StorageBucketsSetIamPolicyRequest', 401 response_type_name=u'Policy', 402 supports_download=False, 403 ) 404 405 def TestIamPermissions(self, request, global_params=None): 406 r"""Tests a set of permissions on the given bucket to see which, if any, are held by the caller. 407 408 Args: 409 request: (StorageBucketsTestIamPermissionsRequest) input message 410 global_params: (StandardQueryParameters, default: None) global arguments 411 Returns: 412 (TestIamPermissionsResponse) The response message. 413 """ 414 config = self.GetMethodConfig('TestIamPermissions') 415 return self._RunMethod( 416 config, request, global_params=global_params) 417 418 TestIamPermissions.method_config = lambda: base_api.ApiMethodInfo( 419 http_method=u'GET', 420 method_id=u'storage.buckets.testIamPermissions', 421 ordered_params=[u'bucket', u'permissions'], 422 path_params=[u'bucket'], 423 query_params=[u'permissions'], 424 relative_path=u'b/{bucket}/iam/testPermissions', 425 request_field='', 426 request_type_name=u'StorageBucketsTestIamPermissionsRequest', 427 response_type_name=u'TestIamPermissionsResponse', 428 supports_download=False, 429 ) 430 431 def Update(self, request, global_params=None): 432 r"""Updates a bucket. 433 434 Args: 435 request: (StorageBucketsUpdateRequest) input message 436 global_params: (StandardQueryParameters, default: None) global arguments 437 Returns: 438 (Bucket) The response message. 439 """ 440 config = self.GetMethodConfig('Update') 441 return self._RunMethod( 442 config, request, global_params=global_params) 443 444 Update.method_config = lambda: base_api.ApiMethodInfo( 445 http_method=u'PUT', 446 method_id=u'storage.buckets.update', 447 ordered_params=[u'bucket'], 448 path_params=[u'bucket'], 449 query_params=[u'ifMetagenerationMatch', u'ifMetagenerationNotMatch', u'predefinedAcl', u'predefinedDefaultObjectAcl', u'projection'], 450 relative_path=u'b/{bucket}', 451 request_field=u'bucketResource', 452 request_type_name=u'StorageBucketsUpdateRequest', 453 response_type_name=u'Bucket', 454 supports_download=False, 455 ) 456 457 class ChannelsService(base_api.BaseApiService): 458 """Service class for the channels resource.""" 459 460 _NAME = u'channels' 461 462 def __init__(self, client): 463 super(StorageV1.ChannelsService, self).__init__(client) 464 self._upload_configs = { 465 } 466 467 def Stop(self, request, global_params=None): 468 r"""Stop watching resources through this channel. 469 470 Args: 471 request: (Channel) input message 472 global_params: (StandardQueryParameters, default: None) global arguments 473 Returns: 474 (StorageChannelsStopResponse) The response message. 475 """ 476 config = self.GetMethodConfig('Stop') 477 return self._RunMethod( 478 config, request, global_params=global_params) 479 480 Stop.method_config = lambda: base_api.ApiMethodInfo( 481 http_method=u'POST', 482 method_id=u'storage.channels.stop', 483 ordered_params=[], 484 path_params=[], 485 query_params=[], 486 relative_path=u'channels/stop', 487 request_field='<request>', 488 request_type_name=u'Channel', 489 response_type_name=u'StorageChannelsStopResponse', 490 supports_download=False, 491 ) 492 493 class DefaultObjectAccessControlsService(base_api.BaseApiService): 494 """Service class for the defaultObjectAccessControls resource.""" 495 496 _NAME = u'defaultObjectAccessControls' 497 498 def __init__(self, client): 499 super(StorageV1.DefaultObjectAccessControlsService, self).__init__(client) 500 self._upload_configs = { 501 } 502 503 def Delete(self, request, global_params=None): 504 r"""Permanently deletes the default object ACL entry for the specified entity on the specified bucket. 505 506 Args: 507 request: (StorageDefaultObjectAccessControlsDeleteRequest) input message 508 global_params: (StandardQueryParameters, default: None) global arguments 509 Returns: 510 (StorageDefaultObjectAccessControlsDeleteResponse) The response message. 511 """ 512 config = self.GetMethodConfig('Delete') 513 return self._RunMethod( 514 config, request, global_params=global_params) 515 516 Delete.method_config = lambda: base_api.ApiMethodInfo( 517 http_method=u'DELETE', 518 method_id=u'storage.defaultObjectAccessControls.delete', 519 ordered_params=[u'bucket', u'entity'], 520 path_params=[u'bucket', u'entity'], 521 query_params=[], 522 relative_path=u'b/{bucket}/defaultObjectAcl/{entity}', 523 request_field='', 524 request_type_name=u'StorageDefaultObjectAccessControlsDeleteRequest', 525 response_type_name=u'StorageDefaultObjectAccessControlsDeleteResponse', 526 supports_download=False, 527 ) 528 529 def Get(self, request, global_params=None): 530 r"""Returns the default object ACL entry for the specified entity on the specified bucket. 531 532 Args: 533 request: (StorageDefaultObjectAccessControlsGetRequest) input message 534 global_params: (StandardQueryParameters, default: None) global arguments 535 Returns: 536 (ObjectAccessControl) The response message. 537 """ 538 config = self.GetMethodConfig('Get') 539 return self._RunMethod( 540 config, request, global_params=global_params) 541 542 Get.method_config = lambda: base_api.ApiMethodInfo( 543 http_method=u'GET', 544 method_id=u'storage.defaultObjectAccessControls.get', 545 ordered_params=[u'bucket', u'entity'], 546 path_params=[u'bucket', u'entity'], 547 query_params=[], 548 relative_path=u'b/{bucket}/defaultObjectAcl/{entity}', 549 request_field='', 550 request_type_name=u'StorageDefaultObjectAccessControlsGetRequest', 551 response_type_name=u'ObjectAccessControl', 552 supports_download=False, 553 ) 554 555 def Insert(self, request, global_params=None): 556 r"""Creates a new default object ACL entry on the specified bucket. 557 558 Args: 559 request: (ObjectAccessControl) input message 560 global_params: (StandardQueryParameters, default: None) global arguments 561 Returns: 562 (ObjectAccessControl) The response message. 563 """ 564 config = self.GetMethodConfig('Insert') 565 return self._RunMethod( 566 config, request, global_params=global_params) 567 568 Insert.method_config = lambda: base_api.ApiMethodInfo( 569 http_method=u'POST', 570 method_id=u'storage.defaultObjectAccessControls.insert', 571 ordered_params=[u'bucket'], 572 path_params=[u'bucket'], 573 query_params=[], 574 relative_path=u'b/{bucket}/defaultObjectAcl', 575 request_field='<request>', 576 request_type_name=u'ObjectAccessControl', 577 response_type_name=u'ObjectAccessControl', 578 supports_download=False, 579 ) 580 581 def List(self, request, global_params=None): 582 r"""Retrieves default object ACL entries on the specified bucket. 583 584 Args: 585 request: (StorageDefaultObjectAccessControlsListRequest) input message 586 global_params: (StandardQueryParameters, default: None) global arguments 587 Returns: 588 (ObjectAccessControls) The response message. 589 """ 590 config = self.GetMethodConfig('List') 591 return self._RunMethod( 592 config, request, global_params=global_params) 593 594 List.method_config = lambda: base_api.ApiMethodInfo( 595 http_method=u'GET', 596 method_id=u'storage.defaultObjectAccessControls.list', 597 ordered_params=[u'bucket'], 598 path_params=[u'bucket'], 599 query_params=[u'ifMetagenerationMatch', u'ifMetagenerationNotMatch'], 600 relative_path=u'b/{bucket}/defaultObjectAcl', 601 request_field='', 602 request_type_name=u'StorageDefaultObjectAccessControlsListRequest', 603 response_type_name=u'ObjectAccessControls', 604 supports_download=False, 605 ) 606 607 def Patch(self, request, global_params=None): 608 r"""Updates a default object ACL entry on the specified bucket. This method supports patch semantics. 609 610 Args: 611 request: (ObjectAccessControl) input message 612 global_params: (StandardQueryParameters, default: None) global arguments 613 Returns: 614 (ObjectAccessControl) The response message. 615 """ 616 config = self.GetMethodConfig('Patch') 617 return self._RunMethod( 618 config, request, global_params=global_params) 619 620 Patch.method_config = lambda: base_api.ApiMethodInfo( 621 http_method=u'PATCH', 622 method_id=u'storage.defaultObjectAccessControls.patch', 623 ordered_params=[u'bucket', u'entity'], 624 path_params=[u'bucket', u'entity'], 625 query_params=[], 626 relative_path=u'b/{bucket}/defaultObjectAcl/{entity}', 627 request_field='<request>', 628 request_type_name=u'ObjectAccessControl', 629 response_type_name=u'ObjectAccessControl', 630 supports_download=False, 631 ) 632 633 def Update(self, request, global_params=None): 634 r"""Updates a default object ACL entry on the specified bucket. 635 636 Args: 637 request: (ObjectAccessControl) input message 638 global_params: (StandardQueryParameters, default: None) global arguments 639 Returns: 640 (ObjectAccessControl) The response message. 641 """ 642 config = self.GetMethodConfig('Update') 643 return self._RunMethod( 644 config, request, global_params=global_params) 645 646 Update.method_config = lambda: base_api.ApiMethodInfo( 647 http_method=u'PUT', 648 method_id=u'storage.defaultObjectAccessControls.update', 649 ordered_params=[u'bucket', u'entity'], 650 path_params=[u'bucket', u'entity'], 651 query_params=[], 652 relative_path=u'b/{bucket}/defaultObjectAcl/{entity}', 653 request_field='<request>', 654 request_type_name=u'ObjectAccessControl', 655 response_type_name=u'ObjectAccessControl', 656 supports_download=False, 657 ) 658 659 class NotificationsService(base_api.BaseApiService): 660 """Service class for the notifications resource.""" 661 662 _NAME = u'notifications' 663 664 def __init__(self, client): 665 super(StorageV1.NotificationsService, self).__init__(client) 666 self._upload_configs = { 667 } 668 669 def Delete(self, request, global_params=None): 670 r"""Permanently deletes a notification subscription. 671 672 Args: 673 request: (StorageNotificationsDeleteRequest) input message 674 global_params: (StandardQueryParameters, default: None) global arguments 675 Returns: 676 (StorageNotificationsDeleteResponse) The response message. 677 """ 678 config = self.GetMethodConfig('Delete') 679 return self._RunMethod( 680 config, request, global_params=global_params) 681 682 Delete.method_config = lambda: base_api.ApiMethodInfo( 683 http_method=u'DELETE', 684 method_id=u'storage.notifications.delete', 685 ordered_params=[u'notification'], 686 path_params=[u'notification'], 687 query_params=[], 688 relative_path=u'notifications/{notification}', 689 request_field='', 690 request_type_name=u'StorageNotificationsDeleteRequest', 691 response_type_name=u'StorageNotificationsDeleteResponse', 692 supports_download=False, 693 ) 694 695 def Get(self, request, global_params=None): 696 r"""View a notification configuration. 697 698 Args: 699 request: (StorageNotificationsGetRequest) input message 700 global_params: (StandardQueryParameters, default: None) global arguments 701 Returns: 702 (Notification) The response message. 703 """ 704 config = self.GetMethodConfig('Get') 705 return self._RunMethod( 706 config, request, global_params=global_params) 707 708 Get.method_config = lambda: base_api.ApiMethodInfo( 709 http_method=u'GET', 710 method_id=u'storage.notifications.get', 711 ordered_params=[u'notification'], 712 path_params=[u'notification'], 713 query_params=[], 714 relative_path=u'notifications/{notification}', 715 request_field='', 716 request_type_name=u'StorageNotificationsGetRequest', 717 response_type_name=u'Notification', 718 supports_download=False, 719 ) 720 721 def Insert(self, request, global_params=None): 722 r"""Creates a notification subscription for a given bucket. 723 724 Args: 725 request: (Notification) input message 726 global_params: (StandardQueryParameters, default: None) global arguments 727 Returns: 728 (Notification) The response message. 729 """ 730 config = self.GetMethodConfig('Insert') 731 return self._RunMethod( 732 config, request, global_params=global_params) 733 734 Insert.method_config = lambda: base_api.ApiMethodInfo( 735 http_method=u'POST', 736 method_id=u'storage.notifications.insert', 737 ordered_params=[], 738 path_params=[], 739 query_params=[], 740 relative_path=u'notifications', 741 request_field='<request>', 742 request_type_name=u'Notification', 743 response_type_name=u'Notification', 744 supports_download=False, 745 ) 746 747 def List(self, request, global_params=None): 748 r"""Retrieves a list of notification subscriptions for a given bucket. 749 750 Args: 751 request: (StorageNotificationsListRequest) input message 752 global_params: (StandardQueryParameters, default: None) global arguments 753 Returns: 754 (Notifications) The response message. 755 """ 756 config = self.GetMethodConfig('List') 757 return self._RunMethod( 758 config, request, global_params=global_params) 759 760 List.method_config = lambda: base_api.ApiMethodInfo( 761 http_method=u'GET', 762 method_id=u'storage.notifications.list', 763 ordered_params=[u'bucket'], 764 path_params=[], 765 query_params=[u'bucket'], 766 relative_path=u'notifications', 767 request_field='', 768 request_type_name=u'StorageNotificationsListRequest', 769 response_type_name=u'Notifications', 770 supports_download=False, 771 ) 772 773 class ObjectAccessControlsService(base_api.BaseApiService): 774 """Service class for the objectAccessControls resource.""" 775 776 _NAME = u'objectAccessControls' 777 778 def __init__(self, client): 779 super(StorageV1.ObjectAccessControlsService, self).__init__(client) 780 self._upload_configs = { 781 } 782 783 def Delete(self, request, global_params=None): 784 r"""Permanently deletes the ACL entry for the specified entity on the specified object. 785 786 Args: 787 request: (StorageObjectAccessControlsDeleteRequest) input message 788 global_params: (StandardQueryParameters, default: None) global arguments 789 Returns: 790 (StorageObjectAccessControlsDeleteResponse) The response message. 791 """ 792 config = self.GetMethodConfig('Delete') 793 return self._RunMethod( 794 config, request, global_params=global_params) 795 796 Delete.method_config = lambda: base_api.ApiMethodInfo( 797 http_method=u'DELETE', 798 method_id=u'storage.objectAccessControls.delete', 799 ordered_params=[u'bucket', u'object', u'entity'], 800 path_params=[u'bucket', u'entity', u'object'], 801 query_params=[u'generation'], 802 relative_path=u'b/{bucket}/o/{object}/acl/{entity}', 803 request_field='', 804 request_type_name=u'StorageObjectAccessControlsDeleteRequest', 805 response_type_name=u'StorageObjectAccessControlsDeleteResponse', 806 supports_download=False, 807 ) 808 809 def Get(self, request, global_params=None): 810 r"""Returns the ACL entry for the specified entity on the specified object. 811 812 Args: 813 request: (StorageObjectAccessControlsGetRequest) input message 814 global_params: (StandardQueryParameters, default: None) global arguments 815 Returns: 816 (ObjectAccessControl) The response message. 817 """ 818 config = self.GetMethodConfig('Get') 819 return self._RunMethod( 820 config, request, global_params=global_params) 821 822 Get.method_config = lambda: base_api.ApiMethodInfo( 823 http_method=u'GET', 824 method_id=u'storage.objectAccessControls.get', 825 ordered_params=[u'bucket', u'object', u'entity'], 826 path_params=[u'bucket', u'entity', u'object'], 827 query_params=[u'generation'], 828 relative_path=u'b/{bucket}/o/{object}/acl/{entity}', 829 request_field='', 830 request_type_name=u'StorageObjectAccessControlsGetRequest', 831 response_type_name=u'ObjectAccessControl', 832 supports_download=False, 833 ) 834 835 def Insert(self, request, global_params=None): 836 r"""Creates a new ACL entry on the specified object. 837 838 Args: 839 request: (StorageObjectAccessControlsInsertRequest) input message 840 global_params: (StandardQueryParameters, default: None) global arguments 841 Returns: 842 (ObjectAccessControl) The response message. 843 """ 844 config = self.GetMethodConfig('Insert') 845 return self._RunMethod( 846 config, request, global_params=global_params) 847 848 Insert.method_config = lambda: base_api.ApiMethodInfo( 849 http_method=u'POST', 850 method_id=u'storage.objectAccessControls.insert', 851 ordered_params=[u'bucket', u'object'], 852 path_params=[u'bucket', u'object'], 853 query_params=[u'generation'], 854 relative_path=u'b/{bucket}/o/{object}/acl', 855 request_field=u'objectAccessControl', 856 request_type_name=u'StorageObjectAccessControlsInsertRequest', 857 response_type_name=u'ObjectAccessControl', 858 supports_download=False, 859 ) 860 861 def List(self, request, global_params=None): 862 r"""Retrieves ACL entries on the specified object. 863 864 Args: 865 request: (StorageObjectAccessControlsListRequest) input message 866 global_params: (StandardQueryParameters, default: None) global arguments 867 Returns: 868 (ObjectAccessControls) The response message. 869 """ 870 config = self.GetMethodConfig('List') 871 return self._RunMethod( 872 config, request, global_params=global_params) 873 874 List.method_config = lambda: base_api.ApiMethodInfo( 875 http_method=u'GET', 876 method_id=u'storage.objectAccessControls.list', 877 ordered_params=[u'bucket', u'object'], 878 path_params=[u'bucket', u'object'], 879 query_params=[u'generation'], 880 relative_path=u'b/{bucket}/o/{object}/acl', 881 request_field='', 882 request_type_name=u'StorageObjectAccessControlsListRequest', 883 response_type_name=u'ObjectAccessControls', 884 supports_download=False, 885 ) 886 887 def Patch(self, request, global_params=None): 888 r"""Updates an ACL entry on the specified object. This method supports patch semantics. 889 890 Args: 891 request: (StorageObjectAccessControlsPatchRequest) input message 892 global_params: (StandardQueryParameters, default: None) global arguments 893 Returns: 894 (ObjectAccessControl) The response message. 895 """ 896 config = self.GetMethodConfig('Patch') 897 return self._RunMethod( 898 config, request, global_params=global_params) 899 900 Patch.method_config = lambda: base_api.ApiMethodInfo( 901 http_method=u'PATCH', 902 method_id=u'storage.objectAccessControls.patch', 903 ordered_params=[u'bucket', u'object', u'entity'], 904 path_params=[u'bucket', u'entity', u'object'], 905 query_params=[u'generation'], 906 relative_path=u'b/{bucket}/o/{object}/acl/{entity}', 907 request_field=u'objectAccessControl', 908 request_type_name=u'StorageObjectAccessControlsPatchRequest', 909 response_type_name=u'ObjectAccessControl', 910 supports_download=False, 911 ) 912 913 def Update(self, request, global_params=None): 914 r"""Updates an ACL entry on the specified object. 915 916 Args: 917 request: (StorageObjectAccessControlsUpdateRequest) input message 918 global_params: (StandardQueryParameters, default: None) global arguments 919 Returns: 920 (ObjectAccessControl) The response message. 921 """ 922 config = self.GetMethodConfig('Update') 923 return self._RunMethod( 924 config, request, global_params=global_params) 925 926 Update.method_config = lambda: base_api.ApiMethodInfo( 927 http_method=u'PUT', 928 method_id=u'storage.objectAccessControls.update', 929 ordered_params=[u'bucket', u'object', u'entity'], 930 path_params=[u'bucket', u'entity', u'object'], 931 query_params=[u'generation'], 932 relative_path=u'b/{bucket}/o/{object}/acl/{entity}', 933 request_field=u'objectAccessControl', 934 request_type_name=u'StorageObjectAccessControlsUpdateRequest', 935 response_type_name=u'ObjectAccessControl', 936 supports_download=False, 937 ) 938 939 class ObjectsService(base_api.BaseApiService): 940 """Service class for the objects resource.""" 941 942 _NAME = u'objects' 943 944 def __init__(self, client): 945 super(StorageV1.ObjectsService, self).__init__(client) 946 self._upload_configs = { 947 'Insert': base_api.ApiUploadInfo( 948 accept=['*/*'], 949 max_size=None, 950 resumable_multipart=True, 951 resumable_path=u'/resumable/upload/storage/v1/b/{bucket}/o', 952 simple_multipart=True, 953 simple_path=u'/upload/storage/v1/b/{bucket}/o', 954 ), 955 } 956 957 def Compose(self, request, global_params=None, download=None): 958 r"""Concatenates a list of existing objects into a new object in the same bucket. 959 960 Args: 961 request: (StorageObjectsComposeRequest) input message 962 global_params: (StandardQueryParameters, default: None) global arguments 963 download: (Download, default: None) If present, download 964 data from the request via this stream. 965 Returns: 966 (Object) The response message. 967 """ 968 config = self.GetMethodConfig('Compose') 969 return self._RunMethod( 970 config, request, global_params=global_params, 971 download=download) 972 973 Compose.method_config = lambda: base_api.ApiMethodInfo( 974 http_method=u'POST', 975 method_id=u'storage.objects.compose', 976 ordered_params=[u'destinationBucket', u'destinationObject'], 977 path_params=[u'destinationBucket', u'destinationObject'], 978 query_params=[u'destinationPredefinedAcl', u'ifGenerationMatch', u'ifMetagenerationMatch'], 979 relative_path=u'b/{destinationBucket}/o/{destinationObject}/compose', 980 request_field=u'composeRequest', 981 request_type_name=u'StorageObjectsComposeRequest', 982 response_type_name=u'Object', 983 supports_download=True, 984 ) 985 986 def Copy(self, request, global_params=None, download=None): 987 r"""Copies a source object to a destination object. Optionally overrides metadata. 988 989 Args: 990 request: (StorageObjectsCopyRequest) input message 991 global_params: (StandardQueryParameters, default: None) global arguments 992 download: (Download, default: None) If present, download 993 data from the request via this stream. 994 Returns: 995 (Object) The response message. 996 """ 997 config = self.GetMethodConfig('Copy') 998 return self._RunMethod( 999 config, request, global_params=global_params, 1000 download=download) 1001 1002 Copy.method_config = lambda: base_api.ApiMethodInfo( 1003 http_method=u'POST', 1004 method_id=u'storage.objects.copy', 1005 ordered_params=[u'sourceBucket', u'sourceObject', u'destinationBucket', u'destinationObject'], 1006 path_params=[u'destinationBucket', u'destinationObject', u'sourceBucket', u'sourceObject'], 1007 query_params=[u'destinationPredefinedAcl', u'ifGenerationMatch', u'ifGenerationNotMatch', u'ifMetagenerationMatch', u'ifMetagenerationNotMatch', u'ifSourceGenerationMatch', u'ifSourceGenerationNotMatch', u'ifSourceMetagenerationMatch', u'ifSourceMetagenerationNotMatch', u'projection', u'sourceGeneration'], 1008 relative_path=u'b/{sourceBucket}/o/{sourceObject}/copyTo/b/{destinationBucket}/o/{destinationObject}', 1009 request_field=u'object', 1010 request_type_name=u'StorageObjectsCopyRequest', 1011 response_type_name=u'Object', 1012 supports_download=True, 1013 ) 1014 1015 def Delete(self, request, global_params=None): 1016 r"""Deletes an object and its metadata. Deletions are permanent if versioning is not enabled for the bucket, or if the generation parameter is used. 1017 1018 Args: 1019 request: (StorageObjectsDeleteRequest) input message 1020 global_params: (StandardQueryParameters, default: None) global arguments 1021 Returns: 1022 (StorageObjectsDeleteResponse) The response message. 1023 """ 1024 config = self.GetMethodConfig('Delete') 1025 return self._RunMethod( 1026 config, request, global_params=global_params) 1027 1028 Delete.method_config = lambda: base_api.ApiMethodInfo( 1029 http_method=u'DELETE', 1030 method_id=u'storage.objects.delete', 1031 ordered_params=[u'bucket', u'object'], 1032 path_params=[u'bucket', u'object'], 1033 query_params=[u'generation', u'ifGenerationMatch', u'ifGenerationNotMatch', u'ifMetagenerationMatch', u'ifMetagenerationNotMatch'], 1034 relative_path=u'b/{bucket}/o/{object}', 1035 request_field='', 1036 request_type_name=u'StorageObjectsDeleteRequest', 1037 response_type_name=u'StorageObjectsDeleteResponse', 1038 supports_download=False, 1039 ) 1040 1041 def Get(self, request, global_params=None, download=None): 1042 r"""Retrieves an object or its metadata. 1043 1044 Args: 1045 request: (StorageObjectsGetRequest) input message 1046 global_params: (StandardQueryParameters, default: None) global arguments 1047 download: (Download, default: None) If present, download 1048 data from the request via this stream. 1049 Returns: 1050 (Object) The response message. 1051 """ 1052 config = self.GetMethodConfig('Get') 1053 return self._RunMethod( 1054 config, request, global_params=global_params, 1055 download=download) 1056 1057 Get.method_config = lambda: base_api.ApiMethodInfo( 1058 http_method=u'GET', 1059 method_id=u'storage.objects.get', 1060 ordered_params=[u'bucket', u'object'], 1061 path_params=[u'bucket', u'object'], 1062 query_params=[u'generation', u'ifGenerationMatch', u'ifGenerationNotMatch', u'ifMetagenerationMatch', u'ifMetagenerationNotMatch', u'projection'], 1063 relative_path=u'b/{bucket}/o/{object}', 1064 request_field='', 1065 request_type_name=u'StorageObjectsGetRequest', 1066 response_type_name=u'Object', 1067 supports_download=True, 1068 ) 1069 1070 def GetIamPolicy(self, request, global_params=None): 1071 r"""Returns an IAM policy for the specified object. 1072 1073 Args: 1074 request: (StorageObjectsGetIamPolicyRequest) input message 1075 global_params: (StandardQueryParameters, default: None) global arguments 1076 Returns: 1077 (Policy) The response message. 1078 """ 1079 config = self.GetMethodConfig('GetIamPolicy') 1080 return self._RunMethod( 1081 config, request, global_params=global_params) 1082 1083 GetIamPolicy.method_config = lambda: base_api.ApiMethodInfo( 1084 http_method=u'GET', 1085 method_id=u'storage.objects.getIamPolicy', 1086 ordered_params=[u'bucket', u'object'], 1087 path_params=[u'bucket', u'object'], 1088 query_params=[u'generation'], 1089 relative_path=u'b/{bucket}/o/{object}/iam', 1090 request_field='', 1091 request_type_name=u'StorageObjectsGetIamPolicyRequest', 1092 response_type_name=u'Policy', 1093 supports_download=False, 1094 ) 1095 1096 def Insert(self, request, global_params=None, upload=None, download=None): 1097 r"""Stores a new object and metadata. 1098 1099 Args: 1100 request: (StorageObjectsInsertRequest) input message 1101 global_params: (StandardQueryParameters, default: None) global arguments 1102 upload: (Upload, default: None) If present, upload 1103 this stream with the request. 1104 download: (Download, default: None) If present, download 1105 data from the request via this stream. 1106 Returns: 1107 (Object) The response message. 1108 """ 1109 config = self.GetMethodConfig('Insert') 1110 upload_config = self.GetUploadConfig('Insert') 1111 return self._RunMethod( 1112 config, request, global_params=global_params, 1113 upload=upload, upload_config=upload_config, 1114 download=download) 1115 1116 Insert.method_config = lambda: base_api.ApiMethodInfo( 1117 http_method=u'POST', 1118 method_id=u'storage.objects.insert', 1119 ordered_params=[u'bucket'], 1120 path_params=[u'bucket'], 1121 query_params=[u'contentEncoding', u'ifGenerationMatch', u'ifGenerationNotMatch', u'ifMetagenerationMatch', u'ifMetagenerationNotMatch', u'name', u'predefinedAcl', u'projection'], 1122 relative_path=u'b/{bucket}/o', 1123 request_field=u'object', 1124 request_type_name=u'StorageObjectsInsertRequest', 1125 response_type_name=u'Object', 1126 supports_download=True, 1127 ) 1128 1129 def List(self, request, global_params=None): 1130 r"""Retrieves a list of objects matching the criteria. 1131 1132 Args: 1133 request: (StorageObjectsListRequest) input message 1134 global_params: (StandardQueryParameters, default: None) global arguments 1135 Returns: 1136 (Objects) The response message. 1137 """ 1138 config = self.GetMethodConfig('List') 1139 return self._RunMethod( 1140 config, request, global_params=global_params) 1141 1142 List.method_config = lambda: base_api.ApiMethodInfo( 1143 http_method=u'GET', 1144 method_id=u'storage.objects.list', 1145 ordered_params=[u'bucket'], 1146 path_params=[u'bucket'], 1147 query_params=[u'delimiter', u'maxResults', u'pageToken', u'prefix', u'projection', u'versions'], 1148 relative_path=u'b/{bucket}/o', 1149 request_field='', 1150 request_type_name=u'StorageObjectsListRequest', 1151 response_type_name=u'Objects', 1152 supports_download=False, 1153 ) 1154 1155 def Patch(self, request, global_params=None): 1156 r"""Updates an object's metadata. This method supports patch semantics. 1157 1158 Args: 1159 request: (StorageObjectsPatchRequest) input message 1160 global_params: (StandardQueryParameters, default: None) global arguments 1161 Returns: 1162 (Object) The response message. 1163 """ 1164 config = self.GetMethodConfig('Patch') 1165 return self._RunMethod( 1166 config, request, global_params=global_params) 1167 1168 Patch.method_config = lambda: base_api.ApiMethodInfo( 1169 http_method=u'PATCH', 1170 method_id=u'storage.objects.patch', 1171 ordered_params=[u'bucket', u'object'], 1172 path_params=[u'bucket', u'object'], 1173 query_params=[u'generation', u'ifGenerationMatch', u'ifGenerationNotMatch', u'ifMetagenerationMatch', u'ifMetagenerationNotMatch', u'predefinedAcl', u'projection'], 1174 relative_path=u'b/{bucket}/o/{object}', 1175 request_field=u'objectResource', 1176 request_type_name=u'StorageObjectsPatchRequest', 1177 response_type_name=u'Object', 1178 supports_download=False, 1179 ) 1180 1181 def Rewrite(self, request, global_params=None): 1182 r"""Rewrites a source object to a destination object. Optionally overrides metadata. 1183 1184 Args: 1185 request: (StorageObjectsRewriteRequest) input message 1186 global_params: (StandardQueryParameters, default: None) global arguments 1187 Returns: 1188 (RewriteResponse) The response message. 1189 """ 1190 config = self.GetMethodConfig('Rewrite') 1191 return self._RunMethod( 1192 config, request, global_params=global_params) 1193 1194 Rewrite.method_config = lambda: base_api.ApiMethodInfo( 1195 http_method=u'POST', 1196 method_id=u'storage.objects.rewrite', 1197 ordered_params=[u'sourceBucket', u'sourceObject', u'destinationBucket', u'destinationObject'], 1198 path_params=[u'destinationBucket', u'destinationObject', u'sourceBucket', u'sourceObject'], 1199 query_params=[u'destinationPredefinedAcl', u'ifGenerationMatch', u'ifGenerationNotMatch', u'ifMetagenerationMatch', u'ifMetagenerationNotMatch', u'ifSourceGenerationMatch', u'ifSourceGenerationNotMatch', u'ifSourceMetagenerationMatch', u'ifSourceMetagenerationNotMatch', u'maxBytesRewrittenPerCall', u'projection', u'rewriteToken', u'sourceGeneration'], 1200 relative_path=u'b/{sourceBucket}/o/{sourceObject}/rewriteTo/b/{destinationBucket}/o/{destinationObject}', 1201 request_field=u'object', 1202 request_type_name=u'StorageObjectsRewriteRequest', 1203 response_type_name=u'RewriteResponse', 1204 supports_download=False, 1205 ) 1206 1207 def SetIamPolicy(self, request, global_params=None): 1208 r"""Updates an IAM policy for the specified object. 1209 1210 Args: 1211 request: (StorageObjectsSetIamPolicyRequest) input message 1212 global_params: (StandardQueryParameters, default: None) global arguments 1213 Returns: 1214 (Policy) The response message. 1215 """ 1216 config = self.GetMethodConfig('SetIamPolicy') 1217 return self._RunMethod( 1218 config, request, global_params=global_params) 1219 1220 SetIamPolicy.method_config = lambda: base_api.ApiMethodInfo( 1221 http_method=u'PUT', 1222 method_id=u'storage.objects.setIamPolicy', 1223 ordered_params=[u'bucket', u'object'], 1224 path_params=[u'bucket', u'object'], 1225 query_params=[u'generation'], 1226 relative_path=u'b/{bucket}/o/{object}/iam', 1227 request_field=u'policy', 1228 request_type_name=u'StorageObjectsSetIamPolicyRequest', 1229 response_type_name=u'Policy', 1230 supports_download=False, 1231 ) 1232 1233 def TestIamPermissions(self, request, global_params=None): 1234 r"""Tests a set of permissions on the given object to see which, if any, are held by the caller. 1235 1236 Args: 1237 request: (StorageObjectsTestIamPermissionsRequest) input message 1238 global_params: (StandardQueryParameters, default: None) global arguments 1239 Returns: 1240 (TestIamPermissionsResponse) The response message. 1241 """ 1242 config = self.GetMethodConfig('TestIamPermissions') 1243 return self._RunMethod( 1244 config, request, global_params=global_params) 1245 1246 TestIamPermissions.method_config = lambda: base_api.ApiMethodInfo( 1247 http_method=u'GET', 1248 method_id=u'storage.objects.testIamPermissions', 1249 ordered_params=[u'bucket', u'object', u'permissions'], 1250 path_params=[u'bucket', u'object'], 1251 query_params=[u'generation', u'permissions'], 1252 relative_path=u'b/{bucket}/o/{object}/iam/testPermissions', 1253 request_field='', 1254 request_type_name=u'StorageObjectsTestIamPermissionsRequest', 1255 response_type_name=u'TestIamPermissionsResponse', 1256 supports_download=False, 1257 ) 1258 1259 def Update(self, request, global_params=None, download=None): 1260 r"""Updates an object's metadata. 1261 1262 Args: 1263 request: (StorageObjectsUpdateRequest) input message 1264 global_params: (StandardQueryParameters, default: None) global arguments 1265 download: (Download, default: None) If present, download 1266 data from the request via this stream. 1267 Returns: 1268 (Object) The response message. 1269 """ 1270 config = self.GetMethodConfig('Update') 1271 return self._RunMethod( 1272 config, request, global_params=global_params, 1273 download=download) 1274 1275 Update.method_config = lambda: base_api.ApiMethodInfo( 1276 http_method=u'PUT', 1277 method_id=u'storage.objects.update', 1278 ordered_params=[u'bucket', u'object'], 1279 path_params=[u'bucket', u'object'], 1280 query_params=[u'generation', u'ifGenerationMatch', u'ifGenerationNotMatch', u'ifMetagenerationMatch', u'ifMetagenerationNotMatch', u'predefinedAcl', u'projection'], 1281 relative_path=u'b/{bucket}/o/{object}', 1282 request_field=u'objectResource', 1283 request_type_name=u'StorageObjectsUpdateRequest', 1284 response_type_name=u'Object', 1285 supports_download=True, 1286 ) 1287 1288 def WatchAll(self, request, global_params=None): 1289 r"""Watch for changes on all objects in a bucket. 1290 1291 Args: 1292 request: (StorageObjectsWatchAllRequest) input message 1293 global_params: (StandardQueryParameters, default: None) global arguments 1294 Returns: 1295 (Channel) The response message. 1296 """ 1297 config = self.GetMethodConfig('WatchAll') 1298 return self._RunMethod( 1299 config, request, global_params=global_params) 1300 1301 WatchAll.method_config = lambda: base_api.ApiMethodInfo( 1302 http_method=u'POST', 1303 method_id=u'storage.objects.watchAll', 1304 ordered_params=[u'bucket'], 1305 path_params=[u'bucket'], 1306 query_params=[u'delimiter', u'maxResults', u'pageToken', u'prefix', u'projection', u'versions'], 1307 relative_path=u'b/{bucket}/o/watch', 1308 request_field=u'channel', 1309 request_type_name=u'StorageObjectsWatchAllRequest', 1310 response_type_name=u'Channel', 1311 supports_download=False, 1312 ) 1313