| /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_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_storage_url.py | 49 self.assertEquals('abc', storage_url.bucket_name)
54 self.assertEquals('abc', storage_url.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/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/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/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/mapreduce/mapreduce/ |
| mapreduce_pipeline.py | 84 # Although we are using all the default settings (and inherited bucket_name)
109 bucket_name: The name of the Google Cloud Storage bucket.
131 bucket_name,
136 util.strip_prefix_from_items("/%s/" % bucket_name, filenames))
140 "bucket_name": bucket_name,
204 # Check that you have a bucket_name set in the mapper_params and set it
206 if mapper_params.get("bucket_name") is None:
208 mapper_params["bucket_name"] = (
214 if mapper_params["bucket_name"] is None
[all...] |
| 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...] |
| /external/chromium-trace/catapult/third_party/gsutil/gslib/ |
| 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...] |
| 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...] |
| 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...] |
| 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...] |
| 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...] |
| /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/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/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/boto/services/ |
| message.py | 29 def for_key(self, key, params=None, bucket_name=None):
52 if bucket_name:
53 self['Bucket'] = bucket_name
|
| service.py | 71 bucket_name = message['Bucket']
74 boto.log.info('get_file: %s/%s to %s' % (bucket_name, key_name, file_name))
75 bucket = boto.lookup('s3', bucket_name)
85 def put_file(self, bucket_name, file_path, key_name=None):
86 boto.log.info('putting file %s as %s.%s' % (file_path, bucket_name, key_name))
87 bucket = boto.lookup('s3', bucket_name)
|
| /external/chromium-trace/catapult/third_party/gsutil/third_party/boto/tests/unit/s3/ |
| test_uri.py | 40 self.assertEqual('', uri.bucket_name)
61 self.assertEqual('bucket', uri.bucket_name)
82 self.assertEqual('bucket', uri.bucket_name)
103 self.assertEqual('bucket', uri.bucket_name)
123 self.assertEqual('bucket', uri.bucket_name)
143 self.assertEqual('bucket', uri.bucket_name)
172 self.assertEqual('bucket', uri.bucket_name)
193 self.assertEqual('', uri.bucket_name)
214 self.assertEqual('', uri.bucket_name)
235 self.assertEqual('bucket', uri.bucket_name)
[all...] |
| /external/chromium-trace/catapult/third_party/gsutil/third_party/boto/tests/integration/s3/ |
| mock_storage_service.py | 375 def create_bucket(self, bucket_name, headers=NOT_IMPL, location=NOT_IMPL,
377 if bucket_name in self.buckets:
382 mock_bucket = MockBucket(name=bucket_name, connection=self)
383 self.buckets[bucket_name] = mock_bucket
392 def get_bucket(self, bucket_name, validate=NOT_IMPL, headers=NOT_IMPL):
393 if bucket_name not in self.buckets:
396 return self.buckets[bucket_name]
410 def __init__(self, scheme, bucket_name=None, object_name=None,
414 self.bucket_name = bucket_name
[all...] |
| 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)
|
| /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/libchrome/base/trace_event/ |
| trace_sampling_thread.cc | 22 const char* bucket_name; member in class:base::trace_event::TraceBucketData
98 : bucket(bucket), bucket_name(name), callback(callback) {}
|
