Index: tools/telemetry/third_party/gsutilz/third_party/apitools/samples/storage_sample/storage/storage_v1_client.py |
diff --git a/tools/telemetry/third_party/gsutilz/third_party/apitools/samples/storage_sample/storage/storage_v1_client.py b/tools/telemetry/third_party/gsutilz/third_party/apitools/samples/storage_sample/storage/storage_v1_client.py |
index 4d5024df76654842b409877d0c1306c3409d2886..18bd33d09459c03d84700323e7ad912ed086c835 100644 |
--- a/tools/telemetry/third_party/gsutilz/third_party/apitools/samples/storage_sample/storage/storage_v1_client.py |
+++ b/tools/telemetry/third_party/gsutilz/third_party/apitools/samples/storage_sample/storage/storage_v1_client.py |
@@ -1,4 +1,5 @@ |
"""Generated client library for storage version v1.""" |
+# NOTE: This file is autogenerated and should not be edited by hand. |
from apitools.base.py import base_api |
import storage_v1_messages as messages |
@@ -32,91 +33,91 @@ class StorageV1(base_api.BaseApiClient): |
credentials_args=credentials_args, |
default_global_params=default_global_params, |
additional_http_headers=additional_http_headers) |
- self.defaultObjectAccessControls = self.DefaultObjectAccessControlsService(self) |
self.bucketAccessControls = self.BucketAccessControlsService(self) |
+ self.buckets = self.BucketsService(self) |
self.channels = self.ChannelsService(self) |
- self.objects = self.ObjectsService(self) |
+ self.defaultObjectAccessControls = self.DefaultObjectAccessControlsService(self) |
self.objectAccessControls = self.ObjectAccessControlsService(self) |
- self.buckets = self.BucketsService(self) |
+ self.objects = self.ObjectsService(self) |
- class DefaultObjectAccessControlsService(base_api.BaseApiService): |
- """Service class for the defaultObjectAccessControls resource.""" |
+ class BucketAccessControlsService(base_api.BaseApiService): |
+ """Service class for the bucketAccessControls resource.""" |
- _NAME = u'defaultObjectAccessControls' |
+ _NAME = u'bucketAccessControls' |
def __init__(self, client): |
- super(StorageV1.DefaultObjectAccessControlsService, self).__init__(client) |
+ super(StorageV1.BucketAccessControlsService, self).__init__(client) |
self._method_configs = { |
'Delete': base_api.ApiMethodInfo( |
http_method=u'DELETE', |
- method_id=u'storage.defaultObjectAccessControls.delete', |
+ method_id=u'storage.bucketAccessControls.delete', |
ordered_params=[u'bucket', u'entity'], |
path_params=[u'bucket', u'entity'], |
query_params=[], |
- relative_path=u'b/{bucket}/defaultObjectAcl/{entity}', |
+ relative_path=u'b/{bucket}/acl/{entity}', |
request_field='', |
- request_type_name=u'StorageDefaultObjectAccessControlsDeleteRequest', |
- response_type_name=u'StorageDefaultObjectAccessControlsDeleteResponse', |
+ request_type_name=u'StorageBucketAccessControlsDeleteRequest', |
+ response_type_name=u'StorageBucketAccessControlsDeleteResponse', |
supports_download=False, |
), |
'Get': base_api.ApiMethodInfo( |
http_method=u'GET', |
- method_id=u'storage.defaultObjectAccessControls.get', |
+ method_id=u'storage.bucketAccessControls.get', |
ordered_params=[u'bucket', u'entity'], |
path_params=[u'bucket', u'entity'], |
query_params=[], |
- relative_path=u'b/{bucket}/defaultObjectAcl/{entity}', |
+ relative_path=u'b/{bucket}/acl/{entity}', |
request_field='', |
- request_type_name=u'StorageDefaultObjectAccessControlsGetRequest', |
- response_type_name=u'ObjectAccessControl', |
+ request_type_name=u'StorageBucketAccessControlsGetRequest', |
+ response_type_name=u'BucketAccessControl', |
supports_download=False, |
), |
'Insert': base_api.ApiMethodInfo( |
http_method=u'POST', |
- method_id=u'storage.defaultObjectAccessControls.insert', |
+ method_id=u'storage.bucketAccessControls.insert', |
ordered_params=[u'bucket'], |
path_params=[u'bucket'], |
query_params=[], |
- relative_path=u'b/{bucket}/defaultObjectAcl', |
+ relative_path=u'b/{bucket}/acl', |
request_field='<request>', |
- request_type_name=u'ObjectAccessControl', |
- response_type_name=u'ObjectAccessControl', |
+ request_type_name=u'BucketAccessControl', |
+ response_type_name=u'BucketAccessControl', |
supports_download=False, |
), |
'List': base_api.ApiMethodInfo( |
http_method=u'GET', |
- method_id=u'storage.defaultObjectAccessControls.list', |
+ method_id=u'storage.bucketAccessControls.list', |
ordered_params=[u'bucket'], |
path_params=[u'bucket'], |
- query_params=[u'ifMetagenerationMatch', u'ifMetagenerationNotMatch'], |
- relative_path=u'b/{bucket}/defaultObjectAcl', |
+ query_params=[], |
+ relative_path=u'b/{bucket}/acl', |
request_field='', |
- request_type_name=u'StorageDefaultObjectAccessControlsListRequest', |
- response_type_name=u'ObjectAccessControls', |
+ request_type_name=u'StorageBucketAccessControlsListRequest', |
+ response_type_name=u'BucketAccessControls', |
supports_download=False, |
), |
'Patch': base_api.ApiMethodInfo( |
http_method=u'PATCH', |
- method_id=u'storage.defaultObjectAccessControls.patch', |
+ method_id=u'storage.bucketAccessControls.patch', |
ordered_params=[u'bucket', u'entity'], |
path_params=[u'bucket', u'entity'], |
query_params=[], |
- relative_path=u'b/{bucket}/defaultObjectAcl/{entity}', |
+ relative_path=u'b/{bucket}/acl/{entity}', |
request_field='<request>', |
- request_type_name=u'ObjectAccessControl', |
- response_type_name=u'ObjectAccessControl', |
+ request_type_name=u'BucketAccessControl', |
+ response_type_name=u'BucketAccessControl', |
supports_download=False, |
), |
'Update': base_api.ApiMethodInfo( |
http_method=u'PUT', |
- method_id=u'storage.defaultObjectAccessControls.update', |
+ method_id=u'storage.bucketAccessControls.update', |
ordered_params=[u'bucket', u'entity'], |
path_params=[u'bucket', u'entity'], |
query_params=[], |
- relative_path=u'b/{bucket}/defaultObjectAcl/{entity}', |
+ relative_path=u'b/{bucket}/acl/{entity}', |
request_field='<request>', |
- request_type_name=u'ObjectAccessControl', |
- response_type_name=u'ObjectAccessControl', |
+ request_type_name=u'BucketAccessControl', |
+ response_type_name=u'BucketAccessControl', |
supports_download=False, |
), |
} |
@@ -125,161 +126,161 @@ class StorageV1(base_api.BaseApiClient): |
} |
def Delete(self, request, global_params=None): |
- """Permanently deletes the default object ACL entry for the specified entity on the specified bucket. |
+ """Permanently deletes the ACL entry for the specified entity on the specified bucket. |
Args: |
- request: (StorageDefaultObjectAccessControlsDeleteRequest) input message |
+ request: (StorageBucketAccessControlsDeleteRequest) input message |
global_params: (StandardQueryParameters, default: None) global arguments |
Returns: |
- (StorageDefaultObjectAccessControlsDeleteResponse) The response message. |
+ (StorageBucketAccessControlsDeleteResponse) The response message. |
""" |
config = self.GetMethodConfig('Delete') |
return self._RunMethod( |
config, request, global_params=global_params) |
def Get(self, request, global_params=None): |
- """Returns the default object ACL entry for the specified entity on the specified bucket. |
+ """Returns the ACL entry for the specified entity on the specified bucket. |
Args: |
- request: (StorageDefaultObjectAccessControlsGetRequest) input message |
+ request: (StorageBucketAccessControlsGetRequest) input message |
global_params: (StandardQueryParameters, default: None) global arguments |
Returns: |
- (ObjectAccessControl) The response message. |
+ (BucketAccessControl) The response message. |
""" |
config = self.GetMethodConfig('Get') |
return self._RunMethod( |
config, request, global_params=global_params) |
def Insert(self, request, global_params=None): |
- """Creates a new default object ACL entry on the specified bucket. |
+ """Creates a new ACL entry on the specified bucket. |
Args: |
- request: (ObjectAccessControl) input message |
+ request: (BucketAccessControl) input message |
global_params: (StandardQueryParameters, default: None) global arguments |
Returns: |
- (ObjectAccessControl) The response message. |
+ (BucketAccessControl) The response message. |
""" |
config = self.GetMethodConfig('Insert') |
return self._RunMethod( |
config, request, global_params=global_params) |
def List(self, request, global_params=None): |
- """Retrieves default object ACL entries on the specified bucket. |
+ """Retrieves ACL entries on the specified bucket. |
Args: |
- request: (StorageDefaultObjectAccessControlsListRequest) input message |
+ request: (StorageBucketAccessControlsListRequest) input message |
global_params: (StandardQueryParameters, default: None) global arguments |
Returns: |
- (ObjectAccessControls) The response message. |
+ (BucketAccessControls) The response message. |
""" |
config = self.GetMethodConfig('List') |
return self._RunMethod( |
config, request, global_params=global_params) |
def Patch(self, request, global_params=None): |
- """Updates a default object ACL entry on the specified bucket. This method supports patch semantics. |
+ """Updates an ACL entry on the specified bucket. This method supports patch semantics. |
Args: |
- request: (ObjectAccessControl) input message |
+ request: (BucketAccessControl) input message |
global_params: (StandardQueryParameters, default: None) global arguments |
Returns: |
- (ObjectAccessControl) The response message. |
+ (BucketAccessControl) The response message. |
""" |
config = self.GetMethodConfig('Patch') |
return self._RunMethod( |
config, request, global_params=global_params) |
def Update(self, request, global_params=None): |
- """Updates a default object ACL entry on the specified bucket. |
+ """Updates an ACL entry on the specified bucket. |
Args: |
- request: (ObjectAccessControl) input message |
+ request: (BucketAccessControl) input message |
global_params: (StandardQueryParameters, default: None) global arguments |
Returns: |
- (ObjectAccessControl) The response message. |
+ (BucketAccessControl) The response message. |
""" |
config = self.GetMethodConfig('Update') |
return self._RunMethod( |
config, request, global_params=global_params) |
- class BucketAccessControlsService(base_api.BaseApiService): |
- """Service class for the bucketAccessControls resource.""" |
+ class BucketsService(base_api.BaseApiService): |
+ """Service class for the buckets resource.""" |
- _NAME = u'bucketAccessControls' |
+ _NAME = u'buckets' |
def __init__(self, client): |
- super(StorageV1.BucketAccessControlsService, self).__init__(client) |
+ super(StorageV1.BucketsService, self).__init__(client) |
self._method_configs = { |
'Delete': base_api.ApiMethodInfo( |
http_method=u'DELETE', |
- method_id=u'storage.bucketAccessControls.delete', |
- ordered_params=[u'bucket', u'entity'], |
- path_params=[u'bucket', u'entity'], |
- query_params=[], |
- relative_path=u'b/{bucket}/acl/{entity}', |
+ method_id=u'storage.buckets.delete', |
+ ordered_params=[u'bucket'], |
+ path_params=[u'bucket'], |
+ query_params=[u'ifMetagenerationMatch', u'ifMetagenerationNotMatch'], |
+ relative_path=u'b/{bucket}', |
request_field='', |
- request_type_name=u'StorageBucketAccessControlsDeleteRequest', |
- response_type_name=u'StorageBucketAccessControlsDeleteResponse', |
+ request_type_name=u'StorageBucketsDeleteRequest', |
+ response_type_name=u'StorageBucketsDeleteResponse', |
supports_download=False, |
), |
'Get': base_api.ApiMethodInfo( |
http_method=u'GET', |
- method_id=u'storage.bucketAccessControls.get', |
- ordered_params=[u'bucket', u'entity'], |
- path_params=[u'bucket', u'entity'], |
- query_params=[], |
- relative_path=u'b/{bucket}/acl/{entity}', |
+ method_id=u'storage.buckets.get', |
+ ordered_params=[u'bucket'], |
+ path_params=[u'bucket'], |
+ query_params=[u'ifMetagenerationMatch', u'ifMetagenerationNotMatch', u'projection'], |
+ relative_path=u'b/{bucket}', |
request_field='', |
- request_type_name=u'StorageBucketAccessControlsGetRequest', |
- response_type_name=u'BucketAccessControl', |
+ request_type_name=u'StorageBucketsGetRequest', |
+ response_type_name=u'Bucket', |
supports_download=False, |
), |
'Insert': base_api.ApiMethodInfo( |
http_method=u'POST', |
- method_id=u'storage.bucketAccessControls.insert', |
- ordered_params=[u'bucket'], |
- path_params=[u'bucket'], |
- query_params=[], |
- relative_path=u'b/{bucket}/acl', |
- request_field='<request>', |
- request_type_name=u'BucketAccessControl', |
- response_type_name=u'BucketAccessControl', |
+ method_id=u'storage.buckets.insert', |
+ ordered_params=[u'project'], |
+ path_params=[], |
+ query_params=[u'predefinedAcl', u'predefinedDefaultObjectAcl', u'project', u'projection'], |
+ relative_path=u'b', |
+ request_field=u'bucket', |
+ request_type_name=u'StorageBucketsInsertRequest', |
+ response_type_name=u'Bucket', |
supports_download=False, |
), |
'List': base_api.ApiMethodInfo( |
http_method=u'GET', |
- method_id=u'storage.bucketAccessControls.list', |
- ordered_params=[u'bucket'], |
- path_params=[u'bucket'], |
- query_params=[], |
- relative_path=u'b/{bucket}/acl', |
+ method_id=u'storage.buckets.list', |
+ ordered_params=[u'project'], |
+ path_params=[], |
+ query_params=[u'maxResults', u'pageToken', u'prefix', u'project', u'projection'], |
+ relative_path=u'b', |
request_field='', |
- request_type_name=u'StorageBucketAccessControlsListRequest', |
- response_type_name=u'BucketAccessControls', |
+ request_type_name=u'StorageBucketsListRequest', |
+ response_type_name=u'Buckets', |
supports_download=False, |
), |
'Patch': base_api.ApiMethodInfo( |
http_method=u'PATCH', |
- method_id=u'storage.bucketAccessControls.patch', |
- ordered_params=[u'bucket', u'entity'], |
- path_params=[u'bucket', u'entity'], |
- query_params=[], |
- relative_path=u'b/{bucket}/acl/{entity}', |
- request_field='<request>', |
- request_type_name=u'BucketAccessControl', |
- response_type_name=u'BucketAccessControl', |
+ method_id=u'storage.buckets.patch', |
+ ordered_params=[u'bucket'], |
+ path_params=[u'bucket'], |
+ query_params=[u'ifMetagenerationMatch', u'ifMetagenerationNotMatch', u'predefinedAcl', u'predefinedDefaultObjectAcl', u'projection'], |
+ relative_path=u'b/{bucket}', |
+ request_field=u'bucketResource', |
+ request_type_name=u'StorageBucketsPatchRequest', |
+ response_type_name=u'Bucket', |
supports_download=False, |
), |
'Update': base_api.ApiMethodInfo( |
http_method=u'PUT', |
- method_id=u'storage.bucketAccessControls.update', |
- ordered_params=[u'bucket', u'entity'], |
- path_params=[u'bucket', u'entity'], |
- query_params=[], |
- relative_path=u'b/{bucket}/acl/{entity}', |
- request_field='<request>', |
- request_type_name=u'BucketAccessControl', |
- response_type_name=u'BucketAccessControl', |
+ method_id=u'storage.buckets.update', |
+ ordered_params=[u'bucket'], |
+ path_params=[u'bucket'], |
+ query_params=[u'ifMetagenerationMatch', u'ifMetagenerationNotMatch', u'predefinedAcl', u'predefinedDefaultObjectAcl', u'projection'], |
+ relative_path=u'b/{bucket}', |
+ request_field=u'bucketResource', |
+ request_type_name=u'StorageBucketsUpdateRequest', |
+ response_type_name=u'Bucket', |
supports_download=False, |
), |
} |
@@ -288,78 +289,78 @@ class StorageV1(base_api.BaseApiClient): |
} |
def Delete(self, request, global_params=None): |
- """Permanently deletes the ACL entry for the specified entity on the specified bucket. |
+ """Permanently deletes an empty bucket. |
Args: |
- request: (StorageBucketAccessControlsDeleteRequest) input message |
+ request: (StorageBucketsDeleteRequest) input message |
global_params: (StandardQueryParameters, default: None) global arguments |
Returns: |
- (StorageBucketAccessControlsDeleteResponse) The response message. |
+ (StorageBucketsDeleteResponse) The response message. |
""" |
config = self.GetMethodConfig('Delete') |
return self._RunMethod( |
config, request, global_params=global_params) |
def Get(self, request, global_params=None): |
- """Returns the ACL entry for the specified entity on the specified bucket. |
+ """Returns metadata for the specified bucket. |
Args: |
- request: (StorageBucketAccessControlsGetRequest) input message |
+ request: (StorageBucketsGetRequest) input message |
global_params: (StandardQueryParameters, default: None) global arguments |
Returns: |
- (BucketAccessControl) The response message. |
+ (Bucket) The response message. |
""" |
config = self.GetMethodConfig('Get') |
return self._RunMethod( |
config, request, global_params=global_params) |
def Insert(self, request, global_params=None): |
- """Creates a new ACL entry on the specified bucket. |
+ """Creates a new bucket. |
Args: |
- request: (BucketAccessControl) input message |
+ request: (StorageBucketsInsertRequest) input message |
global_params: (StandardQueryParameters, default: None) global arguments |
Returns: |
- (BucketAccessControl) The response message. |
+ (Bucket) The response message. |
""" |
config = self.GetMethodConfig('Insert') |
return self._RunMethod( |
config, request, global_params=global_params) |
def List(self, request, global_params=None): |
- """Retrieves ACL entries on the specified bucket. |
+ """Retrieves a list of buckets for a given project. |
Args: |
- request: (StorageBucketAccessControlsListRequest) input message |
+ request: (StorageBucketsListRequest) input message |
global_params: (StandardQueryParameters, default: None) global arguments |
Returns: |
- (BucketAccessControls) The response message. |
+ (Buckets) The response message. |
""" |
config = self.GetMethodConfig('List') |
return self._RunMethod( |
config, request, global_params=global_params) |
def Patch(self, request, global_params=None): |
- """Updates an ACL entry on the specified bucket. This method supports patch semantics. |
+ """Updates a bucket. This method supports patch semantics. |
Args: |
- request: (BucketAccessControl) input message |
+ request: (StorageBucketsPatchRequest) input message |
global_params: (StandardQueryParameters, default: None) global arguments |
Returns: |
- (BucketAccessControl) The response message. |
+ (Bucket) The response message. |
""" |
config = self.GetMethodConfig('Patch') |
return self._RunMethod( |
config, request, global_params=global_params) |
def Update(self, request, global_params=None): |
- """Updates an ACL entry on the specified bucket. |
+ """Updates a bucket. |
Args: |
- request: (BucketAccessControl) input message |
+ request: (StorageBucketsUpdateRequest) input message |
global_params: (StandardQueryParameters, default: None) global arguments |
Returns: |
- (BucketAccessControl) The response message. |
+ (Bucket) The response message. |
""" |
config = self.GetMethodConfig('Update') |
return self._RunMethod( |
@@ -403,269 +404,167 @@ class StorageV1(base_api.BaseApiClient): |
return self._RunMethod( |
config, request, global_params=global_params) |
- class ObjectsService(base_api.BaseApiService): |
- """Service class for the objects resource.""" |
+ class DefaultObjectAccessControlsService(base_api.BaseApiService): |
+ """Service class for the defaultObjectAccessControls resource.""" |
- _NAME = u'objects' |
+ _NAME = u'defaultObjectAccessControls' |
def __init__(self, client): |
- super(StorageV1.ObjectsService, self).__init__(client) |
+ super(StorageV1.DefaultObjectAccessControlsService, self).__init__(client) |
self._method_configs = { |
- 'Compose': base_api.ApiMethodInfo( |
- http_method=u'POST', |
- method_id=u'storage.objects.compose', |
- ordered_params=[u'destinationBucket', u'destinationObject'], |
- path_params=[u'destinationBucket', u'destinationObject'], |
- query_params=[u'destinationPredefinedAcl', u'ifGenerationMatch', u'ifMetagenerationMatch'], |
- relative_path=u'b/{destinationBucket}/o/{destinationObject}/compose', |
- request_field=u'composeRequest', |
- request_type_name=u'StorageObjectsComposeRequest', |
- response_type_name=u'Object', |
- supports_download=True, |
- ), |
- 'Copy': base_api.ApiMethodInfo( |
- http_method=u'POST', |
- method_id=u'storage.objects.copy', |
- ordered_params=[u'sourceBucket', u'sourceObject', u'destinationBucket', u'destinationObject'], |
- path_params=[u'destinationBucket', u'destinationObject', u'sourceBucket', u'sourceObject'], |
- query_params=[u'destinationPredefinedAcl', u'ifGenerationMatch', u'ifGenerationNotMatch', u'ifMetagenerationMatch', u'ifMetagenerationNotMatch', u'ifSourceGenerationMatch', u'ifSourceGenerationNotMatch', u'ifSourceMetagenerationMatch', u'ifSourceMetagenerationNotMatch', u'projection', u'sourceGeneration'], |
- relative_path=u'b/{sourceBucket}/o/{sourceObject}/copyTo/b/{destinationBucket}/o/{destinationObject}', |
- request_field=u'object', |
- request_type_name=u'StorageObjectsCopyRequest', |
- response_type_name=u'Object', |
- supports_download=True, |
- ), |
'Delete': base_api.ApiMethodInfo( |
http_method=u'DELETE', |
- method_id=u'storage.objects.delete', |
- ordered_params=[u'bucket', u'object'], |
- path_params=[u'bucket', u'object'], |
- query_params=[u'generation', u'ifGenerationMatch', u'ifGenerationNotMatch', u'ifMetagenerationMatch', u'ifMetagenerationNotMatch'], |
- relative_path=u'b/{bucket}/o/{object}', |
+ method_id=u'storage.defaultObjectAccessControls.delete', |
+ ordered_params=[u'bucket', u'entity'], |
+ path_params=[u'bucket', u'entity'], |
+ query_params=[], |
+ relative_path=u'b/{bucket}/defaultObjectAcl/{entity}', |
request_field='', |
- request_type_name=u'StorageObjectsDeleteRequest', |
- response_type_name=u'StorageObjectsDeleteResponse', |
+ request_type_name=u'StorageDefaultObjectAccessControlsDeleteRequest', |
+ response_type_name=u'StorageDefaultObjectAccessControlsDeleteResponse', |
supports_download=False, |
), |
'Get': base_api.ApiMethodInfo( |
http_method=u'GET', |
- method_id=u'storage.objects.get', |
- ordered_params=[u'bucket', u'object'], |
- path_params=[u'bucket', u'object'], |
- query_params=[u'generation', u'ifGenerationMatch', u'ifGenerationNotMatch', u'ifMetagenerationMatch', u'ifMetagenerationNotMatch', u'projection'], |
- relative_path=u'b/{bucket}/o/{object}', |
+ method_id=u'storage.defaultObjectAccessControls.get', |
+ ordered_params=[u'bucket', u'entity'], |
+ path_params=[u'bucket', u'entity'], |
+ query_params=[], |
+ relative_path=u'b/{bucket}/defaultObjectAcl/{entity}', |
request_field='', |
- request_type_name=u'StorageObjectsGetRequest', |
- response_type_name=u'Object', |
- supports_download=True, |
+ request_type_name=u'StorageDefaultObjectAccessControlsGetRequest', |
+ response_type_name=u'ObjectAccessControl', |
+ supports_download=False, |
), |
'Insert': base_api.ApiMethodInfo( |
http_method=u'POST', |
- method_id=u'storage.objects.insert', |
+ method_id=u'storage.defaultObjectAccessControls.insert', |
ordered_params=[u'bucket'], |
path_params=[u'bucket'], |
- query_params=[u'contentEncoding', u'ifGenerationMatch', u'ifGenerationNotMatch', u'ifMetagenerationMatch', u'ifMetagenerationNotMatch', u'name', u'predefinedAcl', u'projection'], |
- relative_path=u'b/{bucket}/o', |
- request_field=u'object', |
- request_type_name=u'StorageObjectsInsertRequest', |
- response_type_name=u'Object', |
- supports_download=True, |
+ query_params=[], |
+ relative_path=u'b/{bucket}/defaultObjectAcl', |
+ request_field='<request>', |
+ request_type_name=u'ObjectAccessControl', |
+ response_type_name=u'ObjectAccessControl', |
+ supports_download=False, |
), |
'List': base_api.ApiMethodInfo( |
http_method=u'GET', |
- method_id=u'storage.objects.list', |
+ method_id=u'storage.defaultObjectAccessControls.list', |
ordered_params=[u'bucket'], |
path_params=[u'bucket'], |
- query_params=[u'delimiter', u'maxResults', u'pageToken', u'prefix', u'projection', u'versions'], |
- relative_path=u'b/{bucket}/o', |
+ query_params=[u'ifMetagenerationMatch', u'ifMetagenerationNotMatch'], |
+ relative_path=u'b/{bucket}/defaultObjectAcl', |
request_field='', |
- request_type_name=u'StorageObjectsListRequest', |
- response_type_name=u'Objects', |
+ request_type_name=u'StorageDefaultObjectAccessControlsListRequest', |
+ response_type_name=u'ObjectAccessControls', |
supports_download=False, |
), |
'Patch': base_api.ApiMethodInfo( |
http_method=u'PATCH', |
- method_id=u'storage.objects.patch', |
- ordered_params=[u'bucket', u'object'], |
- path_params=[u'bucket', u'object'], |
- query_params=[u'generation', u'ifGenerationMatch', u'ifGenerationNotMatch', u'ifMetagenerationMatch', u'ifMetagenerationNotMatch', u'predefinedAcl', u'projection'], |
- relative_path=u'b/{bucket}/o/{object}', |
- request_field=u'objectResource', |
- request_type_name=u'StorageObjectsPatchRequest', |
- response_type_name=u'Object', |
+ method_id=u'storage.defaultObjectAccessControls.patch', |
+ ordered_params=[u'bucket', u'entity'], |
+ path_params=[u'bucket', u'entity'], |
+ query_params=[], |
+ relative_path=u'b/{bucket}/defaultObjectAcl/{entity}', |
+ request_field='<request>', |
+ request_type_name=u'ObjectAccessControl', |
+ response_type_name=u'ObjectAccessControl', |
supports_download=False, |
), |
'Update': base_api.ApiMethodInfo( |
http_method=u'PUT', |
- method_id=u'storage.objects.update', |
- ordered_params=[u'bucket', u'object'], |
- path_params=[u'bucket', u'object'], |
- query_params=[u'generation', u'ifGenerationMatch', u'ifGenerationNotMatch', u'ifMetagenerationMatch', u'ifMetagenerationNotMatch', u'predefinedAcl', u'projection'], |
- relative_path=u'b/{bucket}/o/{object}', |
- request_field=u'objectResource', |
- request_type_name=u'StorageObjectsUpdateRequest', |
- response_type_name=u'Object', |
- supports_download=True, |
- ), |
- 'WatchAll': base_api.ApiMethodInfo( |
- http_method=u'POST', |
- method_id=u'storage.objects.watchAll', |
- ordered_params=[u'bucket'], |
- path_params=[u'bucket'], |
- query_params=[u'delimiter', u'maxResults', u'pageToken', u'prefix', u'projection', u'versions'], |
- relative_path=u'b/{bucket}/o/watch', |
- request_field=u'channel', |
- request_type_name=u'StorageObjectsWatchAllRequest', |
- response_type_name=u'Channel', |
+ method_id=u'storage.defaultObjectAccessControls.update', |
+ ordered_params=[u'bucket', u'entity'], |
+ path_params=[u'bucket', u'entity'], |
+ query_params=[], |
+ relative_path=u'b/{bucket}/defaultObjectAcl/{entity}', |
+ request_field='<request>', |
+ request_type_name=u'ObjectAccessControl', |
+ response_type_name=u'ObjectAccessControl', |
supports_download=False, |
), |
} |
self._upload_configs = { |
- 'Insert': base_api.ApiUploadInfo( |
- accept=['*/*'], |
- max_size=None, |
- resumable_multipart=True, |
- resumable_path=u'/resumable/upload/storage/v1/b/{bucket}/o', |
- simple_multipart=True, |
- simple_path=u'/upload/storage/v1/b/{bucket}/o', |
- ), |
} |
- def Compose(self, request, global_params=None, download=None): |
- """Concatenates a list of existing objects into a new object in the same bucket. |
- |
- Args: |
- request: (StorageObjectsComposeRequest) input message |
- global_params: (StandardQueryParameters, default: None) global arguments |
- download: (Download, default: None) If present, download |
- data from the request via this stream. |
- Returns: |
- (Object) The response message. |
- """ |
- config = self.GetMethodConfig('Compose') |
- return self._RunMethod( |
- config, request, global_params=global_params, |
- download=download) |
- |
- def Copy(self, request, global_params=None, download=None): |
- """Copies an object to a specified location. Optionally overrides metadata. |
- |
- Args: |
- request: (StorageObjectsCopyRequest) input message |
- global_params: (StandardQueryParameters, default: None) global arguments |
- download: (Download, default: None) If present, download |
- data from the request via this stream. |
- Returns: |
- (Object) The response message. |
- """ |
- config = self.GetMethodConfig('Copy') |
- return self._RunMethod( |
- config, request, global_params=global_params, |
- download=download) |
- |
def Delete(self, request, global_params=None): |
- """Deletes an object and its metadata. Deletions are permanent if versioning is not enabled for the bucket, or if the generation parameter is used. |
+ """Permanently deletes the default object ACL entry for the specified entity on the specified bucket. |
Args: |
- request: (StorageObjectsDeleteRequest) input message |
+ request: (StorageDefaultObjectAccessControlsDeleteRequest) input message |
global_params: (StandardQueryParameters, default: None) global arguments |
Returns: |
- (StorageObjectsDeleteResponse) The response message. |
+ (StorageDefaultObjectAccessControlsDeleteResponse) The response message. |
""" |
config = self.GetMethodConfig('Delete') |
return self._RunMethod( |
config, request, global_params=global_params) |
- def Get(self, request, global_params=None, download=None): |
- """Retrieves an object or its metadata. |
+ def Get(self, request, global_params=None): |
+ """Returns the default object ACL entry for the specified entity on the specified bucket. |
Args: |
- request: (StorageObjectsGetRequest) input message |
+ request: (StorageDefaultObjectAccessControlsGetRequest) input message |
global_params: (StandardQueryParameters, default: None) global arguments |
- download: (Download, default: None) If present, download |
- data from the request via this stream. |
Returns: |
- (Object) The response message. |
+ (ObjectAccessControl) The response message. |
""" |
config = self.GetMethodConfig('Get') |
return self._RunMethod( |
- config, request, global_params=global_params, |
- download=download) |
+ config, request, global_params=global_params) |
- def Insert(self, request, global_params=None, upload=None, download=None): |
- """Stores a new object and metadata. |
+ def Insert(self, request, global_params=None): |
+ """Creates a new default object ACL entry on the specified bucket. |
Args: |
- request: (StorageObjectsInsertRequest) input message |
+ request: (ObjectAccessControl) input message |
global_params: (StandardQueryParameters, default: None) global arguments |
- upload: (Upload, default: None) If present, upload |
- this stream with the request. |
- download: (Download, default: None) If present, download |
- data from the request via this stream. |
Returns: |
- (Object) The response message. |
+ (ObjectAccessControl) The response message. |
""" |
config = self.GetMethodConfig('Insert') |
- upload_config = self.GetUploadConfig('Insert') |
return self._RunMethod( |
- config, request, global_params=global_params, |
- upload=upload, upload_config=upload_config, |
- download=download) |
+ config, request, global_params=global_params) |
def List(self, request, global_params=None): |
- """Retrieves a list of objects matching the criteria. |
+ """Retrieves default object ACL entries on the specified bucket. |
Args: |
- request: (StorageObjectsListRequest) input message |
+ request: (StorageDefaultObjectAccessControlsListRequest) input message |
global_params: (StandardQueryParameters, default: None) global arguments |
Returns: |
- (Objects) The response message. |
+ (ObjectAccessControls) The response message. |
""" |
config = self.GetMethodConfig('List') |
return self._RunMethod( |
config, request, global_params=global_params) |
def Patch(self, request, global_params=None): |
- """Updates an object's metadata. This method supports patch semantics. |
+ """Updates a default object ACL entry on the specified bucket. This method supports patch semantics. |
Args: |
- request: (StorageObjectsPatchRequest) input message |
+ request: (ObjectAccessControl) input message |
global_params: (StandardQueryParameters, default: None) global arguments |
Returns: |
- (Object) The response message. |
+ (ObjectAccessControl) The response message. |
""" |
config = self.GetMethodConfig('Patch') |
return self._RunMethod( |
config, request, global_params=global_params) |
- def Update(self, request, global_params=None, download=None): |
- """Updates an object's metadata. |
+ def Update(self, request, global_params=None): |
+ """Updates a default object ACL entry on the specified bucket. |
Args: |
- request: (StorageObjectsUpdateRequest) input message |
+ request: (ObjectAccessControl) input message |
global_params: (StandardQueryParameters, default: None) global arguments |
- download: (Download, default: None) If present, download |
- data from the request via this stream. |
Returns: |
- (Object) The response message. |
+ (ObjectAccessControl) The response message. |
""" |
config = self.GetMethodConfig('Update') |
return self._RunMethod( |
- config, request, global_params=global_params, |
- download=download) |
- |
- def WatchAll(self, request, global_params=None): |
- """Watch for changes on all objects in a bucket. |
- |
- Args: |
- request: (StorageObjectsWatchAllRequest) input message |
- global_params: (StandardQueryParameters, default: None) global arguments |
- Returns: |
- (Channel) The response message. |
- """ |
- config = self.GetMethodConfig('WatchAll') |
- return self._RunMethod( |
config, request, global_params=global_params) |
class ObjectAccessControlsService(base_api.BaseApiService): |
@@ -831,165 +730,292 @@ class StorageV1(base_api.BaseApiClient): |
return self._RunMethod( |
config, request, global_params=global_params) |
- class BucketsService(base_api.BaseApiService): |
- """Service class for the buckets resource.""" |
+ class ObjectsService(base_api.BaseApiService): |
+ """Service class for the objects resource.""" |
- _NAME = u'buckets' |
+ _NAME = u'objects' |
def __init__(self, client): |
- super(StorageV1.BucketsService, self).__init__(client) |
+ super(StorageV1.ObjectsService, self).__init__(client) |
self._method_configs = { |
+ 'Compose': base_api.ApiMethodInfo( |
+ http_method=u'POST', |
+ method_id=u'storage.objects.compose', |
+ ordered_params=[u'destinationBucket', u'destinationObject'], |
+ path_params=[u'destinationBucket', u'destinationObject'], |
+ query_params=[u'destinationPredefinedAcl', u'ifGenerationMatch', u'ifMetagenerationMatch'], |
+ relative_path=u'b/{destinationBucket}/o/{destinationObject}/compose', |
+ request_field=u'composeRequest', |
+ request_type_name=u'StorageObjectsComposeRequest', |
+ response_type_name=u'Object', |
+ supports_download=True, |
+ ), |
+ 'Copy': base_api.ApiMethodInfo( |
+ http_method=u'POST', |
+ method_id=u'storage.objects.copy', |
+ ordered_params=[u'sourceBucket', u'sourceObject', u'destinationBucket', u'destinationObject'], |
+ path_params=[u'destinationBucket', u'destinationObject', u'sourceBucket', u'sourceObject'], |
+ query_params=[u'destinationPredefinedAcl', u'ifGenerationMatch', u'ifGenerationNotMatch', u'ifMetagenerationMatch', u'ifMetagenerationNotMatch', u'ifSourceGenerationMatch', u'ifSourceGenerationNotMatch', u'ifSourceMetagenerationMatch', u'ifSourceMetagenerationNotMatch', u'projection', u'sourceGeneration'], |
+ relative_path=u'b/{sourceBucket}/o/{sourceObject}/copyTo/b/{destinationBucket}/o/{destinationObject}', |
+ request_field=u'object', |
+ request_type_name=u'StorageObjectsCopyRequest', |
+ response_type_name=u'Object', |
+ supports_download=True, |
+ ), |
'Delete': base_api.ApiMethodInfo( |
http_method=u'DELETE', |
- method_id=u'storage.buckets.delete', |
- ordered_params=[u'bucket'], |
- path_params=[u'bucket'], |
- query_params=[u'ifMetagenerationMatch', u'ifMetagenerationNotMatch'], |
- relative_path=u'b/{bucket}', |
+ method_id=u'storage.objects.delete', |
+ ordered_params=[u'bucket', u'object'], |
+ path_params=[u'bucket', u'object'], |
+ query_params=[u'generation', u'ifGenerationMatch', u'ifGenerationNotMatch', u'ifMetagenerationMatch', u'ifMetagenerationNotMatch'], |
+ relative_path=u'b/{bucket}/o/{object}', |
request_field='', |
- request_type_name=u'StorageBucketsDeleteRequest', |
- response_type_name=u'StorageBucketsDeleteResponse', |
+ request_type_name=u'StorageObjectsDeleteRequest', |
+ response_type_name=u'StorageObjectsDeleteResponse', |
supports_download=False, |
), |
'Get': base_api.ApiMethodInfo( |
http_method=u'GET', |
- method_id=u'storage.buckets.get', |
- ordered_params=[u'bucket'], |
- path_params=[u'bucket'], |
- query_params=[u'ifMetagenerationMatch', u'ifMetagenerationNotMatch', u'projection'], |
- relative_path=u'b/{bucket}', |
+ method_id=u'storage.objects.get', |
+ ordered_params=[u'bucket', u'object'], |
+ path_params=[u'bucket', u'object'], |
+ query_params=[u'generation', u'ifGenerationMatch', u'ifGenerationNotMatch', u'ifMetagenerationMatch', u'ifMetagenerationNotMatch', u'projection'], |
+ relative_path=u'b/{bucket}/o/{object}', |
request_field='', |
- request_type_name=u'StorageBucketsGetRequest', |
- response_type_name=u'Bucket', |
- supports_download=False, |
+ request_type_name=u'StorageObjectsGetRequest', |
+ response_type_name=u'Object', |
+ supports_download=True, |
), |
'Insert': base_api.ApiMethodInfo( |
http_method=u'POST', |
- method_id=u'storage.buckets.insert', |
- ordered_params=[u'project'], |
- path_params=[], |
- query_params=[u'predefinedAcl', u'predefinedDefaultObjectAcl', u'project', u'projection'], |
- relative_path=u'b', |
- request_field=u'bucket', |
- request_type_name=u'StorageBucketsInsertRequest', |
- response_type_name=u'Bucket', |
- supports_download=False, |
+ method_id=u'storage.objects.insert', |
+ ordered_params=[u'bucket'], |
+ path_params=[u'bucket'], |
+ query_params=[u'contentEncoding', u'ifGenerationMatch', u'ifGenerationNotMatch', u'ifMetagenerationMatch', u'ifMetagenerationNotMatch', u'name', u'predefinedAcl', u'projection'], |
+ relative_path=u'b/{bucket}/o', |
+ request_field=u'object', |
+ request_type_name=u'StorageObjectsInsertRequest', |
+ response_type_name=u'Object', |
+ supports_download=True, |
), |
'List': base_api.ApiMethodInfo( |
http_method=u'GET', |
- method_id=u'storage.buckets.list', |
- ordered_params=[u'project'], |
- path_params=[], |
- query_params=[u'maxResults', u'pageToken', u'prefix', u'project', u'projection'], |
- relative_path=u'b', |
+ method_id=u'storage.objects.list', |
+ ordered_params=[u'bucket'], |
+ path_params=[u'bucket'], |
+ query_params=[u'delimiter', u'maxResults', u'pageToken', u'prefix', u'projection', u'versions'], |
+ relative_path=u'b/{bucket}/o', |
request_field='', |
- request_type_name=u'StorageBucketsListRequest', |
- response_type_name=u'Buckets', |
+ request_type_name=u'StorageObjectsListRequest', |
+ response_type_name=u'Objects', |
supports_download=False, |
), |
'Patch': base_api.ApiMethodInfo( |
http_method=u'PATCH', |
- method_id=u'storage.buckets.patch', |
- ordered_params=[u'bucket'], |
- path_params=[u'bucket'], |
- query_params=[u'ifMetagenerationMatch', u'ifMetagenerationNotMatch', u'predefinedAcl', u'predefinedDefaultObjectAcl', u'projection'], |
- relative_path=u'b/{bucket}', |
- request_field=u'bucketResource', |
- request_type_name=u'StorageBucketsPatchRequest', |
- response_type_name=u'Bucket', |
+ method_id=u'storage.objects.patch', |
+ ordered_params=[u'bucket', u'object'], |
+ path_params=[u'bucket', u'object'], |
+ query_params=[u'generation', u'ifGenerationMatch', u'ifGenerationNotMatch', u'ifMetagenerationMatch', u'ifMetagenerationNotMatch', u'predefinedAcl', u'projection'], |
+ relative_path=u'b/{bucket}/o/{object}', |
+ request_field=u'objectResource', |
+ request_type_name=u'StorageObjectsPatchRequest', |
+ response_type_name=u'Object', |
+ supports_download=False, |
+ ), |
+ 'Rewrite': base_api.ApiMethodInfo( |
+ http_method=u'POST', |
+ method_id=u'storage.objects.rewrite', |
+ ordered_params=[u'sourceBucket', u'sourceObject', u'destinationBucket', u'destinationObject'], |
+ path_params=[u'destinationBucket', u'destinationObject', u'sourceBucket', u'sourceObject'], |
+ 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'], |
+ relative_path=u'b/{sourceBucket}/o/{sourceObject}/rewriteTo/b/{destinationBucket}/o/{destinationObject}', |
+ request_field=u'object', |
+ request_type_name=u'StorageObjectsRewriteRequest', |
+ response_type_name=u'RewriteResponse', |
supports_download=False, |
), |
'Update': base_api.ApiMethodInfo( |
http_method=u'PUT', |
- method_id=u'storage.buckets.update', |
+ method_id=u'storage.objects.update', |
+ ordered_params=[u'bucket', u'object'], |
+ path_params=[u'bucket', u'object'], |
+ query_params=[u'generation', u'ifGenerationMatch', u'ifGenerationNotMatch', u'ifMetagenerationMatch', u'ifMetagenerationNotMatch', u'predefinedAcl', u'projection'], |
+ relative_path=u'b/{bucket}/o/{object}', |
+ request_field=u'objectResource', |
+ request_type_name=u'StorageObjectsUpdateRequest', |
+ response_type_name=u'Object', |
+ supports_download=True, |
+ ), |
+ 'WatchAll': base_api.ApiMethodInfo( |
+ http_method=u'POST', |
+ method_id=u'storage.objects.watchAll', |
ordered_params=[u'bucket'], |
path_params=[u'bucket'], |
- query_params=[u'ifMetagenerationMatch', u'ifMetagenerationNotMatch', u'predefinedAcl', u'predefinedDefaultObjectAcl', u'projection'], |
- relative_path=u'b/{bucket}', |
- request_field=u'bucketResource', |
- request_type_name=u'StorageBucketsUpdateRequest', |
- response_type_name=u'Bucket', |
+ query_params=[u'delimiter', u'maxResults', u'pageToken', u'prefix', u'projection', u'versions'], |
+ relative_path=u'b/{bucket}/o/watch', |
+ request_field=u'channel', |
+ request_type_name=u'StorageObjectsWatchAllRequest', |
+ response_type_name=u'Channel', |
supports_download=False, |
), |
} |
self._upload_configs = { |
+ 'Insert': base_api.ApiUploadInfo( |
+ accept=['*/*'], |
+ max_size=None, |
+ resumable_multipart=True, |
+ resumable_path=u'/resumable/upload/storage/v1/b/{bucket}/o', |
+ simple_multipart=True, |
+ simple_path=u'/upload/storage/v1/b/{bucket}/o', |
+ ), |
} |
+ def Compose(self, request, global_params=None, download=None): |
+ """Concatenates a list of existing objects into a new object in the same bucket. |
+ |
+ Args: |
+ request: (StorageObjectsComposeRequest) input message |
+ global_params: (StandardQueryParameters, default: None) global arguments |
+ download: (Download, default: None) If present, download |
+ data from the request via this stream. |
+ Returns: |
+ (Object) The response message. |
+ """ |
+ config = self.GetMethodConfig('Compose') |
+ return self._RunMethod( |
+ config, request, global_params=global_params, |
+ download=download) |
+ |
+ def Copy(self, request, global_params=None, download=None): |
+ """Copies a source object to a destination object. Optionally overrides metadata. |
+ |
+ Args: |
+ request: (StorageObjectsCopyRequest) input message |
+ global_params: (StandardQueryParameters, default: None) global arguments |
+ download: (Download, default: None) If present, download |
+ data from the request via this stream. |
+ Returns: |
+ (Object) The response message. |
+ """ |
+ config = self.GetMethodConfig('Copy') |
+ return self._RunMethod( |
+ config, request, global_params=global_params, |
+ download=download) |
+ |
def Delete(self, request, global_params=None): |
- """Permanently deletes an empty bucket. |
+ """Deletes an object and its metadata. Deletions are permanent if versioning is not enabled for the bucket, or if the generation parameter is used. |
Args: |
- request: (StorageBucketsDeleteRequest) input message |
+ request: (StorageObjectsDeleteRequest) input message |
global_params: (StandardQueryParameters, default: None) global arguments |
Returns: |
- (StorageBucketsDeleteResponse) The response message. |
+ (StorageObjectsDeleteResponse) The response message. |
""" |
config = self.GetMethodConfig('Delete') |
return self._RunMethod( |
config, request, global_params=global_params) |
- def Get(self, request, global_params=None): |
- """Returns metadata for the specified bucket. |
+ def Get(self, request, global_params=None, download=None): |
+ """Retrieves an object or its metadata. |
Args: |
- request: (StorageBucketsGetRequest) input message |
+ request: (StorageObjectsGetRequest) input message |
global_params: (StandardQueryParameters, default: None) global arguments |
+ download: (Download, default: None) If present, download |
+ data from the request via this stream. |
Returns: |
- (Bucket) The response message. |
+ (Object) The response message. |
""" |
config = self.GetMethodConfig('Get') |
return self._RunMethod( |
- config, request, global_params=global_params) |
+ config, request, global_params=global_params, |
+ download=download) |
- def Insert(self, request, global_params=None): |
- """Creates a new bucket. |
+ def Insert(self, request, global_params=None, upload=None, download=None): |
+ """Stores a new object and metadata. |
Args: |
- request: (StorageBucketsInsertRequest) input message |
+ request: (StorageObjectsInsertRequest) input message |
global_params: (StandardQueryParameters, default: None) global arguments |
+ upload: (Upload, default: None) If present, upload |
+ this stream with the request. |
+ download: (Download, default: None) If present, download |
+ data from the request via this stream. |
Returns: |
- (Bucket) The response message. |
+ (Object) The response message. |
""" |
config = self.GetMethodConfig('Insert') |
+ upload_config = self.GetUploadConfig('Insert') |
return self._RunMethod( |
- config, request, global_params=global_params) |
+ config, request, global_params=global_params, |
+ upload=upload, upload_config=upload_config, |
+ download=download) |
def List(self, request, global_params=None): |
- """Retrieves a list of buckets for a given project. |
+ """Retrieves a list of objects matching the criteria. |
Args: |
- request: (StorageBucketsListRequest) input message |
+ request: (StorageObjectsListRequest) input message |
global_params: (StandardQueryParameters, default: None) global arguments |
Returns: |
- (Buckets) The response message. |
+ (Objects) The response message. |
""" |
config = self.GetMethodConfig('List') |
return self._RunMethod( |
config, request, global_params=global_params) |
def Patch(self, request, global_params=None): |
- """Updates a bucket. This method supports patch semantics. |
+ """Updates an object's metadata. This method supports patch semantics. |
Args: |
- request: (StorageBucketsPatchRequest) input message |
+ request: (StorageObjectsPatchRequest) input message |
global_params: (StandardQueryParameters, default: None) global arguments |
Returns: |
- (Bucket) The response message. |
+ (Object) The response message. |
""" |
config = self.GetMethodConfig('Patch') |
return self._RunMethod( |
config, request, global_params=global_params) |
- def Update(self, request, global_params=None): |
- """Updates a bucket. |
+ def Rewrite(self, request, global_params=None): |
+ """Rewrites a source object to a destination object. Optionally overrides metadata. |
Args: |
- request: (StorageBucketsUpdateRequest) input message |
+ request: (StorageObjectsRewriteRequest) input message |
global_params: (StandardQueryParameters, default: None) global arguments |
Returns: |
- (Bucket) The response message. |
+ (RewriteResponse) The response message. |
+ """ |
+ config = self.GetMethodConfig('Rewrite') |
+ return self._RunMethod( |
+ config, request, global_params=global_params) |
+ |
+ def Update(self, request, global_params=None, download=None): |
+ """Updates an object's metadata. |
+ |
+ Args: |
+ request: (StorageObjectsUpdateRequest) input message |
+ global_params: (StandardQueryParameters, default: None) global arguments |
+ download: (Download, default: None) If present, download |
+ data from the request via this stream. |
+ Returns: |
+ (Object) The response message. |
""" |
config = self.GetMethodConfig('Update') |
return self._RunMethod( |
+ config, request, global_params=global_params, |
+ download=download) |
+ |
+ def WatchAll(self, request, global_params=None): |
+ """Watch for changes on all objects in a bucket. |
+ |
+ Args: |
+ request: (StorageObjectsWatchAllRequest) input message |
+ global_params: (StandardQueryParameters, default: None) global arguments |
+ Returns: |
+ (Channel) The response message. |
+ """ |
+ config = self.GetMethodConfig('WatchAll') |
+ return self._RunMethod( |
config, request, global_params=global_params) |