f3df2095ac
Start using common QuotaSet class in the block storage service. Change-Id: I741c74e596571dae6d28e305b89aafa4b51f4f3c
627 lines
26 KiB
Python
627 lines
26 KiB
Python
# 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.
|
|
|
|
from openstack.block_storage import _base_proxy
|
|
from openstack.block_storage.v2 import backup as _backup
|
|
from openstack.block_storage.v2 import quota_set as _quota_set
|
|
from openstack.block_storage.v2 import snapshot as _snapshot
|
|
from openstack.block_storage.v2 import stats as _stats
|
|
from openstack.block_storage.v2 import type as _type
|
|
from openstack.block_storage.v2 import volume as _volume
|
|
from openstack.identity.v3 import project as _project
|
|
from openstack import resource
|
|
|
|
|
|
class Proxy(_base_proxy.BaseBlockStorageProxy):
|
|
|
|
# ====== SNAPSHOTS ======
|
|
def get_snapshot(self, snapshot):
|
|
"""Get a single snapshot
|
|
|
|
:param snapshot: The value can be the ID of a snapshot or a
|
|
:class:`~openstack.block_storage.v2.snapshot.Snapshot`
|
|
instance.
|
|
|
|
:returns: One :class:`~openstack.block_storage.v2.snapshot.Snapshot`
|
|
:raises: :class:`~openstack.exceptions.ResourceNotFound`
|
|
when no resource can be found.
|
|
"""
|
|
return self._get(_snapshot.Snapshot, snapshot)
|
|
|
|
def snapshots(self, details=True, **query):
|
|
"""Retrieve a generator of snapshots
|
|
|
|
:param bool details: When set to ``False``
|
|
:class:`~openstack.block_storage.v2.snapshot.Snapshot`
|
|
objects will be returned. The default, ``True``, will cause
|
|
:class:`~openstack.block_storage.v2.snapshot.SnapshotDetail`
|
|
objects to be returned.
|
|
:param kwargs query: Optional query parameters to be sent to limit
|
|
the snapshots being returned. Available parameters include:
|
|
|
|
* name: Name of the snapshot as a string.
|
|
* all_projects: Whether return the snapshots in all projects.
|
|
* volume_id: volume id of a snapshot.
|
|
* status: Value of the status of the snapshot so that you can
|
|
filter on "available" for example.
|
|
|
|
:returns: A generator of snapshot objects.
|
|
"""
|
|
base_path = '/snapshots/detail' if details else None
|
|
return self._list(_snapshot.Snapshot, base_path=base_path, **query)
|
|
|
|
def create_snapshot(self, **attrs):
|
|
"""Create a new snapshot from attributes
|
|
|
|
:param dict attrs: Keyword arguments which will be used to create
|
|
a :class:`~openstack.block_storage.v2.snapshot.Snapshot`,
|
|
comprised of the properties on the Snapshot class.
|
|
|
|
:returns: The results of snapshot creation
|
|
:rtype: :class:`~openstack.block_storage.v2.snapshot.Snapshot`
|
|
"""
|
|
return self._create(_snapshot.Snapshot, **attrs)
|
|
|
|
def delete_snapshot(self, snapshot, ignore_missing=True):
|
|
"""Delete a snapshot
|
|
|
|
:param snapshot: The value can be either the ID of a snapshot or a
|
|
:class:`~openstack.block_storage.v2.snapshot.Snapshot`
|
|
instance.
|
|
:param bool ignore_missing: When set to ``False``
|
|
:class:`~openstack.exceptions.ResourceNotFound` will be
|
|
raised when the snapshot does not exist.
|
|
When set to ``True``, no exception will be set when
|
|
attempting to delete a nonexistent snapshot.
|
|
|
|
:returns: ``None``
|
|
"""
|
|
self._delete(_snapshot.Snapshot, snapshot,
|
|
ignore_missing=ignore_missing)
|
|
|
|
# ====== SNAPSHOT ACTIONS ======
|
|
def reset_snapshot(self, snapshot, status):
|
|
"""Reset status of the snapshot
|
|
|
|
:param snapshot: The value can be either the ID of a backup or a
|
|
:class:`~openstack.block_storage.v2.snapshot.Snapshot` instance.
|
|
:param str status: New snapshot status
|
|
|
|
:returns: None
|
|
"""
|
|
snapshot = self._get_resource(_snapshot.Snapshot, snapshot)
|
|
snapshot.reset(self, status)
|
|
|
|
# ====== TYPES ======
|
|
def get_type(self, type):
|
|
"""Get a single type
|
|
|
|
:param type: The value can be the ID of a type or a
|
|
:class:`~openstack.block_storage.v2.type.Type` instance.
|
|
|
|
:returns: One :class:`~openstack.block_storage.v2.type.Type`
|
|
:raises: :class:`~openstack.exceptions.ResourceNotFound`
|
|
when no resource can be found.
|
|
"""
|
|
return self._get(_type.Type, type)
|
|
|
|
def types(self, **query):
|
|
"""Retrieve a generator of volume types
|
|
|
|
:returns: A generator of volume type objects.
|
|
"""
|
|
return self._list(_type.Type, **query)
|
|
|
|
def create_type(self, **attrs):
|
|
"""Create a new type from attributes
|
|
|
|
:param dict attrs: Keyword arguments which will be used to create
|
|
a :class:`~openstack.block_storage.v2.type.Type`,
|
|
comprised of the properties on the Type class.
|
|
|
|
:returns: The results of type creation
|
|
:rtype: :class:`~openstack.block_storage.v2.type.Type`
|
|
"""
|
|
return self._create(_type.Type, **attrs)
|
|
|
|
def delete_type(self, type, ignore_missing=True):
|
|
"""Delete a type
|
|
|
|
:param type: The value can be either the ID of a type or a
|
|
:class:`~openstack.block_storage.v2.type.Type` instance.
|
|
:param bool ignore_missing: When set to ``False``
|
|
:class:`~openstack.exceptions.ResourceNotFound` will be
|
|
raised when the type does not exist.
|
|
When set to ``True``, no exception will be set when
|
|
attempting to delete a nonexistent type.
|
|
|
|
:returns: ``None``
|
|
"""
|
|
self._delete(_type.Type, type, ignore_missing=ignore_missing)
|
|
|
|
def get_type_access(self, type):
|
|
"""Lists project IDs that have access to private volume type.
|
|
|
|
:param type: The value can be either the ID of a type or a
|
|
:class:`~openstack.block_storage.v2.type.Type` instance.
|
|
|
|
:returns: List of dictionaries describing projects that have access to
|
|
the specified type
|
|
"""
|
|
res = self._get_resource(_type.Type, type)
|
|
return res.get_private_access(self)
|
|
|
|
def add_type_access(self, type, project_id):
|
|
"""Adds private volume type access to a project.
|
|
|
|
:param type: The value can be either the ID of a type or a
|
|
:class:`~openstack.block_storage.v2.type.Type` instance.
|
|
:param str project_id: The ID of the project. Volume Type access to
|
|
be added to this project ID.
|
|
|
|
:returns: ``None``
|
|
"""
|
|
res = self._get_resource(_type.Type, type)
|
|
return res.add_private_access(self, project_id)
|
|
|
|
def remove_type_access(self, type, project_id):
|
|
"""Remove private volume type access from a project.
|
|
|
|
:param type: The value can be either the ID of a type or a
|
|
:class:`~openstack.block_storage.v2.type.Type` instance.
|
|
:param str project_id: The ID of the project. Volume Type access to
|
|
be removed to this project ID.
|
|
|
|
:returns: ``None``
|
|
"""
|
|
res = self._get_resource(_type.Type, type)
|
|
return res.remove_private_access(self, project_id)
|
|
|
|
# ====== VOLUMES ======
|
|
def get_volume(self, volume):
|
|
"""Get a single volume
|
|
|
|
:param volume: The value can be the ID of a volume or a
|
|
:class:`~openstack.block_storage.v2.volume.Volume` instance.
|
|
|
|
:returns: One :class:`~openstack.block_storage.v2.volume.Volume`
|
|
:raises: :class:`~openstack.exceptions.ResourceNotFound`
|
|
when no resource can be found.
|
|
"""
|
|
return self._get(_volume.Volume, volume)
|
|
|
|
def find_volume(self, name_or_id, ignore_missing=True, **attrs):
|
|
"""Find a single volume
|
|
|
|
:param snapshot: The name or ID a volume
|
|
:param bool ignore_missing: When set to ``False``
|
|
:class:`~openstack.exceptions.ResourceNotFound` will be raised
|
|
when the volume does not exist.
|
|
|
|
:returns: One :class:`~openstack.block_storage.v2.volume.Volume`
|
|
:raises: :class:`~openstack.exceptions.ResourceNotFound`
|
|
when no resource can be found.
|
|
"""
|
|
return self._find(_volume.Volume, name_or_id,
|
|
ignore_missing=ignore_missing)
|
|
|
|
def volumes(self, details=True, **query):
|
|
"""Retrieve a generator of volumes
|
|
|
|
:param bool details: When set to ``False`` no extended attributes
|
|
will be returned. The default, ``True``, will cause objects with
|
|
additional attributes to be returned.
|
|
:param kwargs query: Optional query parameters to be sent to limit
|
|
the volumes being returned. Available parameters include:
|
|
|
|
* name: Name of the volume as a string.
|
|
* all_projects: Whether return the volumes in all projects
|
|
* status: Value of the status of the volume so that you can filter
|
|
on "available" for example.
|
|
|
|
:returns: A generator of volume objects.
|
|
"""
|
|
base_path = '/volumes/detail' if details else None
|
|
return self._list(_volume.Volume, base_path=base_path, **query)
|
|
|
|
def create_volume(self, **attrs):
|
|
"""Create a new volume from attributes
|
|
|
|
:param dict attrs: Keyword arguments which will be used to create
|
|
a :class:`~openstack.block_storage.v2.volume.Volume`,
|
|
comprised of the properties on the Volume class.
|
|
|
|
:returns: The results of volume creation
|
|
:rtype: :class:`~openstack.block_storage.v2.volume.Volume`
|
|
"""
|
|
return self._create(_volume.Volume, **attrs)
|
|
|
|
def delete_volume(self, volume, ignore_missing=True, force=False):
|
|
"""Delete a volume
|
|
|
|
:param volume: The value can be either the ID of a volume or a
|
|
:class:`~openstack.block_storage.v2.volume.Volume` instance.
|
|
:param bool ignore_missing: When set to ``False``
|
|
:class:`~openstack.exceptions.ResourceNotFound` will be raised
|
|
when the volume does not exist. When set to ``True``, no
|
|
exception will be set when attempting to delete a nonexistent
|
|
volume.
|
|
:param bool force: Whether to try forcing volume deletion.
|
|
|
|
:returns: ``None``
|
|
"""
|
|
if not force:
|
|
self._delete(_volume.Volume, volume, ignore_missing=ignore_missing)
|
|
else:
|
|
volume = self._get_resource(_volume.Volume, volume)
|
|
volume.force_delete(self)
|
|
|
|
# ====== VOLUME ACTIONS ======
|
|
def extend_volume(self, volume, size):
|
|
"""Extend a volume
|
|
|
|
:param volume: The value can be either the ID of a volume or a
|
|
:class:`~openstack.block_storage.v2.volume.Volume` instance.
|
|
:param size: New volume size
|
|
|
|
:returns: None
|
|
"""
|
|
volume = self._get_resource(_volume.Volume, volume)
|
|
volume.extend(self, size)
|
|
|
|
def retype_volume(self, volume, new_type, migration_policy="never"):
|
|
"""Retype the volume.
|
|
|
|
:param volume: The value can be either the ID of a volume or a
|
|
:class:`~openstack.block_storage.v2.volume.Volume` instance.
|
|
:param str new_type: The new volume type that volume is changed with.
|
|
:param str migration_policy: Specify if the volume should be migrated
|
|
when it is re-typed. Possible values are on-demand or never.
|
|
Default: never.
|
|
|
|
:returns: None
|
|
"""
|
|
volume = self._get_resource(_volume.Volume, volume)
|
|
volume.retype(self, new_type, migration_policy)
|
|
|
|
def set_volume_bootable_status(self, volume, bootable):
|
|
"""Set bootable status of the volume.
|
|
|
|
:param volume: The value can be either the ID of a volume or a
|
|
:class:`~openstack.block_storage.v2.volume.Volume` instance.
|
|
:param bool bootable: Specifies whether the volume should be bootable
|
|
or not.
|
|
|
|
:returns: None
|
|
"""
|
|
volume = self._get_resource(_volume.Volume, volume)
|
|
volume.set_bootable_status(self, bootable)
|
|
|
|
def reset_volume_status(
|
|
self, volume, status, attach_status, migration_status
|
|
):
|
|
"""Reset volume statuses.
|
|
|
|
:param volume: The value can be either the ID of a volume or a
|
|
:class:`~openstack.block_storage.v2.volume.Volume` instance.
|
|
:param str status: The new volume status.
|
|
:param str attach_status: The new volume attach status.
|
|
:param str migration_status: The new volume migration status (admin
|
|
only).
|
|
|
|
:returns: None
|
|
"""
|
|
volume = self._get_resource(_volume.Volume, volume)
|
|
volume.reset_status(self, status, attach_status, migration_status)
|
|
|
|
def attach_volume(
|
|
self, volume, mountpoint, instance=None, host_name=None
|
|
):
|
|
"""Attaches a volume to a server.
|
|
|
|
:param volume: The value can be either the ID of a volume or a
|
|
:class:`~openstack.block_storage.v2.volume.Volume` instance.
|
|
:param str mountpoint: The attaching mount point.
|
|
:param str instance: The UUID of the attaching instance.
|
|
:param str host_name: The name of the attaching host.
|
|
|
|
:returns: None
|
|
"""
|
|
volume = self._get_resource(_volume.Volume, volume)
|
|
volume.attach(self, mountpoint, instance, host_name)
|
|
|
|
def detach_volume(
|
|
self, volume, attachment, force=False, connector=None
|
|
):
|
|
"""Detaches a volume from a server.
|
|
|
|
:param volume: The value can be either the ID of a volume or a
|
|
:class:`~openstack.block_storage.v2.volume.Volume` instance.
|
|
:param str attachment: The ID of the attachment.
|
|
:param bool force: Whether to force volume detach (Rolls back an
|
|
unsuccessful detach operation after you disconnect the volume.)
|
|
:param dict connector: The connector object.
|
|
|
|
:returns: None
|
|
"""
|
|
volume = self._get_resource(_volume.Volume, volume)
|
|
volume.detach(self, attachment, force, connector)
|
|
|
|
def unmanage_volume(self, volume):
|
|
"""Removes a volume from Block Storage management without removing the
|
|
back-end storage object that is associated with it.
|
|
|
|
:param volume: The value can be either the ID of a volume or a
|
|
:class:`~openstack.block_storage.v2.volume.Volume` instance.
|
|
|
|
:returns: None """
|
|
volume = self._get_resource(_volume.Volume, volume)
|
|
volume.unmanage(self)
|
|
|
|
def migrate_volume(
|
|
self, volume, host=None, force_host_copy=False,
|
|
lock_volume=False
|
|
):
|
|
"""Migrates a volume to the specified host.
|
|
|
|
:param volume: The value can be either the ID of a volume or a
|
|
:class:`~openstack.block_storage.v2.volume.Volume` instance.
|
|
:param str host: The target host for the volume migration. Host
|
|
format is host@backend.
|
|
:param bool force_host_copy: If false (the default), rely on the volume
|
|
backend driver to perform the migration, which might be optimized.
|
|
If true, or the volume driver fails to migrate the volume itself,
|
|
a generic host-based migration is performed.
|
|
:param bool lock_volume: If true, migrating an available volume will
|
|
change its status to maintenance preventing other operations from
|
|
being performed on the volume such as attach, detach, retype, etc.
|
|
|
|
:returns: None
|
|
"""
|
|
volume = self._get_resource(_volume.Volume, volume)
|
|
volume.migrate(self, host, force_host_copy, lock_volume)
|
|
|
|
def complete_volume_migration(
|
|
self, volume, new_volume, error=False
|
|
):
|
|
"""Complete the migration of a volume.
|
|
|
|
:param volume: The value can be either the ID of a volume or a
|
|
:class:`~openstack.block_storage.v2.volume.Volume` instance.
|
|
:param str new_volume: The UUID of the new volume.
|
|
:param bool error: Used to indicate if an error has occured elsewhere
|
|
that requires clean up.
|
|
|
|
:returns: None
|
|
"""
|
|
volume = self._get_resource(_volume.Volume, volume)
|
|
volume.complete_migration(self, new_volume, error)
|
|
|
|
# ====== BACKEND POOLS ======
|
|
|
|
def backend_pools(self, **query):
|
|
"""Returns a generator of cinder Back-end storage pools
|
|
|
|
:param kwargs query: Optional query parameters to be sent to limit
|
|
the resources being returned.
|
|
|
|
:returns A generator of cinder Back-end storage pools objects
|
|
"""
|
|
return self._list(_stats.Pools, **query)
|
|
|
|
# ====== BACKUPS ======
|
|
def backups(self, details=True, **query):
|
|
"""Retrieve a generator of backups
|
|
|
|
:param bool details: When set to ``False`` no additional details will
|
|
be returned. The default, ``True``, will cause objects with
|
|
additional attributes to be returned.
|
|
:param dict query: Optional query parameters to be sent to limit the
|
|
resources being returned:
|
|
|
|
* offset: pagination marker
|
|
* limit: pagination limit
|
|
* sort_key: Sorts by an attribute. A valid value is
|
|
name, status, container_format, disk_format, size, id,
|
|
created_at, or updated_at. Default is created_at.
|
|
The API uses the natural sorting direction of the
|
|
sort_key attribute value.
|
|
* sort_dir: Sorts by one or more sets of attribute and sort
|
|
direction combinations. If you omit the sort direction
|
|
in a set, default is desc.
|
|
|
|
:returns: A generator of backup objects.
|
|
"""
|
|
base_path = '/backups/detail' if details else None
|
|
return self._list(_backup.Backup, base_path=base_path, **query)
|
|
|
|
def get_backup(self, backup):
|
|
"""Get a backup
|
|
|
|
:param backup: The value can be the ID of a backup
|
|
or a :class:`~openstack.block_storage.v2.backup.Backup`
|
|
instance.
|
|
|
|
:returns: Backup instance
|
|
:rtype: :class:`~openstack.block_storage.v2.backup.Backup`
|
|
"""
|
|
return self._get(_backup.Backup, backup)
|
|
|
|
def create_backup(self, **attrs):
|
|
"""Create a new Backup from attributes with native API
|
|
|
|
:param dict attrs: Keyword arguments which will be used to create
|
|
a :class:`~openstack.block_storage.v2.backup.Backup`
|
|
comprised of the properties on the Backup class.
|
|
|
|
:returns: The results of Backup creation
|
|
:rtype: :class:`~openstack.block_storage.v2.backup.Backup`
|
|
"""
|
|
return self._create(_backup.Backup, **attrs)
|
|
|
|
def delete_backup(self, backup, ignore_missing=True, force=False):
|
|
"""Delete a CloudBackup
|
|
|
|
:param backup: The value can be the ID of a backup or a
|
|
:class:`~openstack.block_storage.v2.backup.Backup` instance
|
|
:param bool ignore_missing: When set to ``False``
|
|
:class:`~openstack.exceptions.ResourceNotFound` will be raised when
|
|
the zone does not exist.
|
|
When set to ``True``, no exception will be set when attempting to
|
|
delete a nonexistent zone.
|
|
:param bool force: Whether to try forcing backup deletion
|
|
|
|
:returns: ``None``
|
|
"""
|
|
if not force:
|
|
self._delete(
|
|
_backup.Backup, backup, ignore_missing=ignore_missing)
|
|
else:
|
|
backup = self._get_resource(_backup.Backup, backup)
|
|
backup.force_delete(self)
|
|
|
|
# ====== BACKUP ACTIONS ======
|
|
def restore_backup(self, backup, volume_id, name):
|
|
"""Restore a Backup to volume
|
|
|
|
:param backup: The value can be the ID of a backup or a
|
|
:class:`~openstack.block_storage.v2.backup.Backup` instance
|
|
:param volume_id: The ID of the volume to restore the backup to.
|
|
:param name: The name for new volume creation to restore.
|
|
|
|
:returns: Updated backup instance
|
|
:rtype: :class:`~openstack.block_storage.v2.backup.Backup`
|
|
"""
|
|
backup = self._get_resource(_backup.Backup, backup)
|
|
return backup.restore(self, volume_id=volume_id, name=name)
|
|
|
|
def reset_backup(self, backup, status):
|
|
"""Reset status of the backup
|
|
|
|
:param backup: The value can be either the ID of a backup or a
|
|
:class:`~openstack.block_storage.v3.backup.Backup` instance.
|
|
:param str status: New backup status
|
|
|
|
:returns: None
|
|
"""
|
|
backup = self._get_resource(_backup.Backup, backup)
|
|
backup.reset(self, status)
|
|
|
|
def wait_for_status(self, res, status='available', failures=None,
|
|
interval=2, wait=120):
|
|
"""Wait for a resource to be in a particular status.
|
|
|
|
:param res: The resource to wait on to reach the specified status.
|
|
The resource must have a ``status`` attribute.
|
|
:type resource: A :class:`~openstack.resource.Resource` object.
|
|
:param status: Desired status.
|
|
:param failures: Statuses that would be interpreted as failures.
|
|
:type failures: :py:class:`list`
|
|
:param interval: Number of seconds to wait before to consecutive
|
|
checks. Default to 2.
|
|
:param wait: Maximum number of seconds to wait before the change.
|
|
Default to 120.
|
|
:returns: The resource is returned on success.
|
|
:raises: :class:`~openstack.exceptions.ResourceTimeout` if transition
|
|
to the desired status failed to occur in specified seconds.
|
|
:raises: :class:`~openstack.exceptions.ResourceFailure` if the resource
|
|
has transited to one of the failure statuses.
|
|
:raises: :class:`~AttributeError` if the resource does not have a
|
|
``status`` attribute.
|
|
"""
|
|
failures = ['error'] if failures is None else failures
|
|
return resource.wait_for_status(
|
|
self, res, status, failures, interval, wait)
|
|
|
|
def wait_for_delete(self, res, interval=2, wait=120):
|
|
"""Wait for a resource to be deleted.
|
|
|
|
:param res: The resource to wait on to be deleted.
|
|
:type resource: A :class:`~openstack.resource.Resource` object.
|
|
:param interval: Number of seconds to wait before to consecutive
|
|
checks. Default to 2.
|
|
:param wait: Maximum number of seconds to wait before the change.
|
|
Default to 120.
|
|
:returns: The resource is returned on success.
|
|
:raises: :class:`~openstack.exceptions.ResourceTimeout` if transition
|
|
to delete failed to occur in the specified seconds.
|
|
"""
|
|
return resource.wait_for_delete(self, res, interval, wait)
|
|
|
|
def get_quota_set(self, project, usage=False, **query):
|
|
"""Show QuotaSet information for the project
|
|
|
|
:param project: ID or instance of
|
|
:class:`~openstack.identity.project.Project` of the project for
|
|
which the quota should be retrieved
|
|
:param bool usage: When set to ``True`` quota usage and reservations
|
|
would be filled.
|
|
:param dict query: Additional query parameters to use.
|
|
|
|
:returns: One :class:`~openstack.block_storage.v2.quota_set.QuotaSet`
|
|
:raises: :class:`~openstack.exceptions.ResourceNotFound`
|
|
when no resource can be found.
|
|
"""
|
|
project = self._get_resource(_project.Project, project)
|
|
res = self._get_resource(
|
|
_quota_set.QuotaSet, None, project_id=project.id)
|
|
return res.fetch(
|
|
self, usage=usage, **query)
|
|
|
|
def get_quota_set_defaults(self, project):
|
|
"""Show QuotaSet defaults for the project
|
|
|
|
:param project: ID or instance of
|
|
:class:`~openstack.identity.project.Project` of the project for
|
|
which the quota should be retrieved
|
|
|
|
:returns: One :class:`~openstack.block_storage.v2.quota_set.QuotaSet`
|
|
:raises: :class:`~openstack.exceptions.ResourceNotFound`
|
|
when no resource can be found.
|
|
"""
|
|
project = self._get_resource(_project.Project, project)
|
|
res = self._get_resource(
|
|
_quota_set.QuotaSet, None, project_id=project.id)
|
|
return res.fetch(
|
|
self, base_path='/os-quota-sets/defaults')
|
|
|
|
def revert_quota_set(self, project, **query):
|
|
"""Reset Quota for the project/user.
|
|
|
|
:param project: ID or instance of
|
|
:class:`~openstack.identity.project.Project` of the project for
|
|
which the quota should be resetted.
|
|
:param dict query: Additional parameters to be used.
|
|
|
|
:returns: ``None``
|
|
"""
|
|
project = self._get_resource(_project.Project, project)
|
|
res = self._get_resource(
|
|
_quota_set.QuotaSet, None, project_id=project.id)
|
|
|
|
return res.delete(self, **query)
|
|
|
|
def update_quota_set(self, quota_set, query=None, **attrs):
|
|
"""Update a QuotaSet.
|
|
|
|
:param quota_set: Either the ID of a quota_set or a
|
|
:class:`~openstack.block_storage.v2.quota_set.QuotaSet` instance.
|
|
:param dict query: Optional parameters to be used with update call.
|
|
:attrs kwargs: The attributes to update on the QuotaSet represented
|
|
by ``quota_set``.
|
|
|
|
:returns: The updated QuotaSet
|
|
:rtype: :class:`~openstack.block_storage.v2.quota_set.QuotaSet`
|
|
"""
|
|
res = self._get_resource(_quota_set.QuotaSet, quota_set, **attrs)
|
|
return res.commit(self, **query)
|