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