Home
last modified time | relevance | path

Searched refs:gsutil_api (Results 1 – 25 of 30) sorted by relevance

12

/external/chromium-trace/catapult/third_party/gsutil/gslib/
Dtab_complete.py165 def __init__(self, wildcard_url_str, gsutil_api): argument
175 self._gsutil_api = gsutil_api
193 def __init__(self, gsutil_api, bucket_only=False): argument
200 self._gsutil_api = gsutil_api
285 def __init__(self, gsutil_api): argument
286 self.cloud_object_completer = CloudObjectCompleter(gsutil_api)
304 def MakeCompleter(completer_type, gsutil_api): argument
316 return CloudOrLocalObjectCompleter(gsutil_api)
322 return CloudObjectCompleter(gsutil_api, bucket_only=True)
324 return CloudObjectCompleter(gsutil_api)
Dcopy_helper.py253 gsutil_api = GetCloudApiInstance(cls, thread_state=thread_state)
270 orig_prefer_api = gsutil_api.prefer_api
271 gsutil_api.prefer_api = ApiSelector.XML
274 preconditions, gsutil_api, cls.logger, cls,
279 gsutil_api.prefer_api = orig_prefer_api
927 canned_acl, file_size, preconditions, gsutil_api, argument
952 api_selector = gsutil_api.GetApiSelector(provider=dst_url.scheme)
972 gsutil_api))
1003 composed_object = gsutil_api.ComposeObject(
1089 def ExpandUrlToSingleBlr(url_str, gsutil_api, debug, project_id, argument
[all …]
Dcommand.py470 self.gsutil_api = CloudApiDelegator(
575 url_string, self.gsutil_api, all_versions=all_versions,
631 self.logger, self.gsutil_api,
654 gsutil_api = thread_state
656 gsutil_api = self.gsutil_api
660 if (gsutil_api.GetApiSelector(url.scheme) == ApiSelector.XML
664 self._SetAclXmlPassthrough(url, gsutil_api)
667 self._SetAclGsutilApi(url, gsutil_api)
669 def _SetAclXmlPassthrough(self, url, gsutil_api): argument
682 orig_prefer_api = gsutil_api.prefer_api
[all …]
Dwildcard_iterator.py68 def __init__(self, wildcard_url, gsutil_api, all_versions=False, argument
85 self.gsutil_api = gsutil_api
143 for obj_or_prefix in self.gsutil_api.ListObjects(
161 get_object = self.gsutil_api.GetObjectMetadata(
197 for obj_or_prefix in self.gsutil_api.ListObjects(
336 bucket_url, root_object=self.gsutil_api.GetBucket(
346 for bucket in self.gsutil_api.ListBuckets(
633 def CreateWildcardIterator(url_str, gsutil_api, all_versions=False, debug=0, argument
656 url, gsutil_api, all_versions=all_versions, debug=debug,
Dcommand_runner.py145 self, parser, arguments, gsutil_api): argument
159 action.completer = MakeCompleter(command_argument.completer, gsutil_api)
182 gsutil_api = CloudApiDelegator(
196 subcommand_parser, arguments, gsutil_api)
199 command_parser, command.command_spec.argparse_arguments, gsutil_api)
358 gsutil_api = GcsJsonApi(self.bucket_storage_uri_class, logger,
361 cur_ver = LookUpGsutilVersion(gsutil_api, GSUTIL_PUB_TARBALL)
Ddaisy_chain_wrapper.py76 def __init__(self, src_url, src_obj_size, gsutil_api, progress_callback=None, argument
122 self.gsutil_api = gsutil_api
154 self.gsutil_api.GetObjectMedia(
166 self.gsutil_api.GetObjectMedia(
Dname_expansion.py82 def __init__(self, command_name, debug, logger, gsutil_api, url_strs, argument
136 self.gsutil_api = gsutil_api
295 url_string, self.gsutil_api, debug=self.debug,
300 def NameExpansionIterator(command_name, debug, logger, gsutil_api, url_strs, argument
336 command_name, debug, logger, gsutil_api, url_strs, recursion_requested,
Dcat_helper.py72 self.command_obj.gsutil_api.GetObjectMedia(
/external/chromium-trace/catapult/third_party/gsutil/gslib/tests/
Dtest_copy_helper_funcs.py351 gsutil_api = GcsJsonApi(
355 gsutil_api.http.disable_ssl_certificate_validation = True
357 translated_exc = gsutil_api._TranslateApitoolsResumableUploadException(exc)
360 gsutil_api.http.disable_ssl_certificate_validation = False
362 translated_exc = gsutil_api._TranslateApitoolsResumableUploadException(exc)
365 gsutil_api.http.disable_ssl_certificate_validation = False
367 translated_exc = gsutil_api._TranslateApitoolsResumableUploadException(exc)
371 translated_exc = gsutil_api._TranslateApitoolsResumableUploadException(exc)
376 translated_exc = gsutil_api._TranslateApitoolsResumableUploadException(exc)
381 translated_exc = gsutil_api._TranslateApitoolsResumableUploadException(exc)
[all …]
Dtest_cp.py2210 gsutil_api = GcsJsonApi(BucketStorageUri, logging.getLogger(),
2219 gsutil_api.CopyObject(src_obj_metadata, dst_obj_metadata)
2221 gsutil_api.GetObjectMetadata(src_obj_metadata.bucket,
2224 gsutil_api.GetObjectMetadata(dst_obj_metadata.bucket,
2244 gsutil_api = GcsJsonApi(BucketStorageUri, logging.getLogger(),
2260 gsutil_api.CopyObject(
2272 gsutil_api.CopyObject(
2281 gsutil_api.GetObjectMetadata(src_obj_metadata.bucket,
2284 gsutil_api.GetObjectMetadata(dst_obj_metadata.bucket,
2307 gsutil_api = GcsJsonApi(BucketStorageUri, logging.getLogger(),
[all …]
/external/chromium-trace/catapult/third_party/gsutil/gslib/commands/
Dacl.py408 gsutil_api = thread_state
410 gsutil_api = self.gsutil_api
415 bucket = gsutil_api.GetBucket(url.bucket_name, provider=url.scheme,
419 gcs_object = gsutil_api.GetObjectMetadata(
438 gsutil_api.PatchBucket(url.bucket_name, bucket_metadata,
446 gsutil_api.PatchObjectMetadata(
Dcors.py151 self.api = self.gsutil_api.GetApiSelector(
163 self.gsutil_api.XmlPassThroughSetCors(
170 self.gsutil_api.PatchBucket(url.bucket_name, bucket_metadata,
182 sys.stdout.write(self.gsutil_api.XmlPassThroughGetCors(
Drm.py250 self.command_name, self.debug, self.logger, self.gsutil_api,
308 self.logger, self.gsutil_api,
329 self.gsutil_api.DeleteBucket(url.bucket_name, provider=url.scheme)
341 gsutil_api = GetCloudApiInstance(self, thread_state=thread_state)
345 gsutil_api.DeleteObject(
Dsetmeta.py181 self.command_name, self.debug, self.logger, self.gsutil_api,
209 gsutil_api = GetCloudApiInstance(self, thread_state=thread_state)
215 cloud_obj_metadata = gsutil_api.GetObjectMetadata(
232 api = gsutil_api.GetApiSelector(provider=exp_src_url.scheme)
245 gsutil_api.PatchObjectMetadata(
Dlifecycle.py154 self.gsutil_api.XmlPassThroughSetLifecycle(
159 self.gsutil_api.PatchBucket(url.bucket_name, bucket_metadata,
171 sys.stdout.write(self.gsutil_api.XmlPassThroughGetLifecycle(
Drsync.py460 gsutil_api = GetCloudApiInstance(cls, thread_state=thread_state)
466 _BatchSort(_FieldedListingIterator(cls, gsutil_api, base_url_str, desc),
502 def _FieldedListingIterator(cls, gsutil_api, base_url_str, desc): argument
523 wildcard, gsutil_api, debug=cls.debug,
874 gsutil_api = GetCloudApiInstance(cls, thread_state=thread_state)
886 gsutil_api.DeleteObject(
900 copy_helper.PerformCopy(cls.logger, src_url, dst_url, gsutil_api, cls,
971 copy_helper.ExpandUrlToSingleBlr(url_str, self.gsutil_api, self.debug,
Dlogging.py158 sys.stdout.write(self.gsutil_api.XmlPassThroughGetLogging(
203 self.gsutil_api.PatchBucket(url.bucket_name, bucket_metadata,
222 self.gsutil_api.PatchBucket(url.bucket_name, bucket_metadata,
Dcp.py740 gsutil_api = GetCloudApiInstance(self, thread_state=thread_state)
821 self.logger, exp_src_url, dst_url, gsutil_api,
875 gsutil_api.DeleteObject(exp_src_url.bucket_name,
904 copy_helper.ExpandUrlToSingleBlr(self.args[-1], self.gsutil_api,
909 self.logger, self.gsutil_api, url_strs,
Dperfdiag.py281 cls.gsutil_api = GetCloudApiInstance(cls, thread_state)
297 cls.gsutil_api = GetCloudApiInstance(cls, thread_state)
310 cls.gsutil_api = GetCloudApiInstance(cls, thread_state)
325 cls.gsutil_api = GetCloudApiInstance(cls, thread_state)
338 cls.gsutil_api = GetCloudApiInstance(cls, thread_state)
711 self.gsutil_api.UploadObject(
718 return self.gsutil_api.GetObjectMetadata(
728 self.gsutil_api.GetObjectMedia(
735 self.gsutil_api.DeleteObject(url.bucket_name, url.object_name,
869 self.gsutil_api.ComposeObject(request_components, dst_obj_metadata,
[all …]
Dcompose.py157 dst_obj_metadata.contentType = self.gsutil_api.GetObjectMetadata(
165 self.gsutil_api.ComposeObject(components, dst_obj_metadata,
Dweb.py175 sys.stdout.write(self.gsutil_api.XmlPassThroughGetWebsite(
213 self.gsutil_api.PatchBucket(url.bucket_name, bucket_metadata,
Dnotification.py210 channel = self.gsutil_api.WatchBucket(
234 self.gsutil_api.StopChannel(channel_id, resource_id, provider='gs')
Ddefacl.py259 bucket = self.gsutil_api.GetBucket(
285 self.gsutil_api.PatchBucket(url.bucket_name, bucket_metadata,
Drb.py123 self.gsutil_api.DeleteBucket(url.bucket_name, provider=url.scheme)
Dmb.py191 self.gsutil_api.CreateBucket(

12