| /external/chromium-trace/catapult/third_party/gsutil/gslib/tests/ |
| test_storage_url.py | 21 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/ |
| bucket_listing_ref.py | 68 def __init__(self, storage_url, root_object=None):
72 storage_url: StorageUrl containing a bucket.
77 self._url_string = storage_url.url_string
78 self.storage_url = storage_url
85 def __init__(self, storage_url, root_object=None):
89 storage_url: StorageUrl containing a prefix.
94 self._url_string = storage_url.url_string
95 self.storage_url = storage_url
[all...] |
| cat_helper.py | 70 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())
|
| name_expansion.py | 169 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
[all...] |
| cloud_api_delegator.py | 282 def XmlPassThroughGetAcl(self, storage_url, def_obj_acl=False, provider=None):
286 storage_url: StorageUrl object.
296 ACL XML for the resource specified by storage_url.
298 return self._GetApi(provider).XmlPassThroughGetAcl(storage_url,
301 def XmlPassThroughSetAcl(self, acl_text, storage_url, canned=True,
307 storage_url: StorageUrl object.
321 acl_text, storage_url, canned=canned, def_obj_acl=def_obj_acl)
323 def XmlPassThroughGetCors(self, storage_url, provider=None):
327 storage_url: StorageUrl object.
336 CORS configuration XML for the bucket specified by storage_url
[all...] |
| aclhelpers.py | 224 def Execute(self, storage_url, current_acl, command_name, logger):
228 storage_url: StorageUrl representing the object to change.
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):
313 'Executing %s %s on %s', command_name, self.raw_descriptor, storage_url)
|
| boto_translation.py | 72 from gslib.storage_url import StorageUrlFromString
[all...] |
| util.py | 48 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):
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()
[all...] |
| tab_complete.py | 25 from gslib.storage_url import IsFileUrlString
26 from gslib.storage_url import StorageUrlFromString
27 from gslib.storage_url import StripOneSlash
|
| wildcard_iterator.py | 33 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
|
| copy_helper.py | 82 from gslib.storage_url import ContainsWildcard
83 from gslib.storage_url import StorageUrlFromString
[all...] |
| /external/chromium-trace/catapult/third_party/gsutil/gslib/commands/ |
| ls.py | 28 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...] |
| du.py | 28 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
|
| defacl.py | 31 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)
|
| compose.py | 24 from gslib.storage_url import ContainsWildcard
25 from gslib.storage_url import StorageUrlFromString
133 src_url = blr.storage_url
|
| rb.py | 24 from gslib.storage_url import StorageUrlFromString
120 url = blr.storage_url
|
| stat.py | 30 from gslib.storage_url import ContainsWildcard
31 from gslib.storage_url import StorageUrlFromString
|
| mv.py | 24 from gslib.storage_url import StorageUrlFromString
|
| cors.py | 26 from gslib.storage_url import StorageUrlFromString
159 url = blr.storage_url
|
| hash.py | 32 from gslib.storage_url import StorageUrlFromString
168 file_name = file_ref.storage_url.object_name
|
| logging.py | 28 from gslib.storage_url import StorageUrlFromString
195 url = blr.storage_url
216 url = blr.storage_url
|
| signurl.py | 39 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)])
|
| mb.py | 26 from gslib.storage_url import StorageUrlFromString
|
| rm.py | 30 from gslib.storage_url import StorageUrlFromString
242 bucket_urls_to_delete.append(blr.storage_url)
|
| lifecycle.py | 150 url = blr.storage_url
|
