¡@
OpenStack Study: api.py**** CubicPower OpenStack Study **** def service_destroy(context, service_id): """Destroy the service or raise if it does not exist.""" return IMPL.service_destroy(context, service_id)
**** CubicPower OpenStack Study **** def service_get(context, service_id): """Get a service or raise if it does not exist.""" return IMPL.service_get(context, service_id)
**** CubicPower OpenStack Study **** def service_get_by_host_and_topic(context, host, topic): """Get a service by host it's on and topic it listens to.""" return IMPL.service_get_by_host_and_topic(context, host, topic)
**** CubicPower OpenStack Study **** def service_get_all(context, disabled=None): """Get all services.""" return IMPL.service_get_all(context, disabled)
**** CubicPower OpenStack Study **** def service_get_all_by_topic(context, topic): """Get all services for a given topic.""" return IMPL.service_get_all_by_topic(context, topic)
**** CubicPower OpenStack Study **** def service_get_all_by_host(context, host): """Get all services for a given host.""" return IMPL.service_get_all_by_host(context, host)
**** CubicPower OpenStack Study **** def service_get_all_volume_sorted(context): """Get all volume services sorted by volume count. :returns: a list of (Service, volume_count) tuples. """ return IMPL.service_get_all_volume_sorted(context)
**** CubicPower OpenStack Study **** def service_get_by_args(context, host, binary): """Get the state of an service by node name and binary.""" return IMPL.service_get_by_args(context, host, binary)
**** CubicPower OpenStack Study **** def service_create(context, values): """Create a service from the values dictionary.""" return IMPL.service_create(context, values)
**** CubicPower OpenStack Study **** def service_update(context, service_id, values): """Set the given properties on an service and update it. Raises NotFound if service does not exist. """ return IMPL.service_update(context, service_id, values) ###################
**** CubicPower OpenStack Study **** def iscsi_target_count_by_host(context, host): """Return count of export devices.""" return IMPL.iscsi_target_count_by_host(context, host)
**** CubicPower OpenStack Study **** def iscsi_target_create_safe(context, values): """Create an iscsi_target from the values dictionary. The device is not returned. If the create violates the unique constraints because the iscsi_target and host already exist, no exception is raised. """ return IMPL.iscsi_target_create_safe(context, values) ###############
**** CubicPower OpenStack Study **** def volume_allocate_iscsi_target(context, volume_id, host): """Atomically allocate a free iscsi_target from the pool.""" return IMPL.volume_allocate_iscsi_target(context, volume_id, host)
**** CubicPower OpenStack Study **** def volume_attached(context, volume_id, instance_id, host_name, mountpoint): """Ensure that a volume is set as attached.""" return IMPL.volume_attached(context, volume_id, instance_id, host_name, mountpoint)
**** CubicPower OpenStack Study **** def volume_create(context, values): """Create a volume from the values dictionary.""" return IMPL.volume_create(context, values)
**** CubicPower OpenStack Study **** def volume_data_get_for_host(context, host): """Get (volume_count, gigabytes) for project.""" return IMPL.volume_data_get_for_host(context, host)
**** CubicPower OpenStack Study **** def volume_data_get_for_project(context, project_id): """Get (volume_count, gigabytes) for project.""" return IMPL.volume_data_get_for_project(context, project_id)
**** CubicPower OpenStack Study **** def finish_volume_migration(context, src_vol_id, dest_vol_id): """Perform database updates upon completion of volume migration.""" return IMPL.finish_volume_migration(context, src_vol_id, dest_vol_id)
**** CubicPower OpenStack Study **** def volume_destroy(context, volume_id): """Destroy the volume or raise if it does not exist.""" return IMPL.volume_destroy(context, volume_id)
**** CubicPower OpenStack Study **** def volume_detached(context, volume_id): """Ensure that a volume is set as detached.""" return IMPL.volume_detached(context, volume_id)
**** CubicPower OpenStack Study **** def volume_get(context, volume_id): """Get a volume or raise if it does not exist.""" return IMPL.volume_get(context, volume_id)
**** CubicPower OpenStack Study **** def volume_get_all(context, marker, limit, sort_key, sort_dir, filters=None): """Get all volumes.""" return IMPL.volume_get_all(context, marker, limit, sort_key, sort_dir, filters=filters)
**** CubicPower OpenStack Study **** def volume_get_all_by_host(context, host): """Get all volumes belonging to a host.""" return IMPL.volume_get_all_by_host(context, host)
**** CubicPower OpenStack Study **** def volume_get_all_by_instance_uuid(context, instance_uuid): """Get all volumes belonging to a instance.""" return IMPL.volume_get_all_by_instance_uuid(context, instance_uuid)
**** CubicPower OpenStack Study **** def volume_get_all_by_project(context, project_id, marker, limit, sort_key, sort_dir, filters=None): """Get all volumes belonging to a project.""" return IMPL.volume_get_all_by_project(context, project_id, marker, limit, sort_key, sort_dir, filters=filters)
**** CubicPower OpenStack Study **** def volume_get_iscsi_target_num(context, volume_id): """Get the target num (tid) allocated to the volume.""" return IMPL.volume_get_iscsi_target_num(context, volume_id)
**** CubicPower OpenStack Study **** def volume_update(context, volume_id, values): """Set the given properties on an volume and update it. Raises NotFound if volume does not exist. """ return IMPL.volume_update(context, volume_id, values) ####################
**** CubicPower OpenStack Study **** def snapshot_create(context, values): """Create a snapshot from the values dictionary.""" return IMPL.snapshot_create(context, values)
**** CubicPower OpenStack Study **** def snapshot_destroy(context, snapshot_id): """Destroy the snapshot or raise if it does not exist.""" return IMPL.snapshot_destroy(context, snapshot_id)
**** CubicPower OpenStack Study **** def snapshot_get(context, snapshot_id): """Get a snapshot or raise if it does not exist.""" return IMPL.snapshot_get(context, snapshot_id)
**** CubicPower OpenStack Study **** def snapshot_get_all(context): """Get all snapshots.""" return IMPL.snapshot_get_all(context)
**** CubicPower OpenStack Study **** def snapshot_get_all_by_project(context, project_id): """Get all snapshots belonging to a project.""" return IMPL.snapshot_get_all_by_project(context, project_id)
**** CubicPower OpenStack Study **** def snapshot_get_all_for_volume(context, volume_id): """Get all snapshots for a volume.""" return IMPL.snapshot_get_all_for_volume(context, volume_id)
**** CubicPower OpenStack Study **** def snapshot_update(context, snapshot_id, values): """Set the given properties on an snapshot and update it. Raises NotFound if snapshot does not exist. """ return IMPL.snapshot_update(context, snapshot_id, values)
**** CubicPower OpenStack Study **** def snapshot_data_get_for_project(context, project_id, volume_type_id=None): """Get count and gigabytes used for snapshots for specified project.""" return IMPL.snapshot_data_get_for_project(context, project_id, volume_type_id)
**** CubicPower OpenStack Study **** def snapshot_get_active_by_window(context, begin, end=None, project_id=None): """Get all the snapshots inside the window. Specifying a project_id will filter for a certain project. """ return IMPL.snapshot_get_active_by_window(context, begin, end, project_id) ####################
**** CubicPower OpenStack Study **** def snapshot_metadata_get(context, snapshot_id): """Get all metadata for a snapshot.""" return IMPL.snapshot_metadata_get(context, snapshot_id)
**** CubicPower OpenStack Study **** def snapshot_metadata_delete(context, snapshot_id, key): """Delete the given metadata item.""" return IMPL.snapshot_metadata_delete(context, snapshot_id, key)
**** CubicPower OpenStack Study **** def snapshot_metadata_update(context, snapshot_id, metadata, delete): """Update metadata if it exists, otherwise create it.""" return IMPL.snapshot_metadata_update(context, snapshot_id, metadata, delete) ####################
**** CubicPower OpenStack Study **** def volume_metadata_get(context, volume_id): """Get all metadata for a volume.""" return IMPL.volume_metadata_get(context, volume_id)
**** CubicPower OpenStack Study **** def volume_metadata_delete(context, volume_id, key): """Delete the given metadata item.""" return IMPL.volume_metadata_delete(context, volume_id, key)
**** CubicPower OpenStack Study **** def volume_metadata_update(context, volume_id, metadata, delete): """Update metadata if it exists, otherwise create it.""" return IMPL.volume_metadata_update(context, volume_id, metadata, delete) ##################
**** CubicPower OpenStack Study **** def volume_admin_metadata_get(context, volume_id): """Get all administration metadata for a volume.""" return IMPL.volume_admin_metadata_get(context, volume_id)
**** CubicPower OpenStack Study **** def volume_admin_metadata_delete(context, volume_id, key): """Delete the given metadata item.""" return IMPL.volume_admin_metadata_delete(context, volume_id, key)
**** CubicPower OpenStack Study **** def volume_admin_metadata_update(context, volume_id, metadata, delete): """Update metadata if it exists, otherwise create it.""" return IMPL.volume_admin_metadata_update(context, volume_id, metadata, delete) ##################
**** CubicPower OpenStack Study **** def volume_type_create(context, values): """Create a new volume type.""" return IMPL.volume_type_create(context, values)
**** CubicPower OpenStack Study **** def volume_type_get_all(context, inactive=False): """Get all volume types.""" return IMPL.volume_type_get_all(context, inactive)
**** CubicPower OpenStack Study **** def volume_type_get(context, id, inactive=False): """Get volume type by id.""" return IMPL.volume_type_get(context, id, inactive)
**** CubicPower OpenStack Study **** def volume_type_get_by_name(context, name): """Get volume type by name.""" return IMPL.volume_type_get_by_name(context, name)
**** CubicPower OpenStack Study **** def volume_type_qos_associations_get(context, qos_specs_id, inactive=False): """Get volume types that are associated with specific qos specs.""" return IMPL.volume_type_qos_associations_get(context, qos_specs_id, inactive)
**** CubicPower OpenStack Study **** def volume_type_qos_associate(context, type_id, qos_specs_id): """Associate a volume type with specific qos specs.""" return IMPL.volume_type_qos_associate(context, type_id, qos_specs_id)
**** CubicPower OpenStack Study **** def volume_type_qos_disassociate(context, qos_specs_id, type_id): """Disassociate a volume type from specific qos specs.""" return IMPL.volume_type_qos_disassociate(context, qos_specs_id, type_id)
**** CubicPower OpenStack Study **** def volume_type_qos_disassociate_all(context, qos_specs_id): """Disassociate all volume types from specific qos specs.""" return IMPL.volume_type_qos_disassociate_all(context, qos_specs_id)
**** CubicPower OpenStack Study **** def volume_type_qos_specs_get(context, type_id): """Get all qos specs for given volume type.""" return IMPL.volume_type_qos_specs_get(context, type_id)
**** CubicPower OpenStack Study **** def volume_type_destroy(context, id): """Delete a volume type.""" return IMPL.volume_type_destroy(context, id)
**** CubicPower OpenStack Study **** def volume_get_active_by_window(context, begin, end=None, project_id=None): """Get all the volumes inside the window. Specifying a project_id will filter for a certain project. """ return IMPL.volume_get_active_by_window(context, begin, end, project_id) ####################
**** CubicPower OpenStack Study **** def volume_type_extra_specs_get(context, volume_type_id): """Get all extra specs for a volume type.""" return IMPL.volume_type_extra_specs_get(context, volume_type_id)
**** CubicPower OpenStack Study **** def volume_type_extra_specs_delete(context, volume_type_id, key): """Delete the given extra specs item.""" return IMPL.volume_type_extra_specs_delete(context, volume_type_id, key)
**** CubicPower OpenStack Study **** def volume_type_extra_specs_update_or_create(context, volume_type_id, extra_specs): """Create or update volume type extra specs. This adds or modifies the key/value pairs specified in the extra specs dict argument """ return IMPL.volume_type_extra_specs_update_or_create(context, volume_type_id, extra_specs) ###################
**** CubicPower OpenStack Study **** def volume_type_encryption_get(context, volume_type_id, session=None): return IMPL.volume_type_encryption_get(context, volume_type_id, session)
**** CubicPower OpenStack Study **** def volume_type_encryption_delete(context, volume_type_id): return IMPL.volume_type_encryption_delete(context, volume_type_id)
**** CubicPower OpenStack Study **** def volume_type_encryption_create(context, volume_type_id, encryption_specs): return IMPL.volume_type_encryption_create(context, volume_type_id, encryption_specs)
**** CubicPower OpenStack Study **** def volume_type_encryption_update(context, volume_type_id, encryption_specs): return IMPL.volume_type_encryption_update(context, volume_type_id, encryption_specs)
**** CubicPower OpenStack Study **** def volume_type_encryption_volume_get(context, volume_type_id, session=None): return IMPL.volume_type_encryption_volume_get(context, volume_type_id, session)
**** CubicPower OpenStack Study **** def volume_encryption_metadata_get(context, volume_id, session=None): return IMPL.volume_encryption_metadata_get(context, volume_id, session) ###################
**** CubicPower OpenStack Study **** def qos_specs_create(context, values): """Create a qos_specs.""" return IMPL.qos_specs_create(context, values)
**** CubicPower OpenStack Study **** def qos_specs_get(context, qos_specs_id): """Get all specification for a given qos_specs.""" return IMPL.qos_specs_get(context, qos_specs_id)
**** CubicPower OpenStack Study **** def qos_specs_get_all(context, inactive=False, filters=None): """Get all qos_specs.""" return IMPL.qos_specs_get_all(context, inactive, filters)
**** CubicPower OpenStack Study **** def qos_specs_get_by_name(context, name): """Get all specification for a given qos_specs.""" return IMPL.qos_specs_get_by_name(context, name)
**** CubicPower OpenStack Study **** def qos_specs_associations_get(context, qos_specs_id): """Get all associated volume types for a given qos_specs.""" return IMPL.qos_specs_associations_get(context, qos_specs_id)
**** CubicPower OpenStack Study **** def qos_specs_associate(context, qos_specs_id, type_id): """Associate qos_specs from volume type.""" return IMPL.qos_specs_associate(context, qos_specs_id, type_id)
**** CubicPower OpenStack Study **** def qos_specs_disassociate(context, qos_specs_id, type_id): """Disassociate qos_specs from volume type.""" return IMPL.qos_specs_disassociate(context, qos_specs_id, type_id)
**** CubicPower OpenStack Study **** def qos_specs_disassociate_all(context, qos_specs_id): """Disassociate qos_specs from all entities.""" return IMPL.qos_specs_disassociate_all(context, qos_specs_id)
**** CubicPower OpenStack Study **** def qos_specs_delete(context, qos_specs_id): """Delete the qos_specs.""" return IMPL.qos_specs_delete(context, qos_specs_id)
**** CubicPower OpenStack Study **** def qos_specs_item_delete(context, qos_specs_id, key): """Delete specified key in the qos_specs.""" return IMPL.qos_specs_item_delete(context, qos_specs_id, key)
**** CubicPower OpenStack Study **** def qos_specs_update(context, qos_specs_id, specs): """Update qos specs. This adds or modifies the key/value pairs specified in the specs dict argument for a given qos_specs. """ return IMPL.qos_specs_update(context, qos_specs_id, specs) ###################
**** CubicPower OpenStack Study **** def volume_glance_metadata_create(context, volume_id, key, value): """Update the Glance metadata for the specified volume.""" return IMPL.volume_glance_metadata_create(context, volume_id, key, value)
**** CubicPower OpenStack Study **** def volume_glance_metadata_get_all(context): """Return the glance metadata for all volumes.""" return IMPL.volume_glance_metadata_get_all(context)
**** CubicPower OpenStack Study **** def volume_glance_metadata_get(context, volume_id): """Return the glance metadata for a volume.""" return IMPL.volume_glance_metadata_get(context, volume_id)
**** CubicPower OpenStack Study **** def volume_snapshot_glance_metadata_get(context, snapshot_id): """Return the Glance metadata for the specified snapshot.""" return IMPL.volume_snapshot_glance_metadata_get(context, snapshot_id)
**** CubicPower OpenStack Study **** def volume_glance_metadata_copy_to_snapshot(context, snapshot_id, volume_id): """Update the Glance metadata for a snapshot. This will copy all of the key:value pairs from the originating volume, to ensure that a volume created from the snapshot will retain the original metadata. """ return IMPL.volume_glance_metadata_copy_to_snapshot(context, snapshot_id, volume_id)
**** CubicPower OpenStack Study **** def volume_glance_metadata_copy_to_volume(context, volume_id, snapshot_id): """Update the Glance metadata from a volume (created from a snapshot). This will copy all of the key:value pairs from the originating snapshot, to ensure that the Glance metadata from the original volume is retained. """ return IMPL.volume_glance_metadata_copy_to_volume(context, volume_id, snapshot_id)
**** CubicPower OpenStack Study **** def volume_glance_metadata_delete_by_volume(context, volume_id): """Delete the glance metadata for a volume.""" return IMPL.volume_glance_metadata_delete_by_volume(context, volume_id)
**** CubicPower OpenStack Study **** def volume_glance_metadata_delete_by_snapshot(context, snapshot_id): """Delete the glance metadata for a snapshot.""" return IMPL.volume_glance_metadata_delete_by_snapshot(context, snapshot_id)
**** CubicPower OpenStack Study **** def volume_glance_metadata_copy_from_volume_to_volume(context, src_volume_id, volume_id): """Update the Glance metadata for a volume by copying all of the key:value pairs from the originating volume. This is so that a volume created from the volume (clone) will retain the original metadata. """ return IMPL.volume_glance_metadata_copy_from_volume_to_volume( context, src_volume_id, volume_id) ###################
**** CubicPower OpenStack Study **** def quota_create(context, project_id, resource, limit): """Create a quota for the given project and resource.""" return IMPL.quota_create(context, project_id, resource, limit)
**** CubicPower OpenStack Study **** def quota_get(context, project_id, resource): """Retrieve a quota or raise if it does not exist.""" return IMPL.quota_get(context, project_id, resource)
**** CubicPower OpenStack Study **** def quota_get_all_by_project(context, project_id): """Retrieve all quotas associated with a given project.""" return IMPL.quota_get_all_by_project(context, project_id)
**** CubicPower OpenStack Study **** def quota_update(context, project_id, resource, limit): """Update a quota or raise if it does not exist.""" return IMPL.quota_update(context, project_id, resource, limit)
**** CubicPower OpenStack Study **** def quota_destroy(context, project_id, resource): """Destroy the quota or raise if it does not exist.""" return IMPL.quota_destroy(context, project_id, resource) ###################
**** CubicPower OpenStack Study **** def quota_class_create(context, class_name, resource, limit): """Create a quota class for the given name and resource.""" return IMPL.quota_class_create(context, class_name, resource, limit)
**** CubicPower OpenStack Study **** def quota_class_get(context, class_name, resource): """Retrieve a quota class or raise if it does not exist.""" return IMPL.quota_class_get(context, class_name, resource)
**** CubicPower OpenStack Study **** def quota_class_get_default(context): """Retrieve all default quotas.""" return IMPL.quota_class_get_default(context)
**** CubicPower OpenStack Study **** def quota_class_get_all_by_name(context, class_name): """Retrieve all quotas associated with a given quota class.""" return IMPL.quota_class_get_all_by_name(context, class_name)
**** CubicPower OpenStack Study **** def quota_class_update(context, class_name, resource, limit): """Update a quota class or raise if it does not exist.""" return IMPL.quota_class_update(context, class_name, resource, limit)
**** CubicPower OpenStack Study **** def quota_class_destroy(context, class_name, resource): """Destroy the quota class or raise if it does not exist.""" return IMPL.quota_class_destroy(context, class_name, resource)
**** CubicPower OpenStack Study **** def quota_class_destroy_all_by_name(context, class_name): """Destroy all quotas associated with a given quota class.""" return IMPL.quota_class_destroy_all_by_name(context, class_name) ###################
**** CubicPower OpenStack Study **** def quota_usage_get(context, project_id, resource): """Retrieve a quota usage or raise if it does not exist.""" return IMPL.quota_usage_get(context, project_id, resource)
**** CubicPower OpenStack Study **** def quota_usage_get_all_by_project(context, project_id): """Retrieve all usage associated with a given resource.""" return IMPL.quota_usage_get_all_by_project(context, project_id) ###################
**** CubicPower OpenStack Study **** def reservation_create(context, uuid, usage, project_id, resource, delta, expire): """Create a reservation for the given project and resource.""" return IMPL.reservation_create(context, uuid, usage, project_id, resource, delta, expire)
**** CubicPower OpenStack Study **** def reservation_get(context, uuid): """Retrieve a reservation or raise if it does not exist.""" return IMPL.reservation_get(context, uuid)
**** CubicPower OpenStack Study **** def reservation_get_all_by_project(context, project_id): """Retrieve all reservations associated with a given project.""" return IMPL.reservation_get_all_by_project(context, project_id)
**** CubicPower OpenStack Study **** def reservation_destroy(context, uuid): """Destroy the reservation or raise if it does not exist.""" return IMPL.reservation_destroy(context, uuid) ###################
**** CubicPower OpenStack Study **** def quota_reserve(context, resources, quotas, deltas, expire, until_refresh, max_age, project_id=None): """Check quotas and create appropriate reservations.""" return IMPL.quota_reserve(context, resources, quotas, deltas, expire, until_refresh, max_age, project_id=project_id)
**** CubicPower OpenStack Study **** def reservation_commit(context, reservations, project_id=None): """Commit quota reservations.""" return IMPL.reservation_commit(context, reservations, project_id=project_id)
**** CubicPower OpenStack Study **** def reservation_rollback(context, reservations, project_id=None): """Roll back quota reservations.""" return IMPL.reservation_rollback(context, reservations, project_id=project_id)
**** CubicPower OpenStack Study **** def quota_destroy_all_by_project(context, project_id): """Destroy all quotas associated with a given project.""" return IMPL.quota_destroy_all_by_project(context, project_id)
**** CubicPower OpenStack Study **** def reservation_expire(context): """Roll back any expired reservations.""" return IMPL.reservation_expire(context) ###################
**** CubicPower OpenStack Study **** def backup_get(context, backup_id): """Get a backup or raise if it does not exist.""" return IMPL.backup_get(context, backup_id)
**** CubicPower OpenStack Study **** def backup_get_all(context): """Get all backups.""" return IMPL.backup_get_all(context)
**** CubicPower OpenStack Study **** def backup_get_all_by_host(context, host): """Get all backups belonging to a host.""" return IMPL.backup_get_all_by_host(context, host)
**** CubicPower OpenStack Study **** def backup_create(context, values): """Create a backup from the values dictionary.""" return IMPL.backup_create(context, values)
**** CubicPower OpenStack Study **** def backup_get_all_by_project(context, project_id): """Get all backups belonging to a project.""" return IMPL.backup_get_all_by_project(context, project_id)
**** CubicPower OpenStack Study **** def backup_update(context, backup_id, values): """Set the given properties on a backup and update it. Raises NotFound if backup does not exist. """ return IMPL.backup_update(context, backup_id, values)
**** CubicPower OpenStack Study **** def backup_destroy(context, backup_id): """Destroy the backup or raise if it does not exist.""" return IMPL.backup_destroy(context, backup_id) ###################
**** CubicPower OpenStack Study **** def transfer_get(context, transfer_id): """Get a volume transfer record or raise if it does not exist.""" return IMPL.transfer_get(context, transfer_id)
**** CubicPower OpenStack Study **** def transfer_get_all(context): """Get all volume transfer records.""" return IMPL.transfer_get_all(context)
**** CubicPower OpenStack Study **** def transfer_get_all_by_project(context, project_id): """Get all volume transfer records for specified project.""" return IMPL.transfer_get_all_by_project(context, project_id)
**** CubicPower OpenStack Study **** def transfer_create(context, values): """Create an entry in the transfers table.""" return IMPL.transfer_create(context, values)
**** CubicPower OpenStack Study **** def transfer_destroy(context, transfer_id): """Destroy a record in the volume transfer table.""" return IMPL.transfer_destroy(context, transfer_id)
**** CubicPower OpenStack Study **** def transfer_accept(context, transfer_id, user_id, project_id): """Accept a volume transfer.""" return IMPL.transfer_accept(context, transfer_id, user_id, project_id)
|