725e2543ef
* Add object-store API to ClientManager
* Add object-store client
* Add Object API library in openstackclient.object.v1.lib
* Add Object API {container,object} list commands
* Add library tests
* Add command tests
This should complete the Object v1 container and object list commands
Change-Id: Ib1770d45efa8871959826b85faafa1e0bcef0a03
78 lines
2.1 KiB
Python
78 lines
2.1 KiB
Python
# Copyright 2010-2012 OpenStack Foundation
|
|
# Copyright 2013 Nebula Inc.
|
|
#
|
|
# Licensed under the Apache License, Version 2.0 (the "License"); you may
|
|
# not use this file except in compliance with the License. You may obtain
|
|
# a copy of the License at
|
|
#
|
|
# http://www.apache.org/licenses/LICENSE-2.0
|
|
#
|
|
# Unless required by applicable law or agreed to in writing, software
|
|
# distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
|
|
# WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
|
|
# License for the specific language governing permissions and limitations
|
|
# under the License.
|
|
#
|
|
|
|
"""Object v1 API library"""
|
|
|
|
|
|
def list_containers(
|
|
api,
|
|
url,
|
|
marker=None,
|
|
limit=None,
|
|
end_marker=None,
|
|
prefix=None,
|
|
full_listing=False,
|
|
):
|
|
"""Get containers in an account
|
|
|
|
:param api: a restapi object
|
|
:param url: endpoint
|
|
:param marker: marker query
|
|
:param limit: limit query
|
|
:param end_marker: end_marker query
|
|
:param prefix: prefix query
|
|
:param full_listing: if True, return a full listing, else returns a max
|
|
of 10000 listings
|
|
:returns: list of containers
|
|
"""
|
|
|
|
if full_listing:
|
|
data = listing = list_containers(
|
|
api,
|
|
url,
|
|
marker,
|
|
limit,
|
|
end_marker,
|
|
prefix,
|
|
)
|
|
while listing:
|
|
marker = listing[-1]['name']
|
|
listing = list_containers(
|
|
api,
|
|
url,
|
|
marker,
|
|
limit,
|
|
end_marker,
|
|
prefix,
|
|
)
|
|
if listing:
|
|
data.extend(listing)
|
|
return data
|
|
|
|
object_url = url
|
|
query = "format=json"
|
|
if marker:
|
|
query += '&marker=%s' % marker
|
|
if limit:
|
|
query += '&limit=%d' % limit
|
|
if end_marker:
|
|
query += '&end_marker=%s' % end_marker
|
|
if prefix:
|
|
query += '&prefix=%s' % prefix
|
|
url = "%s?%s" % (object_url, query)
|
|
response = api.request('GET', url)
|
|
return response.json()
|