Home
last modified time | relevance | path

Searched refs:storage_url (Results 1 – 25 of 41) sorted by relevance

12

/external/chromium-trace/catapult/third_party/gsutil/gslib/tests/
Dtest_storage_url.py21 from gslib.storage_url import IsFileUrlString
22 from gslib.storage_url import StorageUrlFromString
39 storage_url = StorageUrlFromString('abc')
40 self.assertTrue(storage_url.IsFileUrl())
41 self.assertEquals('abc', storage_url.object_name)
43 storage_url = StorageUrlFromString('file://abc/123')
44 self.assertTrue(storage_url.IsFileUrl())
45 self.assertEquals('abc/123', storage_url.object_name)
47 storage_url = StorageUrlFromString('gs://abc/123')
48 self.assertTrue(storage_url.IsCloudUrl())
[all …]
/external/chromium-trace/catapult/third_party/gsutil/gslib/
Dbucket_listing_ref.py68 def __init__(self, storage_url, root_object=None): argument
77 self._url_string = storage_url.url_string
78 self.storage_url = storage_url
85 def __init__(self, storage_url, root_object=None): argument
94 self._url_string = storage_url.url_string
95 self.storage_url = storage_url
102 def __init__(self, storage_url, root_object=None): argument
111 self._url_string = storage_url.url_string
112 self.storage_url = storage_url
Dcloud_api_delegator.py282 def XmlPassThroughGetAcl(self, storage_url, def_obj_acl=False, provider=None): argument
298 return self._GetApi(provider).XmlPassThroughGetAcl(storage_url,
301 def XmlPassThroughSetAcl(self, acl_text, storage_url, canned=True, argument
321 acl_text, storage_url, canned=canned, def_obj_acl=def_obj_acl)
323 def XmlPassThroughGetCors(self, storage_url, provider=None): argument
338 return self._GetApi(provider).XmlPassThroughGetCors(storage_url)
340 def XmlPassThroughSetCors(self, cors_text, storage_url, provider=None): argument
356 self._GetApi(provider).XmlPassThroughSetCors(cors_text, storage_url)
358 def XmlPassThroughGetLifecycle(self, storage_url, provider=None): argument
373 return self._GetApi(provider).XmlPassThroughGetLifecycle(storage_url)
[all …]
Dname_expansion.py169 storage_url = StorageUrlFromString(url_str)
171 if storage_url.IsFileUrl() and storage_url.IsStream():
175 yield NameExpansionResult(storage_url, False, False, storage_url)
183 if (storage_url.IsCloudUrl() and storage_url.IsBucket()
200 if storage_url.IsCloudUrl() and storage_url.IsBucket():
251 storage_url, is_multi_source_request, src_names_container,
252 blr.storage_url)
280 storage_url, is_multi_source_request, True, blr.storage_url)
Dcat_helper.py70 storage_url = StorageUrlFromString(blr.url_string)
71 if storage_url.IsCloudUrl():
75 object_size=cat_object.size, generation=storage_url.generation,
76 provider=storage_url.scheme)
78 cat_outfd.write(open(storage_url.object_name, 'rb').read())
Dutil.py48 from gslib.storage_url import StorageUrlFromString
715 storage_url = StorageUrlFromString(url_str)
760 generation_str = GenerationFromUrlAndString(storage_url, obj.generation)
899 def GetStreamFromFileUrl(storage_url): argument
900 if storage_url.IsStream():
903 return open(storage_url.object_name, 'rb')
936 storage_url = StorageUrlFromString(url_str)
937 if storage_url.IsFileUrl():
952 storage_url = StorageUrlFromString(url_str)
953 if storage_url.IsCloudUrl() and storage_url.IsProvider():
Daclhelpers.py224 def Execute(self, storage_url, current_acl, command_name, logger): argument
238 'Executing %s %s on %s', command_name, self.raw_descriptor, storage_url)
241 if command_name == 'acl' and storage_url.IsObject():
244 self.raw_descriptor, storage_url)
311 def Execute(self, storage_url, current_acl, command_name, logger): argument
313 'Executing %s %s on %s', command_name, self.raw_descriptor, storage_url)
Dboto_translation.py72 from gslib.storage_url import StorageUrlFromString
1514 def XmlPassThroughGetAcl(self, storage_url, def_obj_acl=False): argument
1518 storage_url.url_string, suppress_consec_slashes=False,
1528 def XmlPassThroughSetAcl(self, acl_text, storage_url, canned=True, argument
1533 storage_url.url_string, suppress_consec_slashes=False,
1556 def XmlPassThroughSetCors(self, cors_text, storage_url): argument
1559 if storage_url.scheme == 's3':
1573 storage_url.url_string, suppress_consec_slashes=False,
1580 def XmlPassThroughGetCors(self, storage_url): argument
1583 storage_url.url_string, suppress_consec_slashes=False,
[all …]
Dtab_complete.py25 from gslib.storage_url import IsFileUrlString
26 from gslib.storage_url import StorageUrlFromString
27 from gslib.storage_url import StripOneSlash
Dwildcard_iterator.py33 from gslib.storage_url import ContainsWildcard
34 from gslib.storage_url import StorageUrlFromString
35 from gslib.storage_url import StripOneSlash
36 from gslib.storage_url import WILDCARD_REGEX
Dcopy_helper.py82 from gslib.storage_url import ContainsWildcard
83 from gslib.storage_url import StorageUrlFromString
1125 storage_url = StorageUrlFromString(url_str)
1128 if storage_url.IsFileUrl():
1129 return (storage_url, storage_url.IsDirectory())
1132 if storage_url.IsBucket():
1133 return (storage_url, True)
1142 if IsCloudSubdirPlaceholder(storage_url):
1143 return (storage_url, True)
1149 storage_url.bucket_name, prefix=storage_url.object_name, delimiter='/',
[all …]
/external/chromium-trace/catapult/third_party/gsutil/gslib/commands/
Dls.py28 from gslib.storage_url import ContainsWildcard
29 from gslib.storage_url import StorageUrlFromString
308 if bucket_blr.storage_url.scheme == 's3':
393 storage_url = StorageUrlFromString(url_str)
394 if storage_url.IsFileUrl():
405 if storage_url.IsProvider():
408 '%s://*' % storage_url.scheme).IterBuckets(
411 elif storage_url.IsBucket() and get_bucket_info:
421 blr.storage_url.bucket_name,
422 fields=['id'], provider=storage_url.scheme)
[all …]
Ddu.py28 from gslib.storage_url import ContainsWildcard
29 from gslib.storage_url import StorageUrlFromString
265 storage_url = blr.storage_url
266 if storage_url.IsBucket() and self.summary_only:
267 storage_url = StorageUrlFromString(
268 storage_url.CreatePrefixUrl(wildcard_suffix='**'))
269 _, exp_objs, exp_bytes = ls_helper.ExpandUrlAndPrint(storage_url)
270 if (storage_url.IsObject() and exp_objs == 0 and
Ddefacl.py31 from gslib.storage_url import StorageUrlFromString
248 if not result.storage_url.IsBucket():
251 bucket_urls.add(result.storage_url)
253 for storage_url in bucket_urls:
254 self.ApplyAclChanges(storage_url)
Dupdate.py315 storage_url = result.storage_url
316 if storage_url.IsFileUrl() and not storage_url.IsDirectory():
321 elif not (storage_url.IsCloudUrl() and storage_url.IsObject()):
Dcompose.py24 from gslib.storage_url import ContainsWildcard
25 from gslib.storage_url import StorageUrlFromString
133 src_url = blr.storage_url
Dlogging.py28 from gslib.storage_url import StorageUrlFromString
195 url = blr.storage_url
216 url = blr.storage_url
Drb.py24 from gslib.storage_url import StorageUrlFromString
120 url = blr.storage_url
Dstat.py30 from gslib.storage_url import ContainsWildcard
31 from gslib.storage_url import StorageUrlFromString
Dsignurl.py39 from gslib.storage_url import ContainsWildcard
40 from gslib.storage_url import StorageUrlFromString
275 ret.extend([blr.storage_url for blr in self.WildcardIterator(url_str)])
Dhash.py32 from gslib.storage_url import StorageUrlFromString
168 file_name = file_ref.storage_url.object_name
Dcors.py26 from gslib.storage_url import StorageUrlFromString
159 url = blr.storage_url
Drm.py30 from gslib.storage_url import StorageUrlFromString
242 bucket_urls_to_delete.append(blr.storage_url)
Dmv.py24 from gslib.storage_url import StorageUrlFromString
Dmb.py26 from gslib.storage_url import StorageUrlFromString

12