Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(170)

Side by Side Diff: gslib/third_party/storage_apitools/storage_v1_client.py

Issue 698893003: Update checked in version of gsutil to version 4.6 (Closed) Base URL: http://dart.googlecode.com/svn/third_party/gsutil/
Patch Set: Created 6 years, 1 month ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch | Annotate | Revision Log
Property Changes:
Added: svn:eol-style
+ LF
OLDNEW
(Empty)
1 # Copyright 2014 Google Inc. All Rights Reserved.
2 #
3 # Licensed under the Apache License, Version 2.0 (the "License");
4 # you may not use this file except in compliance with the License.
5 # You may obtain a copy of the License at
6 #
7 # http://www.apache.org/licenses/LICENSE-2.0
8 #
9 # Unless required by applicable law or agreed to in writing, software
10 # distributed under the License is distributed on an "AS IS" BASIS,
11 # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12 # See the License for the specific language governing permissions and
13 # limitations under the License.
14 """Generated client library for storage version v1."""
15
16 import gslib
17 import sys
18 from gslib.third_party.storage_apitools import base_api
19 from gslib.third_party.storage_apitools import storage_v1_messages as messages
20
21
22 class StorageV1(base_api.BaseApiClient):
23 """Generated client library for service storage version v1."""
24
25 MESSAGES_MODULE = messages
26
27 _PACKAGE = u'storage'
28 _SCOPES = [u'https://www.googleapis.com/auth/devstorage.full_control', u'https ://www.googleapis.com/auth/devstorage.read_only', u'https://www.googleapis.com/a uth/devstorage.read_write']
29 _VERSION = u'v1'
30 _CLIENT_ID = 'nomatter'
31 _CLIENT_SECRET = 'nomatter'
32 _USER_AGENT = 'apitools gsutil/%s (%s)' % (gslib.VERSION, sys.platform)
33 _CLIENT_CLASS_NAME = u'StorageV1'
34 _URL_VERSION = u'v1'
35
36 def __init__(self, url='', credentials=None,
37 get_credentials=True, http=None, model=None,
38 log_request=False, log_response=False,
39 credentials_args=None, default_global_params=None,
40 version=_VERSION):
41 """Create a new storage handle."""
42 url = url or u'https://www.googleapis.com/storage/v1/'
43 super(StorageV1, self).__init__(
44 url, credentials=credentials,
45 get_credentials=get_credentials, http=http, model=model,
46 log_request=log_request, log_response=log_response,
47 credentials_args=credentials_args,
48 default_global_params=default_global_params)
49 self._version = version
50 self.bucketAccessControls = self.BucketAccessControlsService(self)
51 self.buckets = self.BucketsService(self)
52 self.channels = self.ChannelsService(self)
53 self.defaultObjectAccessControls = self.DefaultObjectAccessControlsService(s elf)
54 self.objectAccessControls = self.ObjectAccessControlsService(self)
55 self.objects = self.ObjectsService(self)
56
57 class BucketAccessControlsService(base_api.BaseApiService):
58 """Service class for the bucketAccessControls resource."""
59
60 def __init__(self, client):
61 super(StorageV1.BucketAccessControlsService, self).__init__(client)
62 self._method_configs = {
63 'Delete': base_api.ApiMethodInfo(
64 http_method=u'DELETE',
65 method_id=u'storage.bucketAccessControls.delete',
66 ordered_params=[u'bucket', u'entity'],
67 path_params=[u'bucket', u'entity'],
68 query_params=[],
69 relative_path=u'b/{bucket}/acl/{entity}',
70 request_field='',
71 request_type_name=u'StorageBucketAccessControlsDeleteRequest',
72 response_type_name=u'StorageBucketAccessControlsDeleteResponse',
73 supports_download=False,
74 ),
75 'Get': base_api.ApiMethodInfo(
76 http_method=u'GET',
77 method_id=u'storage.bucketAccessControls.get',
78 ordered_params=[u'bucket', u'entity'],
79 path_params=[u'bucket', u'entity'],
80 query_params=[],
81 relative_path=u'b/{bucket}/acl/{entity}',
82 request_field='',
83 request_type_name=u'StorageBucketAccessControlsGetRequest',
84 response_type_name=u'BucketAccessControl',
85 supports_download=False,
86 ),
87 'Insert': base_api.ApiMethodInfo(
88 http_method=u'POST',
89 method_id=u'storage.bucketAccessControls.insert',
90 ordered_params=[u'bucket'],
91 path_params=[u'bucket'],
92 query_params=[],
93 relative_path=u'b/{bucket}/acl',
94 request_field='<request>',
95 request_type_name=u'BucketAccessControl',
96 response_type_name=u'BucketAccessControl',
97 supports_download=False,
98 ),
99 'List': base_api.ApiMethodInfo(
100 http_method=u'GET',
101 method_id=u'storage.bucketAccessControls.list',
102 ordered_params=[u'bucket'],
103 path_params=[u'bucket'],
104 query_params=[],
105 relative_path=u'b/{bucket}/acl',
106 request_field='',
107 request_type_name=u'StorageBucketAccessControlsListRequest',
108 response_type_name=u'BucketAccessControls',
109 supports_download=False,
110 ),
111 'Patch': base_api.ApiMethodInfo(
112 http_method=u'PATCH',
113 method_id=u'storage.bucketAccessControls.patch',
114 ordered_params=[u'bucket', u'entity'],
115 path_params=[u'bucket', u'entity'],
116 query_params=[],
117 relative_path=u'b/{bucket}/acl/{entity}',
118 request_field='<request>',
119 request_type_name=u'BucketAccessControl',
120 response_type_name=u'BucketAccessControl',
121 supports_download=False,
122 ),
123 'Update': base_api.ApiMethodInfo(
124 http_method=u'PUT',
125 method_id=u'storage.bucketAccessControls.update',
126 ordered_params=[u'bucket', u'entity'],
127 path_params=[u'bucket', u'entity'],
128 query_params=[],
129 relative_path=u'b/{bucket}/acl/{entity}',
130 request_field='<request>',
131 request_type_name=u'BucketAccessControl',
132 response_type_name=u'BucketAccessControl',
133 supports_download=False,
134 ),
135 }
136
137 self._upload_configs = {
138 }
139
140 def Delete(self, request, global_params=None):
141 """Permanently deletes the ACL entry for the specified entity on the speci fied bucket.
142
143 Args:
144 request: (StorageBucketAccessControlsDeleteRequest) input message
145 global_params: (StandardQueryParameters, default: None) global arguments
146 Returns:
147 (StorageBucketAccessControlsDeleteResponse) The response message.
148 """
149 config = self.GetMethodConfig('Delete')
150 return self._RunMethod(
151 config, request, global_params=global_params)
152
153 def Get(self, request, global_params=None):
154 """Returns the ACL entry for the specified entity on the specified bucket.
155
156 Args:
157 request: (StorageBucketAccessControlsGetRequest) input message
158 global_params: (StandardQueryParameters, default: None) global arguments
159 Returns:
160 (BucketAccessControl) The response message.
161 """
162 config = self.GetMethodConfig('Get')
163 return self._RunMethod(
164 config, request, global_params=global_params)
165
166 def Insert(self, request, global_params=None):
167 """Creates a new ACL entry on the specified bucket.
168
169 Args:
170 request: (BucketAccessControl) input message
171 global_params: (StandardQueryParameters, default: None) global arguments
172 Returns:
173 (BucketAccessControl) The response message.
174 """
175 config = self.GetMethodConfig('Insert')
176 return self._RunMethod(
177 config, request, global_params=global_params)
178
179 def List(self, request, global_params=None):
180 """Retrieves ACL entries on the specified bucket.
181
182 Args:
183 request: (StorageBucketAccessControlsListRequest) input message
184 global_params: (StandardQueryParameters, default: None) global arguments
185 Returns:
186 (BucketAccessControls) The response message.
187 """
188 config = self.GetMethodConfig('List')
189 return self._RunMethod(
190 config, request, global_params=global_params)
191
192 def Patch(self, request, global_params=None):
193 """Updates an ACL entry on the specified bucket. This method supports patc h semantics.
194
195 Args:
196 request: (BucketAccessControl) input message
197 global_params: (StandardQueryParameters, default: None) global arguments
198 Returns:
199 (BucketAccessControl) The response message.
200 """
201 config = self.GetMethodConfig('Patch')
202 return self._RunMethod(
203 config, request, global_params=global_params)
204
205 def Update(self, request, global_params=None):
206 """Updates an ACL entry on the specified bucket.
207
208 Args:
209 request: (BucketAccessControl) input message
210 global_params: (StandardQueryParameters, default: None) global arguments
211 Returns:
212 (BucketAccessControl) The response message.
213 """
214 config = self.GetMethodConfig('Update')
215 return self._RunMethod(
216 config, request, global_params=global_params)
217
218 class BucketsService(base_api.BaseApiService):
219 """Service class for the buckets resource."""
220
221 def __init__(self, client):
222 super(StorageV1.BucketsService, self).__init__(client)
223 self._method_configs = {
224 'Delete': base_api.ApiMethodInfo(
225 http_method=u'DELETE',
226 method_id=u'storage.buckets.delete',
227 ordered_params=[u'bucket'],
228 path_params=[u'bucket'],
229 query_params=[u'ifMetagenerationMatch', u'ifMetagenerationNotMatch '],
230 relative_path=u'b/{bucket}',
231 request_field='',
232 request_type_name=u'StorageBucketsDeleteRequest',
233 response_type_name=u'StorageBucketsDeleteResponse',
234 supports_download=False,
235 ),
236 'Get': base_api.ApiMethodInfo(
237 http_method=u'GET',
238 method_id=u'storage.buckets.get',
239 ordered_params=[u'bucket'],
240 path_params=[u'bucket'],
241 query_params=[u'ifMetagenerationMatch', u'ifMetagenerationNotMatch ', u'projection'],
242 relative_path=u'b/{bucket}',
243 request_field='',
244 request_type_name=u'StorageBucketsGetRequest',
245 response_type_name=u'Bucket',
246 supports_download=False,
247 ),
248 'Insert': base_api.ApiMethodInfo(
249 http_method=u'POST',
250 method_id=u'storage.buckets.insert',
251 ordered_params=[u'project'],
252 path_params=[],
253 query_params=[u'predefinedAcl', u'project', u'projection'],
254 relative_path=u'b',
255 request_field=u'bucket',
256 request_type_name=u'StorageBucketsInsertRequest',
257 response_type_name=u'Bucket',
258 supports_download=False,
259 ),
260 'List': base_api.ApiMethodInfo(
261 http_method=u'GET',
262 method_id=u'storage.buckets.list',
263 ordered_params=[u'project'],
264 path_params=[],
265 query_params=[u'maxResults', u'pageToken', u'project', u'projectio n'],
266 relative_path=u'b',
267 request_field='',
268 request_type_name=u'StorageBucketsListRequest',
269 response_type_name=u'Buckets',
270 supports_download=False,
271 ),
272 'Patch': base_api.ApiMethodInfo(
273 http_method=u'PATCH',
274 method_id=u'storage.buckets.patch',
275 ordered_params=[u'bucket'],
276 path_params=[u'bucket'],
277 query_params=[u'ifMetagenerationMatch', u'ifMetagenerationNotMatch ', u'predefinedAcl', u'projection'],
278 relative_path=u'b/{bucket}',
279 request_field=u'bucketResource',
280 request_type_name=u'StorageBucketsPatchRequest',
281 response_type_name=u'Bucket',
282 supports_download=False,
283 ),
284 'Update': base_api.ApiMethodInfo(
285 http_method=u'PUT',
286 method_id=u'storage.buckets.update',
287 ordered_params=[u'bucket'],
288 path_params=[u'bucket'],
289 query_params=[u'ifMetagenerationMatch', u'ifMetagenerationNotMatch ', u'predefinedAcl', u'projection'],
290 relative_path=u'b/{bucket}',
291 request_field=u'bucketResource',
292 request_type_name=u'StorageBucketsUpdateRequest',
293 response_type_name=u'Bucket',
294 supports_download=False,
295 ),
296 }
297
298 self._upload_configs = {
299 }
300
301 def Delete(self, request, global_params=None):
302 """Permanently deletes an empty bucket.
303
304 Args:
305 request: (StorageBucketsDeleteRequest) input message
306 global_params: (StandardQueryParameters, default: None) global arguments
307 Returns:
308 (StorageBucketsDeleteResponse) The response message.
309 """
310 config = self.GetMethodConfig('Delete')
311 return self._RunMethod(
312 config, request, global_params=global_params)
313
314 def Get(self, request, global_params=None):
315 """Returns metadata for the specified bucket.
316
317 Args:
318 request: (StorageBucketsGetRequest) input message
319 global_params: (StandardQueryParameters, default: None) global arguments
320 Returns:
321 (Bucket) The response message.
322 """
323 config = self.GetMethodConfig('Get')
324 return self._RunMethod(
325 config, request, global_params=global_params)
326
327 def Insert(self, request, global_params=None):
328 """Creates a new bucket.
329
330 Args:
331 request: (StorageBucketsInsertRequest) input message
332 global_params: (StandardQueryParameters, default: None) global arguments
333 Returns:
334 (Bucket) The response message.
335 """
336 config = self.GetMethodConfig('Insert')
337 return self._RunMethod(
338 config, request, global_params=global_params)
339
340 def List(self, request, global_params=None):
341 """Retrieves a list of buckets for a given project.
342
343 Args:
344 request: (StorageBucketsListRequest) input message
345 global_params: (StandardQueryParameters, default: None) global arguments
346 Returns:
347 (Buckets) The response message.
348 """
349 config = self.GetMethodConfig('List')
350 return self._RunMethod(
351 config, request, global_params=global_params)
352
353 def Patch(self, request, global_params=None):
354 """Updates a bucket. This method supports patch semantics.
355
356 Args:
357 request: (StorageBucketsPatchRequest) input message
358 global_params: (StandardQueryParameters, default: None) global arguments
359 Returns:
360 (Bucket) The response message.
361 """
362 config = self.GetMethodConfig('Patch')
363 return self._RunMethod(
364 config, request, global_params=global_params)
365
366 def Update(self, request, global_params=None):
367 """Updates a bucket.
368
369 Args:
370 request: (StorageBucketsUpdateRequest) input message
371 global_params: (StandardQueryParameters, default: None) global arguments
372 Returns:
373 (Bucket) The response message.
374 """
375 config = self.GetMethodConfig('Update')
376 return self._RunMethod(
377 config, request, global_params=global_params)
378
379 class ChannelsService(base_api.BaseApiService):
380 """Service class for the channels resource."""
381
382 def __init__(self, client):
383 super(StorageV1.ChannelsService, self).__init__(client)
384 self._method_configs = {
385 'Stop': base_api.ApiMethodInfo(
386 http_method=u'POST',
387 method_id=u'storage.channels.stop',
388 ordered_params=[],
389 path_params=[],
390 query_params=[],
391 relative_path=u'channels/stop',
392 request_field='<request>',
393 request_type_name=u'Channel',
394 response_type_name=u'StorageChannelsStopResponse',
395 supports_download=False,
396 ),
397 }
398
399 self._upload_configs = {
400 }
401
402 def Stop(self, request, global_params=None):
403 """Stop watching resources through this channel.
404
405 Args:
406 request: (Channel) input message
407 global_params: (StandardQueryParameters, default: None) global arguments
408 Returns:
409 (StorageChannelsStopResponse) The response message.
410 """
411 config = self.GetMethodConfig('Stop')
412 return self._RunMethod(
413 config, request, global_params=global_params)
414
415 class DefaultObjectAccessControlsService(base_api.BaseApiService):
416 """Service class for the defaultObjectAccessControls resource."""
417
418 def __init__(self, client):
419 super(StorageV1.DefaultObjectAccessControlsService, self).__init__(client)
420 self._method_configs = {
421 'Delete': base_api.ApiMethodInfo(
422 http_method=u'DELETE',
423 method_id=u'storage.defaultObjectAccessControls.delete',
424 ordered_params=[u'bucket', u'entity'],
425 path_params=[u'bucket', u'entity'],
426 query_params=[],
427 relative_path=u'b/{bucket}/defaultObjectAcl/{entity}',
428 request_field='',
429 request_type_name=u'StorageDefaultObjectAccessControlsDeleteReques t',
430 response_type_name=u'StorageDefaultObjectAccessControlsDeleteRespo nse',
431 supports_download=False,
432 ),
433 'Get': base_api.ApiMethodInfo(
434 http_method=u'GET',
435 method_id=u'storage.defaultObjectAccessControls.get',
436 ordered_params=[u'bucket', u'entity'],
437 path_params=[u'bucket', u'entity'],
438 query_params=[],
439 relative_path=u'b/{bucket}/defaultObjectAcl/{entity}',
440 request_field='',
441 request_type_name=u'StorageDefaultObjectAccessControlsGetRequest',
442 response_type_name=u'ObjectAccessControl',
443 supports_download=False,
444 ),
445 'Insert': base_api.ApiMethodInfo(
446 http_method=u'POST',
447 method_id=u'storage.defaultObjectAccessControls.insert',
448 ordered_params=[u'bucket'],
449 path_params=[u'bucket'],
450 query_params=[],
451 relative_path=u'b/{bucket}/defaultObjectAcl',
452 request_field='<request>',
453 request_type_name=u'ObjectAccessControl',
454 response_type_name=u'ObjectAccessControl',
455 supports_download=False,
456 ),
457 'List': base_api.ApiMethodInfo(
458 http_method=u'GET',
459 method_id=u'storage.defaultObjectAccessControls.list',
460 ordered_params=[u'bucket'],
461 path_params=[u'bucket'],
462 query_params=[u'ifMetagenerationMatch', u'ifMetagenerationNotMatch '],
463 relative_path=u'b/{bucket}/defaultObjectAcl',
464 request_field='',
465 request_type_name=u'StorageDefaultObjectAccessControlsListRequest' ,
466 response_type_name=u'ObjectAccessControls',
467 supports_download=False,
468 ),
469 'Patch': base_api.ApiMethodInfo(
470 http_method=u'PATCH',
471 method_id=u'storage.defaultObjectAccessControls.patch',
472 ordered_params=[u'bucket', u'entity'],
473 path_params=[u'bucket', u'entity'],
474 query_params=[],
475 relative_path=u'b/{bucket}/defaultObjectAcl/{entity}',
476 request_field='<request>',
477 request_type_name=u'ObjectAccessControl',
478 response_type_name=u'ObjectAccessControl',
479 supports_download=False,
480 ),
481 'Update': base_api.ApiMethodInfo(
482 http_method=u'PUT',
483 method_id=u'storage.defaultObjectAccessControls.update',
484 ordered_params=[u'bucket', u'entity'],
485 path_params=[u'bucket', u'entity'],
486 query_params=[],
487 relative_path=u'b/{bucket}/defaultObjectAcl/{entity}',
488 request_field='<request>',
489 request_type_name=u'ObjectAccessControl',
490 response_type_name=u'ObjectAccessControl',
491 supports_download=False,
492 ),
493 }
494
495 self._upload_configs = {
496 }
497
498 def Delete(self, request, global_params=None):
499 """Permanently deletes the default object ACL entry for the specified enti ty on the specified bucket.
500
501 Args:
502 request: (StorageDefaultObjectAccessControlsDeleteRequest) input message
503 global_params: (StandardQueryParameters, default: None) global arguments
504 Returns:
505 (StorageDefaultObjectAccessControlsDeleteResponse) The response message.
506 """
507 config = self.GetMethodConfig('Delete')
508 return self._RunMethod(
509 config, request, global_params=global_params)
510
511 def Get(self, request, global_params=None):
512 """Returns the default object ACL entry for the specified entity on the sp ecified bucket.
513
514 Args:
515 request: (StorageDefaultObjectAccessControlsGetRequest) input message
516 global_params: (StandardQueryParameters, default: None) global arguments
517 Returns:
518 (ObjectAccessControl) The response message.
519 """
520 config = self.GetMethodConfig('Get')
521 return self._RunMethod(
522 config, request, global_params=global_params)
523
524 def Insert(self, request, global_params=None):
525 """Creates a new default object ACL entry on the specified bucket.
526
527 Args:
528 request: (ObjectAccessControl) input message
529 global_params: (StandardQueryParameters, default: None) global arguments
530 Returns:
531 (ObjectAccessControl) The response message.
532 """
533 config = self.GetMethodConfig('Insert')
534 return self._RunMethod(
535 config, request, global_params=global_params)
536
537 def List(self, request, global_params=None):
538 """Retrieves default object ACL entries on the specified bucket.
539
540 Args:
541 request: (StorageDefaultObjectAccessControlsListRequest) input message
542 global_params: (StandardQueryParameters, default: None) global arguments
543 Returns:
544 (ObjectAccessControls) The response message.
545 """
546 config = self.GetMethodConfig('List')
547 return self._RunMethod(
548 config, request, global_params=global_params)
549
550 def Patch(self, request, global_params=None):
551 """Updates a default object ACL entry on the specified bucket. This method supports patch semantics.
552
553 Args:
554 request: (ObjectAccessControl) input message
555 global_params: (StandardQueryParameters, default: None) global arguments
556 Returns:
557 (ObjectAccessControl) The response message.
558 """
559 config = self.GetMethodConfig('Patch')
560 return self._RunMethod(
561 config, request, global_params=global_params)
562
563 def Update(self, request, global_params=None):
564 """Updates a default object ACL entry on the specified bucket.
565
566 Args:
567 request: (ObjectAccessControl) input message
568 global_params: (StandardQueryParameters, default: None) global arguments
569 Returns:
570 (ObjectAccessControl) The response message.
571 """
572 config = self.GetMethodConfig('Update')
573 return self._RunMethod(
574 config, request, global_params=global_params)
575
576 class ObjectAccessControlsService(base_api.BaseApiService):
577 """Service class for the objectAccessControls resource."""
578
579 def __init__(self, client):
580 super(StorageV1.ObjectAccessControlsService, self).__init__(client)
581 self._method_configs = {
582 'Delete': base_api.ApiMethodInfo(
583 http_method=u'DELETE',
584 method_id=u'storage.objectAccessControls.delete',
585 ordered_params=[u'bucket', u'object', u'entity'],
586 path_params=[u'bucket', u'entity', u'object'],
587 query_params=[u'generation'],
588 relative_path=u'b/{bucket}/o/{object}/acl/{entity}',
589 request_field='',
590 request_type_name=u'StorageObjectAccessControlsDeleteRequest',
591 response_type_name=u'StorageObjectAccessControlsDeleteResponse',
592 supports_download=False,
593 ),
594 'Get': base_api.ApiMethodInfo(
595 http_method=u'GET',
596 method_id=u'storage.objectAccessControls.get',
597 ordered_params=[u'bucket', u'object', u'entity'],
598 path_params=[u'bucket', u'entity', u'object'],
599 query_params=[u'generation'],
600 relative_path=u'b/{bucket}/o/{object}/acl/{entity}',
601 request_field='',
602 request_type_name=u'StorageObjectAccessControlsGetRequest',
603 response_type_name=u'ObjectAccessControl',
604 supports_download=False,
605 ),
606 'Insert': base_api.ApiMethodInfo(
607 http_method=u'POST',
608 method_id=u'storage.objectAccessControls.insert',
609 ordered_params=[u'bucket', u'object'],
610 path_params=[u'bucket', u'object'],
611 query_params=[u'generation'],
612 relative_path=u'b/{bucket}/o/{object}/acl',
613 request_field=u'objectAccessControl',
614 request_type_name=u'StorageObjectAccessControlsInsertRequest',
615 response_type_name=u'ObjectAccessControl',
616 supports_download=False,
617 ),
618 'List': base_api.ApiMethodInfo(
619 http_method=u'GET',
620 method_id=u'storage.objectAccessControls.list',
621 ordered_params=[u'bucket', u'object'],
622 path_params=[u'bucket', u'object'],
623 query_params=[u'generation'],
624 relative_path=u'b/{bucket}/o/{object}/acl',
625 request_field='',
626 request_type_name=u'StorageObjectAccessControlsListRequest',
627 response_type_name=u'ObjectAccessControls',
628 supports_download=False,
629 ),
630 'Patch': base_api.ApiMethodInfo(
631 http_method=u'PATCH',
632 method_id=u'storage.objectAccessControls.patch',
633 ordered_params=[u'bucket', u'object', u'entity'],
634 path_params=[u'bucket', u'entity', u'object'],
635 query_params=[u'generation'],
636 relative_path=u'b/{bucket}/o/{object}/acl/{entity}',
637 request_field=u'objectAccessControl',
638 request_type_name=u'StorageObjectAccessControlsPatchRequest',
639 response_type_name=u'ObjectAccessControl',
640 supports_download=False,
641 ),
642 'Update': base_api.ApiMethodInfo(
643 http_method=u'PUT',
644 method_id=u'storage.objectAccessControls.update',
645 ordered_params=[u'bucket', u'object', u'entity'],
646 path_params=[u'bucket', u'entity', u'object'],
647 query_params=[u'generation'],
648 relative_path=u'b/{bucket}/o/{object}/acl/{entity}',
649 request_field=u'objectAccessControl',
650 request_type_name=u'StorageObjectAccessControlsUpdateRequest',
651 response_type_name=u'ObjectAccessControl',
652 supports_download=False,
653 ),
654 }
655
656 self._upload_configs = {
657 }
658
659 def Delete(self, request, global_params=None):
660 """Permanently deletes the ACL entry for the specified entity on the speci fied object.
661
662 Args:
663 request: (StorageObjectAccessControlsDeleteRequest) input message
664 global_params: (StandardQueryParameters, default: None) global arguments
665 Returns:
666 (StorageObjectAccessControlsDeleteResponse) The response message.
667 """
668 config = self.GetMethodConfig('Delete')
669 return self._RunMethod(
670 config, request, global_params=global_params)
671
672 def Get(self, request, global_params=None):
673 """Returns the ACL entry for the specified entity on the specified object.
674
675 Args:
676 request: (StorageObjectAccessControlsGetRequest) input message
677 global_params: (StandardQueryParameters, default: None) global arguments
678 Returns:
679 (ObjectAccessControl) The response message.
680 """
681 config = self.GetMethodConfig('Get')
682 return self._RunMethod(
683 config, request, global_params=global_params)
684
685 def Insert(self, request, global_params=None):
686 """Creates a new ACL entry on the specified object.
687
688 Args:
689 request: (StorageObjectAccessControlsInsertRequest) input message
690 global_params: (StandardQueryParameters, default: None) global arguments
691 Returns:
692 (ObjectAccessControl) The response message.
693 """
694 config = self.GetMethodConfig('Insert')
695 return self._RunMethod(
696 config, request, global_params=global_params)
697
698 def List(self, request, global_params=None):
699 """Retrieves ACL entries on the specified object.
700
701 Args:
702 request: (StorageObjectAccessControlsListRequest) input message
703 global_params: (StandardQueryParameters, default: None) global arguments
704 Returns:
705 (ObjectAccessControls) The response message.
706 """
707 config = self.GetMethodConfig('List')
708 return self._RunMethod(
709 config, request, global_params=global_params)
710
711 def Patch(self, request, global_params=None):
712 """Updates an ACL entry on the specified object. This method supports patc h semantics.
713
714 Args:
715 request: (StorageObjectAccessControlsPatchRequest) input message
716 global_params: (StandardQueryParameters, default: None) global arguments
717 Returns:
718 (ObjectAccessControl) The response message.
719 """
720 config = self.GetMethodConfig('Patch')
721 return self._RunMethod(
722 config, request, global_params=global_params)
723
724 def Update(self, request, global_params=None):
725 """Updates an ACL entry on the specified object.
726
727 Args:
728 request: (StorageObjectAccessControlsUpdateRequest) input message
729 global_params: (StandardQueryParameters, default: None) global arguments
730 Returns:
731 (ObjectAccessControl) The response message.
732 """
733 config = self.GetMethodConfig('Update')
734 return self._RunMethod(
735 config, request, global_params=global_params)
736
737 class ObjectsService(base_api.BaseApiService):
738 """Service class for the objects resource."""
739
740 def __init__(self, client):
741 super(StorageV1.ObjectsService, self).__init__(client)
742 self._method_configs = {
743 'Compose': base_api.ApiMethodInfo(
744 http_method=u'POST',
745 method_id=u'storage.objects.compose',
746 ordered_params=[u'destinationBucket', u'destinationObject'],
747 path_params=[u'destinationBucket', u'destinationObject'],
748 query_params=[u'destinationPredefinedAcl', u'ifGenerationMatch', u 'ifMetagenerationMatch'],
749 relative_path=u'b/{destinationBucket}/o/{destinationObject}/compos e',
750 request_field=u'composeRequest',
751 request_type_name=u'StorageObjectsComposeRequest',
752 response_type_name=u'Object',
753 supports_download=True,
754 ),
755 'Copy': base_api.ApiMethodInfo(
756 http_method=u'POST',
757 method_id=u'storage.objects.copy',
758 ordered_params=[u'sourceBucket', u'sourceObject', u'destinationBuc ket', u'destinationObject'],
759 path_params=[u'destinationBucket', u'destinationObject', u'sourceB ucket', u'sourceObject'],
760 query_params=[u'destinationPredefinedAcl', u'ifGenerationMatch', u 'ifGenerationNotMatch', u'ifMetagenerationMatch', u'ifMetagenerationNotMatch', u 'ifSourceGenerationMatch', u'ifSourceGenerationNotMatch', u'ifSourceMetagenerati onMatch', u'ifSourceMetagenerationNotMatch', u'projection', u'sourceGeneration'] ,
761 relative_path=u'b/{sourceBucket}/o/{sourceObject}/copyTo/b/{destin ationBucket}/o/{destinationObject}',
762 request_field=u'object',
763 request_type_name=u'StorageObjectsCopyRequest',
764 response_type_name=u'Object',
765 supports_download=True,
766 ),
767 'Delete': base_api.ApiMethodInfo(
768 http_method=u'DELETE',
769 method_id=u'storage.objects.delete',
770 ordered_params=[u'bucket', u'object'],
771 path_params=[u'bucket', u'object'],
772 query_params=[u'generation', u'ifGenerationMatch', u'ifGenerationN otMatch', u'ifMetagenerationMatch', u'ifMetagenerationNotMatch'],
773 relative_path=u'b/{bucket}/o/{object}',
774 request_field='',
775 request_type_name=u'StorageObjectsDeleteRequest',
776 response_type_name=u'StorageObjectsDeleteResponse',
777 supports_download=False,
778 ),
779 'Get': base_api.ApiMethodInfo(
780 http_method=u'GET',
781 method_id=u'storage.objects.get',
782 ordered_params=[u'bucket', u'object'],
783 path_params=[u'bucket', u'object'],
784 query_params=[u'generation', u'ifGenerationMatch', u'ifGenerationN otMatch', u'ifMetagenerationMatch', u'ifMetagenerationNotMatch', u'projection'],
785 relative_path=u'b/{bucket}/o/{object}',
786 request_field='',
787 request_type_name=u'StorageObjectsGetRequest',
788 response_type_name=u'Object',
789 supports_download=True,
790 ),
791 'Insert': base_api.ApiMethodInfo(
792 http_method=u'POST',
793 method_id=u'storage.objects.insert',
794 ordered_params=[u'bucket'],
795 path_params=[u'bucket'],
796 query_params=[u'contentEncoding', u'ifGenerationMatch', u'ifGenera tionNotMatch', u'ifMetagenerationMatch', u'ifMetagenerationNotMatch', u'name', u 'predefinedAcl', u'projection'],
797 relative_path=u'b/{bucket}/o',
798 request_field=u'object',
799 request_type_name=u'StorageObjectsInsertRequest',
800 response_type_name=u'Object',
801 supports_download=True,
802 ),
803 'List': base_api.ApiMethodInfo(
804 http_method=u'GET',
805 method_id=u'storage.objects.list',
806 ordered_params=[u'bucket'],
807 path_params=[u'bucket'],
808 query_params=[u'delimiter', u'maxResults', u'pageToken', u'prefix' , u'projection', u'versions'],
809 relative_path=u'b/{bucket}/o',
810 request_field='',
811 request_type_name=u'StorageObjectsListRequest',
812 response_type_name=u'Objects',
813 supports_download=False,
814 ),
815 'Patch': base_api.ApiMethodInfo(
816 http_method=u'PATCH',
817 method_id=u'storage.objects.patch',
818 ordered_params=[u'bucket', u'object'],
819 path_params=[u'bucket', u'object'],
820 query_params=[u'generation', u'ifGenerationMatch', u'ifGenerationN otMatch', u'ifMetagenerationMatch', u'ifMetagenerationNotMatch', u'predefinedAcl ', u'projection'],
821 relative_path=u'b/{bucket}/o/{object}',
822 request_field=u'objectResource',
823 request_type_name=u'StorageObjectsPatchRequest',
824 response_type_name=u'Object',
825 supports_download=False,
826 ),
827 'Update': base_api.ApiMethodInfo(
828 http_method=u'PUT',
829 method_id=u'storage.objects.update',
830 ordered_params=[u'bucket', u'object'],
831 path_params=[u'bucket', u'object'],
832 query_params=[u'generation', u'ifGenerationMatch', u'ifGenerationN otMatch', u'ifMetagenerationMatch', u'ifMetagenerationNotMatch', u'predefinedAcl ', u'projection'],
833 relative_path=u'b/{bucket}/o/{object}',
834 request_field=u'objectResource',
835 request_type_name=u'StorageObjectsUpdateRequest',
836 response_type_name=u'Object',
837 supports_download=True,
838 ),
839 'WatchAll': base_api.ApiMethodInfo(
840 http_method=u'POST',
841 method_id=u'storage.objects.watchAll',
842 ordered_params=[u'bucket'],
843 path_params=[u'bucket'],
844 query_params=[u'delimiter', u'maxResults', u'pageToken', u'prefix' , u'projection', u'versions'],
845 relative_path=u'b/{bucket}/o/watch',
846 request_field=u'channel',
847 request_type_name=u'StorageObjectsWatchAllRequest',
848 response_type_name=u'Channel',
849 supports_download=False,
850 ),
851 }
852
853 self._upload_configs = {
854 'Insert': base_api.ApiUploadInfo(
855 accept=['*/*'],
856 max_size=None,
857 resumable_multipart=True,
858 resumable_path=u'/resumable/upload/storage/' + self._client._versi on + '/b/{bucket}/o',
859 simple_multipart=True,
860 simple_path=u'/upload/storage/' + self._client._version + '/b/{buc ket}/o',
861 ),
862 }
863
864 def Compose(self, request, global_params=None, download=None):
865 """Concatenates a list of existing objects into a new object in the same b ucket.
866
867 Args:
868 request: (StorageObjectsComposeRequest) input message
869 global_params: (StandardQueryParameters, default: None) global arguments
870 download: (Download, default: None) If present, download
871 data from the request via this stream.
872 Returns:
873 (Object) The response message.
874 """
875 config = self.GetMethodConfig('Compose')
876 return self._RunMethod(
877 config, request, global_params=global_params,
878 download=download)
879
880 def Copy(self, request, global_params=None, download=None):
881 """Copies an object to a specified location. Optionally overrides metadata .
882
883 Args:
884 request: (StorageObjectsCopyRequest) input message
885 global_params: (StandardQueryParameters, default: None) global arguments
886 download: (Download, default: None) If present, download
887 data from the request via this stream.
888 Returns:
889 (Object) The response message.
890 """
891 config = self.GetMethodConfig('Copy')
892 return self._RunMethod(
893 config, request, global_params=global_params,
894 download=download)
895
896 def Delete(self, request, global_params=None):
897 """Deletes an object and its metadata. Deletions are permanent if versioni ng is not enabled for the bucket, or if the generation parameter is used.
898
899 Args:
900 request: (StorageObjectsDeleteRequest) input message
901 global_params: (StandardQueryParameters, default: None) global arguments
902 Returns:
903 (StorageObjectsDeleteResponse) The response message.
904 """
905 config = self.GetMethodConfig('Delete')
906 return self._RunMethod(
907 config, request, global_params=global_params)
908
909 def Get(self, request, global_params=None, download=None):
910 """Retrieves objects or their metadata.
911
912 Args:
913 request: (StorageObjectsGetRequest) input message
914 global_params: (StandardQueryParameters, default: None) global arguments
915 download: (Download, default: None) If present, download
916 data from the request via this stream.
917 Returns:
918 (Object) The response message.
919 """
920 config = self.GetMethodConfig('Get')
921 return self._RunMethod(
922 config, request, global_params=global_params,
923 download=download)
924
925 def Insert(self, request, global_params=None, upload=None, download=None):
926 """Stores a new object and metadata.
927
928 Args:
929 request: (StorageObjectsInsertRequest) input message
930 global_params: (StandardQueryParameters, default: None) global arguments
931 upload: (Upload, default: None) If present, upload
932 this stream with the request.
933 download: (Download, default: None) If present, download
934 data from the request via this stream.
935 Returns:
936 (Object) The response message.
937 """
938 config = self.GetMethodConfig('Insert')
939 upload_config = self.GetUploadConfig('Insert')
940 return self._RunMethod(
941 config, request, global_params=global_params,
942 upload=upload, upload_config=upload_config,
943 download=download)
944
945 def List(self, request, global_params=None):
946 """Retrieves a list of objects matching the criteria.
947
948 Args:
949 request: (StorageObjectsListRequest) input message
950 global_params: (StandardQueryParameters, default: None) global arguments
951 Returns:
952 (Objects) The response message.
953 """
954 config = self.GetMethodConfig('List')
955 return self._RunMethod(
956 config, request, global_params=global_params)
957
958 def Patch(self, request, global_params=None):
959 """Updates an object's metadata. This method supports patch semantics.
960
961 Args:
962 request: (StorageObjectsPatchRequest) input message
963 global_params: (StandardQueryParameters, default: None) global arguments
964 Returns:
965 (Object) The response message.
966 """
967 config = self.GetMethodConfig('Patch')
968 return self._RunMethod(
969 config, request, global_params=global_params)
970
971 def Update(self, request, global_params=None, download=None):
972 """Updates an object's metadata.
973
974 Args:
975 request: (StorageObjectsUpdateRequest) input message
976 global_params: (StandardQueryParameters, default: None) global arguments
977 download: (Download, default: None) If present, download
978 data from the request via this stream.
979 Returns:
980 (Object) The response message.
981 """
982 config = self.GetMethodConfig('Update')
983 return self._RunMethod(
984 config, request, global_params=global_params,
985 download=download)
986
987 def WatchAll(self, request, global_params=None):
988 """Watch for changes on all objects in a bucket.
989
990 Args:
991 request: (StorageObjectsWatchAllRequest) input message
992 global_params: (StandardQueryParameters, default: None) global arguments
993 Returns:
994 (Channel) The response message.
995 """
996 config = self.GetMethodConfig('WatchAll')
997 return self._RunMethod(
998 config, request, global_params=global_params)
OLDNEW
« no previous file with comments | « gslib/third_party/storage_apitools/http_wrapper.py ('k') | gslib/third_party/storage_apitools/storage_v1_messages.py » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698