Index: tools/telemetry/third_party/gsutil/gslib/third_party/storage_apitools/storage_v1_client.py |
diff --git a/tools/telemetry/third_party/gsutil/gslib/third_party/storage_apitools/storage_v1_client.py b/tools/telemetry/third_party/gsutil/gslib/third_party/storage_apitools/storage_v1_client.py |
deleted file mode 100644 |
index bbffce3e51ca759bd5cab7e19dded1a2d3e2a825..0000000000000000000000000000000000000000 |
--- a/tools/telemetry/third_party/gsutil/gslib/third_party/storage_apitools/storage_v1_client.py |
+++ /dev/null |
@@ -1,1043 +0,0 @@ |
-# Copyright 2014 Google Inc. All Rights Reserved. |
-# |
-# Licensed under the Apache License, Version 2.0 (the "License"); |
-# you may not use this file except in compliance with the License. |
-# You may obtain a copy of the License at |
-# |
-# http://www.apache.org/licenses/LICENSE-2.0 |
-# |
-# Unless required by applicable law or agreed to in writing, software |
-# distributed under the License is distributed on an "AS IS" BASIS, |
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
-# See the License for the specific language governing permissions and |
-# limitations under the License. |
-"""Generated client library for storage version v1.""" |
- |
-import os |
-import sys |
- |
-from apitools.base.py import base_api |
- |
-import gslib |
-from gslib.third_party.storage_apitools import storage_v1_messages as messages |
- |
- |
-class StorageV1(base_api.BaseApiClient): |
- """Generated client library for service storage version v1.""" |
- |
- MESSAGES_MODULE = messages |
- |
- _PACKAGE = u'storage' |
- _SCOPES = [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'] |
- _VERSION = u'v1' |
- _CLIENT_ID = 'nomatter' |
- _CLIENT_SECRET = 'nomatter' |
- _USER_AGENT = 'apitools gsutil/%s (%s)' % (gslib.VERSION, sys.platform) |
- if os.environ.get('CLOUDSDK_WRAPPER') == '1': |
- _USER_AGENT += ' Cloud SDK Command Line Tool' |
- if os.environ.get('CLOUDSDK_VERSION'): |
- _USER_AGENT += ' %s' % os.environ.get('CLOUDSDK_VERSION') |
- _CLIENT_CLASS_NAME = u'StorageV1' |
- _URL_VERSION = u'v1' |
- |
- def __init__(self, url='', credentials=None, |
- get_credentials=True, http=None, model=None, |
- log_request=False, log_response=False, |
- credentials_args=None, default_global_params=None, |
- version=_VERSION): |
- """Create a new storage handle.""" |
- url = url or u'https://www.googleapis.com/storage/v1/' |
- super(StorageV1, self).__init__( |
- url, credentials=credentials, |
- get_credentials=get_credentials, http=http, model=model, |
- log_request=log_request, log_response=log_response, |
- credentials_args=credentials_args, |
- default_global_params=default_global_params) |
- self._version = version |
- self.bucketAccessControls = self.BucketAccessControlsService(self) |
- self.buckets = self.BucketsService(self) |
- self.channels = self.ChannelsService(self) |
- self.defaultObjectAccessControls = self.DefaultObjectAccessControlsService(self) |
- self.objectAccessControls = self.ObjectAccessControlsService(self) |
- self.objects = self.ObjectsService(self) |
- |
- |
- class BucketAccessControlsService(base_api.BaseApiService): |
- """Service class for the bucketAccessControls resource.""" |
- |
- _NAME = u'bucketAccessControls' |
- |
- def __init__(self, client): |
- super(StorageV1.BucketAccessControlsService, 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}', |
- request_field='', |
- 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.bucketAccessControls.get', |
- ordered_params=[u'bucket', u'entity'], |
- path_params=[u'bucket', u'entity'], |
- query_params=[], |
- relative_path=u'b/{bucket}/acl/{entity}', |
- request_field='', |
- 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.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', |
- 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', |
- request_field='', |
- 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.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', |
- 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', |
- supports_download=False, |
- ), |
- } |
- |
- self._upload_configs = { |
- } |
- |
- def Delete(self, request, global_params=None): |
- """Permanently deletes the ACL entry for the specified entity on the specified bucket. |
- |
- Args: |
- request: (StorageBucketAccessControlsDeleteRequest) input message |
- global_params: (StandardQueryParameters, default: None) global arguments |
- Returns: |
- (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 ACL entry for the specified entity on the specified bucket. |
- |
- Args: |
- request: (StorageBucketAccessControlsGetRequest) input message |
- global_params: (StandardQueryParameters, default: None) global arguments |
- Returns: |
- (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 ACL entry on the specified bucket. |
- |
- Args: |
- request: (BucketAccessControl) input message |
- global_params: (StandardQueryParameters, default: None) global arguments |
- Returns: |
- (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 ACL entries on the specified bucket. |
- |
- Args: |
- request: (StorageBucketAccessControlsListRequest) input message |
- global_params: (StandardQueryParameters, default: None) global arguments |
- Returns: |
- (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 an ACL entry on the specified bucket. This method supports patch semantics. |
- |
- Args: |
- request: (BucketAccessControl) input message |
- global_params: (StandardQueryParameters, default: None) global arguments |
- Returns: |
- (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 an ACL entry on the specified bucket. |
- |
- Args: |
- request: (BucketAccessControl) input message |
- global_params: (StandardQueryParameters, default: None) global arguments |
- Returns: |
- (BucketAccessControl) The response message. |
- """ |
- config = self.GetMethodConfig('Update') |
- return self._RunMethod( |
- config, request, global_params=global_params) |
- |
- class BucketsService(base_api.BaseApiService): |
- """Service class for the buckets resource.""" |
- |
- _NAME = u'buckets' |
- |
- def __init__(self, client): |
- super(StorageV1.BucketsService, self).__init__(client) |
- self._method_configs = { |
- '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}', |
- request_field='', |
- 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.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'StorageBucketsGetRequest', |
- response_type_name=u'Bucket', |
- supports_download=False, |
- ), |
- '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, |
- ), |
- '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', |
- request_field='', |
- 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.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.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, |
- ), |
- } |
- |
- self._upload_configs = { |
- } |
- |
- def Delete(self, request, global_params=None): |
- """Permanently deletes an empty bucket. |
- |
- Args: |
- request: (StorageBucketsDeleteRequest) input message |
- global_params: (StandardQueryParameters, default: None) global arguments |
- Returns: |
- (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 metadata for the specified bucket. |
- |
- Args: |
- request: (StorageBucketsGetRequest) input message |
- global_params: (StandardQueryParameters, default: None) global arguments |
- Returns: |
- (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 bucket. |
- |
- Args: |
- request: (StorageBucketsInsertRequest) input message |
- global_params: (StandardQueryParameters, default: None) global arguments |
- Returns: |
- (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 a list of buckets for a given project. |
- |
- Args: |
- request: (StorageBucketsListRequest) input message |
- global_params: (StandardQueryParameters, default: None) global arguments |
- Returns: |
- (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 a bucket. This method supports patch semantics. |
- |
- Args: |
- request: (StorageBucketsPatchRequest) input message |
- global_params: (StandardQueryParameters, default: None) global arguments |
- Returns: |
- (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 a bucket. |
- |
- Args: |
- request: (StorageBucketsUpdateRequest) input message |
- global_params: (StandardQueryParameters, default: None) global arguments |
- Returns: |
- (Bucket) The response message. |
- """ |
- config = self.GetMethodConfig('Update') |
- return self._RunMethod( |
- config, request, global_params=global_params) |
- |
- class ChannelsService(base_api.BaseApiService): |
- """Service class for the channels resource.""" |
- |
- _NAME = u'channels' |
- |
- def __init__(self, client): |
- super(StorageV1.ChannelsService, self).__init__(client) |
- self._method_configs = { |
- 'Stop': base_api.ApiMethodInfo( |
- http_method=u'POST', |
- method_id=u'storage.channels.stop', |
- ordered_params=[], |
- path_params=[], |
- query_params=[], |
- relative_path=u'channels/stop', |
- request_field='<request>', |
- request_type_name=u'Channel', |
- response_type_name=u'StorageChannelsStopResponse', |
- supports_download=False, |
- ), |
- } |
- |
- self._upload_configs = { |
- } |
- |
- def Stop(self, request, global_params=None): |
- """Stop watching resources through this channel. |
- |
- Args: |
- request: (Channel) input message |
- global_params: (StandardQueryParameters, default: None) global arguments |
- Returns: |
- (StorageChannelsStopResponse) The response message. |
- """ |
- config = self.GetMethodConfig('Stop') |
- return self._RunMethod( |
- config, request, global_params=global_params) |
- |
- class DefaultObjectAccessControlsService(base_api.BaseApiService): |
- """Service class for the defaultObjectAccessControls resource.""" |
- |
- _NAME = u'defaultObjectAccessControls' |
- |
- def __init__(self, client): |
- super(StorageV1.DefaultObjectAccessControlsService, self).__init__(client) |
- self._method_configs = { |
- 'Delete': base_api.ApiMethodInfo( |
- http_method=u'DELETE', |
- 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'StorageDefaultObjectAccessControlsDeleteRequest', |
- response_type_name=u'StorageDefaultObjectAccessControlsDeleteResponse', |
- supports_download=False, |
- ), |
- 'Get': base_api.ApiMethodInfo( |
- http_method=u'GET', |
- 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'StorageDefaultObjectAccessControlsGetRequest', |
- response_type_name=u'ObjectAccessControl', |
- supports_download=False, |
- ), |
- 'Insert': base_api.ApiMethodInfo( |
- http_method=u'POST', |
- method_id=u'storage.defaultObjectAccessControls.insert', |
- ordered_params=[u'bucket'], |
- path_params=[u'bucket'], |
- 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.defaultObjectAccessControls.list', |
- ordered_params=[u'bucket'], |
- path_params=[u'bucket'], |
- query_params=[u'ifMetagenerationMatch', u'ifMetagenerationNotMatch'], |
- relative_path=u'b/{bucket}/defaultObjectAcl', |
- request_field='', |
- 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.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.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 = { |
- } |
- |
- def Delete(self, request, global_params=None): |
- """Permanently deletes the default object ACL entry for the specified entity on the specified bucket. |
- |
- Args: |
- request: (StorageDefaultObjectAccessControlsDeleteRequest) input message |
- global_params: (StandardQueryParameters, default: None) global arguments |
- Returns: |
- (StorageDefaultObjectAccessControlsDeleteResponse) 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. |
- |
- Args: |
- request: (StorageDefaultObjectAccessControlsGetRequest) input message |
- global_params: (StandardQueryParameters, default: None) global arguments |
- Returns: |
- (ObjectAccessControl) 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. |
- |
- Args: |
- request: (ObjectAccessControl) input message |
- global_params: (StandardQueryParameters, default: None) global arguments |
- Returns: |
- (ObjectAccessControl) 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. |
- |
- Args: |
- request: (StorageDefaultObjectAccessControlsListRequest) input message |
- global_params: (StandardQueryParameters, default: None) global arguments |
- Returns: |
- (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 a default object ACL entry on the specified bucket. This method supports patch semantics. |
- |
- Args: |
- request: (ObjectAccessControl) input message |
- global_params: (StandardQueryParameters, default: None) global arguments |
- Returns: |
- (ObjectAccessControl) 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. |
- |
- Args: |
- request: (ObjectAccessControl) input message |
- global_params: (StandardQueryParameters, default: None) global arguments |
- Returns: |
- (ObjectAccessControl) The response message. |
- """ |
- config = self.GetMethodConfig('Update') |
- return self._RunMethod( |
- config, request, global_params=global_params) |
- |
- class ObjectAccessControlsService(base_api.BaseApiService): |
- """Service class for the objectAccessControls resource.""" |
- |
- _NAME = u'objectAccessControls' |
- |
- def __init__(self, client): |
- super(StorageV1.ObjectAccessControlsService, self).__init__(client) |
- self._method_configs = { |
- 'Delete': base_api.ApiMethodInfo( |
- http_method=u'DELETE', |
- method_id=u'storage.objectAccessControls.delete', |
- ordered_params=[u'bucket', u'object', u'entity'], |
- path_params=[u'bucket', u'entity', u'object'], |
- query_params=[u'generation'], |
- relative_path=u'b/{bucket}/o/{object}/acl/{entity}', |
- request_field='', |
- request_type_name=u'StorageObjectAccessControlsDeleteRequest', |
- response_type_name=u'StorageObjectAccessControlsDeleteResponse', |
- supports_download=False, |
- ), |
- 'Get': base_api.ApiMethodInfo( |
- http_method=u'GET', |
- method_id=u'storage.objectAccessControls.get', |
- ordered_params=[u'bucket', u'object', u'entity'], |
- path_params=[u'bucket', u'entity', u'object'], |
- query_params=[u'generation'], |
- relative_path=u'b/{bucket}/o/{object}/acl/{entity}', |
- request_field='', |
- request_type_name=u'StorageObjectAccessControlsGetRequest', |
- response_type_name=u'ObjectAccessControl', |
- supports_download=False, |
- ), |
- 'Insert': base_api.ApiMethodInfo( |
- http_method=u'POST', |
- method_id=u'storage.objectAccessControls.insert', |
- ordered_params=[u'bucket', u'object'], |
- path_params=[u'bucket', u'object'], |
- query_params=[u'generation'], |
- relative_path=u'b/{bucket}/o/{object}/acl', |
- request_field=u'objectAccessControl', |
- request_type_name=u'StorageObjectAccessControlsInsertRequest', |
- response_type_name=u'ObjectAccessControl', |
- supports_download=False, |
- ), |
- 'List': base_api.ApiMethodInfo( |
- http_method=u'GET', |
- method_id=u'storage.objectAccessControls.list', |
- ordered_params=[u'bucket', u'object'], |
- path_params=[u'bucket', u'object'], |
- query_params=[u'generation'], |
- relative_path=u'b/{bucket}/o/{object}/acl', |
- request_field='', |
- request_type_name=u'StorageObjectAccessControlsListRequest', |
- response_type_name=u'ObjectAccessControls', |
- supports_download=False, |
- ), |
- 'Patch': base_api.ApiMethodInfo( |
- http_method=u'PATCH', |
- method_id=u'storage.objectAccessControls.patch', |
- ordered_params=[u'bucket', u'object', u'entity'], |
- path_params=[u'bucket', u'entity', u'object'], |
- query_params=[u'generation'], |
- relative_path=u'b/{bucket}/o/{object}/acl/{entity}', |
- request_field=u'objectAccessControl', |
- request_type_name=u'StorageObjectAccessControlsPatchRequest', |
- response_type_name=u'ObjectAccessControl', |
- supports_download=False, |
- ), |
- 'Update': base_api.ApiMethodInfo( |
- http_method=u'PUT', |
- method_id=u'storage.objectAccessControls.update', |
- ordered_params=[u'bucket', u'object', u'entity'], |
- path_params=[u'bucket', u'entity', u'object'], |
- query_params=[u'generation'], |
- relative_path=u'b/{bucket}/o/{object}/acl/{entity}', |
- request_field=u'objectAccessControl', |
- request_type_name=u'StorageObjectAccessControlsUpdateRequest', |
- response_type_name=u'ObjectAccessControl', |
- supports_download=False, |
- ), |
- } |
- |
- self._upload_configs = { |
- } |
- |
- def Delete(self, request, global_params=None): |
- """Permanently deletes the ACL entry for the specified entity on the specified object. |
- |
- Args: |
- request: (StorageObjectAccessControlsDeleteRequest) input message |
- global_params: (StandardQueryParameters, default: None) global arguments |
- Returns: |
- (StorageObjectAccessControlsDeleteResponse) 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 object. |
- |
- Args: |
- request: (StorageObjectAccessControlsGetRequest) input message |
- global_params: (StandardQueryParameters, default: None) global arguments |
- Returns: |
- (ObjectAccessControl) 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 object. |
- |
- Args: |
- request: (StorageObjectAccessControlsInsertRequest) input message |
- global_params: (StandardQueryParameters, default: None) global arguments |
- Returns: |
- (ObjectAccessControl) 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 object. |
- |
- Args: |
- request: (StorageObjectAccessControlsListRequest) input message |
- global_params: (StandardQueryParameters, default: None) global arguments |
- Returns: |
- (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 ACL entry on the specified object. This method supports patch semantics. |
- |
- Args: |
- request: (StorageObjectAccessControlsPatchRequest) input message |
- global_params: (StandardQueryParameters, default: None) global arguments |
- Returns: |
- (ObjectAccessControl) 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 object. |
- |
- Args: |
- request: (StorageObjectAccessControlsUpdateRequest) input message |
- global_params: (StandardQueryParameters, default: None) global arguments |
- Returns: |
- (ObjectAccessControl) The response message. |
- """ |
- config = self.GetMethodConfig('Update') |
- return self._RunMethod( |
- config, request, global_params=global_params) |
- |
- class ObjectsService(base_api.BaseApiService): |
- """Service class for the objects resource.""" |
- |
- _NAME = u'objects' |
- |
- def __init__(self, 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.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'StorageObjectsDeleteRequest', |
- response_type_name=u'StorageObjectsDeleteResponse', |
- 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}', |
- request_field='', |
- 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.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.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'StorageObjectsListRequest', |
- response_type_name=u'Objects', |
- 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', |
- 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.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', |
- supports_download=False, |
- ), |
- } |
- |
- self._upload_configs = { |
- 'Insert': base_api.ApiUploadInfo( |
- accept=['*/*'], |
- max_size=None, |
- resumable_multipart=True, |
- resumable_path=u'/resumable/upload/storage/' + self._client._version + '/b/{bucket}/o', |
- simple_multipart=True, |
- simple_path=u'/upload/storage/' + self._client._version + '/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. |
- |
- Args: |
- request: (StorageObjectsDeleteRequest) input message |
- global_params: (StandardQueryParameters, default: None) global arguments |
- Returns: |
- (StorageObjectsDeleteResponse) 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. |
- |
- Args: |
- 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: |
- (Object) The response message. |
- """ |
- config = self.GetMethodConfig('Get') |
- return self._RunMethod( |
- config, request, global_params=global_params, |
- download=download) |
- |
- def Insert(self, request, global_params=None, upload=None, download=None): |
- """Stores a new object and metadata. |
- |
- Args: |
- 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: |
- (Object) 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) |
- |
- def List(self, request, global_params=None): |
- """Retrieves a list of objects matching the criteria. |
- |
- Args: |
- request: (StorageObjectsListRequest) input message |
- global_params: (StandardQueryParameters, default: None) global arguments |
- Returns: |
- (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 an object's metadata. This method supports patch semantics. |
- |
- Args: |
- request: (StorageObjectsPatchRequest) input message |
- global_params: (StandardQueryParameters, default: None) global arguments |
- Returns: |
- (Object) The response message. |
- """ |
- config = self.GetMethodConfig('Patch') |
- return self._RunMethod( |
- config, request, global_params=global_params) |
- |
- def Rewrite(self, request, global_params=None): |
- """Rewrites a source object to a destination object. Optionally overrides metadata. |
- |
- Args: |
- request: (StorageObjectsRewriteRequest) input message |
- global_params: (StandardQueryParameters, default: None) global arguments |
- Returns: |
- (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) |