| /external/chromium-trace/catapult/third_party/gsutil/third_party/boto/boto/file/ |
| connection.py | 32 def get_bucket(self, bucket_name, validate=True, headers=None):
33 return Bucket(bucket_name, self.file_storage_uri.object_name)
|
| /external/chromium-trace/catapult/third_party/gsutil/third_party/boto/boto/sqs/ |
| bigmessage.py | 61 bucket_name = key_name = None
69 bucket_name = s3_components[0]
76 return bucket_name, key_name
86 bucket_name, key_name = self._get_bucket_key(self.s3_url)
87 if bucket_name and key_name:
91 s3_bucket = s3_conn.get_bucket(bucket_name)
94 self.s3_url = 's3://%s/%s' % (bucket_name, key_name)
98 bucket_name, key_name = self._get_bucket_key(s3_url)
99 if bucket_name and key_name:
101 s3_bucket = s3_conn.get_bucket(bucket_name)
[all...] |
| /external/chromium-trace/catapult/third_party/gsutil/gslib/tests/ |
| test_tabcomplete.py | 47 bucket_name = bucket_base_name + '-suffix'
48 self.CreateBucket(bucket_name)
51 expected_result = '//%s/' % bucket_name
60 bucket_name = bucket_base_name + '-s'
61 self.CreateBucket(bucket_name)
64 expected_result = '//%s ' % bucket_name
77 self.default_provider, object_uri.bucket_name, object_base_name)
88 request = '%s://%s/' % (self.default_provider, object_uri.bucket_name)
89 expected_result = '//%s/%s/' % (object_uri.bucket_name, object_base_name)
118 self.default_provider, object_uri.bucket_name, object_base_name
[all...] |
| mock_cloud_api.py | 61 def __init__(self, bucket_name, versioned=False):
63 name=bucket_name,
126 def MockCreateBucket(self, bucket_name):
128 if bucket_name in self.buckets:
129 raise ServiceException('Bucket %s already exists.' % bucket_name,
131 self.buckets[bucket_name] = MockBucket(bucket_name)
133 def MockCreateVersionedBucket(self, bucket_name):
135 if bucket_name in self.buckets:
136 raise ServiceException('Bucket %s already exists.' % bucket_name,
[all...] |
| test_storage_url.py | 49 self.assertEquals('abc', storage_url.bucket_name)
54 self.assertEquals('abc', storage_url.bucket_name)
|
| test_copy_helper_funcs.py | 149 bucket_name = self.MakeTempName('bucket')
162 self.default_provider, bucket_name,
167 apitools_messages.Object(bucket=bucket_name,
181 self.default_provider, bucket_name, fpath_not_uploaded))
193 self.default_provider, bucket_name, fpath_wrong_contents))
197 apitools_messages.Object(bucket=bucket_name,
220 apitools_messages.Object(bucket=bucket_name,
234 bucket_name))
247 self.default_provider, bucket_name, fpath_no_longer_used))
255 bucket_name = self.MakeTempName('bucket'
[all...] |
| test_trace.py | 39 (key_uri.bucket_name, key_uri.object_name))
|
| /external/chromium-trace/catapult/third_party/gsutil/third_party/boto/tests/integration/storage_uri/ |
| test_storage_uri.py | 47 bucket_name = 'keytest-%d' % int(time.time())
48 bucket = conn.create_bucket(bucket_name, location=Location.USWest2)
53 suri = boto.storage_uri('s3://%s/test' % bucket_name)
62 alt_bucket = alt_conn.get_bucket(bucket_name)
|
| /external/chromium-trace/catapult/third_party/gsutil/third_party/boto/tests/integration/cloudtrail/ |
| test_cloudtrail.py | 58 bucket_name = 'cloudtrail-integ-{0}'.format(time())
59 policy = DEFAULT_S3_POLICY.replace('<BucketName>', bucket_name)\
62 b = s3.create_bucket(bucket_name)
66 cloudtrail.create_trail(trail={'Name': 'test', 'S3BucketName': bucket_name})
91 s3.delete_bucket(bucket_name)
|
| /external/chromium-trace/catapult/third_party/gsutil/gslib/commands/ |
| mb.py | 192 bucket_uri.bucket_name, project_id=self.project_id,
197 bucket_name = bucket_uri.bucket_name
198 final_comp = bucket_name[bucket_name.rfind('.')+1:]
203 ' of the top-level DNS tree.' % (bucket_name, final_comp))))
|
| compose.py | 122 bucket=target_url.bucket_name)
136 if src_url.bucket_name != target_url.bucket_name:
158 first_src_url.bucket_name, first_src_url.object_name,
|
| /external/chromium-trace/catapult/third_party/gsutil/third_party/boto/boto/gs/ |
| connection.py | 49 def create_bucket(self, bucket_name, headers=None,
58 :type bucket_name: string
59 :param bucket_name: The name of the new bucket.
75 check_lowercase_bucketname(bucket_name)
94 'PUT', get_utf8_value(bucket_name), headers=headers,
101 return self.bucket_class(self, bucket_name)
106 def get_bucket(self, bucket_name, validate=True, headers=None):
115 :type bucket_name: string
116 :param bucket_name: The name of the bucket
126 bucket = self.bucket_class(self, bucket_name)
[all...] |
| /external/chromium-trace/catapult/third_party/gsutil/gslib/ |
| cloud_api.py | 49 def GetBucket(self, bucket_name, provider=None, fields=None):
53 bucket_name: Name of the bucket.
94 def PatchBucket(self, bucket_name, metadata, canned_acl=None,
100 bucket_name: Name of bucket to update.
118 def CreateBucket(self, bucket_name, project_id=None, metadata=None,
123 bucket_name: Name of the new bucket.
139 def DeleteBucket(self, bucket_name, preconditions=None, provider=None):
143 bucket_name: Name of the bucket to delete.
175 def ListObjects(self, bucket_name, prefix=None, delimiter=None,
180 bucket_name: Bucket containing the objects
[all...] |
| storage_url.py | 121 For File URLs, scheme is always file, bucket_name is always blank,
127 self.bucket_name = ''
180 self.bucket_name = None
190 self.bucket_name = bucket_match.group('bucket')
191 if (not ContainsWildcard(self.bucket_name) and
192 (not BUCKET_NAME_RE.match(self.bucket_name) or
193 TOO_LONG_DNS_NAME_COMP.search(self.bucket_name))):
199 self.bucket_name = object_match.group('bucket')
228 return bool(self.bucket_name and not self.object_name)
231 return bool(self.bucket_name and self.object_name
[all...] |
| cloud_api_delegator.py | 172 def GetBucket(self, bucket_name, provider=None, fields=None):
173 return self._GetApi(provider).GetBucket(bucket_name, fields=fields)
179 def PatchBucket(self, bucket_name, metadata, canned_acl=None,
183 bucket_name, metadata, canned_acl=canned_acl,
187 def CreateBucket(self, bucket_name, project_id=None, metadata=None,
190 bucket_name, project_id=project_id, metadata=metadata, fields=fields)
192 def DeleteBucket(self, bucket_name, preconditions=None, provider=None):
193 return self._GetApi(provider).DeleteBucket(bucket_name,
196 def ListObjects(self, bucket_name, prefix=None, delimiter=None,
199 bucket_name, prefix=prefix, delimiter=delimiter
[all...] |
| boto_translation.py | 184 def GetBucket(self, bucket_name, provider=None, fields=None):
187 bucket_uri = self._StorageUriForBucket(bucket_name)
195 self._TranslateExceptionAndRaise(e, bucket_name=bucket_name)
222 def PatchBucket(self, bucket_name, metadata, canned_acl=None,
227 bucket_uri = self._StorageUriForBucket(bucket_name)
274 return self.GetBucket(bucket_name, fields=fields)
276 self._TranslateExceptionAndRaise(e, bucket_name=bucket_name)
278 def CreateBucket(self, bucket_name, project_id=None, metadata=None
[all...] |
| gcs_json_api.py | 379 def GetBucket(self, bucket_name, provider=None, fields=None):
384 bucket=bucket_name, projection=projection)
396 self._TranslateExceptionAndRaise(e, bucket_name=bucket_name)
398 def PatchBucket(self, bucket_name, metadata, canned_acl=None,
447 bucket=bucket_name, bucketResource=bucket_metadata,
462 def CreateBucket(self, bucket_name, project_id=None, metadata=None,
469 metadata.name = bucket_name
487 self._TranslateExceptionAndRaise(e, bucket_name=bucket_name)
[all...] |
| /external/chromium-trace/catapult/third_party/gsutil/third_party/boto/boto/services/ |
| message.py | 29 def for_key(self, key, params=None, bucket_name=None):
52 if bucket_name:
53 self['Bucket'] = bucket_name
|
| /external/chromium-trace/catapult/third_party/gsutil/third_party/boto/tests/integration/s3/ |
| test_encryption.py | 59 bucket_name = 'encryption-%d' % int(time.time())
60 bucket = c.create_bucket(bucket_name)
63 bucket = c.get_bucket(bucket_name)
|
| test_mfa.py | 42 self.bucket_name = 'mfa-%d' % int(time.time())
43 self.bucket = self.conn.create_bucket(self.bucket_name)
|
| /external/chromium-trace/catapult/third_party/gsutil/third_party/boto/bin/ |
| fetch_file | 30 The URI can be either an HTTP URL, or "s3://bucket_name/key_name"
|
| /external/chromium-trace/catapult/third_party/gsutil/gslib/tests/testcase/ |
| integration_testcase.py | 196 def CreateBucket(self, bucket_name=None, test_objects=0, storage_class=None,
203 bucket_name: Create the bucket with this name. If not provided, a
218 json_bucket = self.CreateBucketJson(bucket_name=bucket_name,
227 bucket_name = bucket_name or self.MakeTempName('bucket')
229 bucket_uri = boto.storage_uri('%s://%s' % (provider, bucket_name.lower()),
254 def CreateVersionedBucket(self, bucket_name=None, test_objects=0):
260 bucket_name: Create the bucket with this name. If not provided, a
268 bucket_uri = self.CreateBucket(bucket_name=bucket_name
[all...] |
| /external/chromium-trace/catapult/third_party/gsutil/third_party/boto/tests/integration/gs/ |
| test_basic.py | 86 bucket_name = bucket.name
88 bucket = self._GetConnection().get_bucket(bucket_name)
341 bucket_name = bucket.name
342 uri = storage_uri('gs://' + bucket_name)
375 bucket_name = bucket.name
377 bucket = self._GetConnection().get_bucket(bucket_name)
390 bucket_name = bucket.name
391 uri = storage_uri('gs://' + bucket_name)
407 bucket_name = bucket.name
409 bucket = self._GetConnection().get_bucket(bucket_name)
[all...] |
| /external/chromium-trace/catapult/third_party/gsutil/third_party/boto/boto/s3/ |
| connection.py | 210 def __contains__(self, bucket_name):
211 return not (self.lookup(bucket_name) is None)
236 def build_post_form_args(self, bucket_name, key, expires_in=6000,
248 :type bucket_name: string
249 :param bucket_name: Bucket to submit to
301 conditions.append('{"bucket": "%s"}' % bucket_name)
349 bucket_name))
464 def get_bucket(self, bucket_name, validate=True, headers=None):
487 bucket = conn.get_bucket('<bucket_name>', validate=False)
490 :type bucket_name: strin
[all...] |
| /external/chromium-trace/catapult/third_party/mapreduce/mapreduce/ |
| shuffler.py | 150 bucket_name = params.get("bucket_name")
153 full_filename = "/%s/%s" % (bucket_name, filename)
172 bucket_name: The name of the Google Cloud Storage bucket.
181 def run(self, job_name, bucket_name, filenames):
184 filenames_only = util.strip_prefix_from_items("/%s/" % bucket_name,
193 "bucket_name": bucket_name,
416 BUCKET_NAME_PARAM = "bucket_name"
477 bucket_name = params.get(cls.BUCKET_NAME_PARAM
[all...] |
