The cinder.scheduler.manager Module

The cinder.scheduler.manager Module

Scheduler Service

class SchedulerManager(scheduler_driver=None, service_name=None, *args, **kwargs)

Bases: cinder.manager.CleanableManager, cinder.manager.Manager

Chooses a host to create volumes.

create_group(context, group, group_spec=None, group_filter_properties=None, request_spec_list=None, filter_properties_list=None)
create_snapshot(ctxt, volume, snapshot, backend, request_spec=None, filter_properties=None)

Create snapshot for a volume.

The main purpose of this method is to check if target backend (of volume and snapshot) has sufficient capacity to host to-be-created snapshot.

create_volume(context, volume, snapshot_id=None, image_id=None, request_spec=None, filter_properties=None, backup_id=None)
extend_volume(context, volume, new_size, reservations, request_spec=None, filter_properties=None)
get_pools(context, filters=None)

Get active pools from scheduler’s cache.

NOTE(dulek): There’s no self._wait_for_scheduler() because get_pools is an RPC call (is blocking for the c-api). Also this is admin-only API extension so it won’t hurt the user much to retry the request manually.

manage_existing(context, volume, request_spec, filter_properties=None)

Ensure that the host exists and can accept the volume.

migrate_volume(context, volume, backend, force_copy, request_spec, filter_properties)

Ensure that the backend exists and can accept the volume.

migrate_volume_to_host(context, volume, host, force_host_copy, request_spec, filter_properties=None)
notify_service_capabilities(context, service_name, capabilities, host=None, backend=None, timestamp=None)

Process a capability update from a service node.

retype(context, volume, request_spec, filter_properties=None)

Schedule the modification of a volume’s type.

  • context – the request context
  • volume – the volume object to retype
  • request_spec – parameters for this retype request
  • filter_properties – parameters to filter by
target = <Target version=3.10>
update_service_capabilities(context, service_name=None, host=None, capabilities=None, cluster_name=None, timestamp=None, **kwargs)

Process a capability update from a service node.

validate_host_capacity(context, backend, request_spec, filter_properties)
work_cleanup(context, cleanup_request)

Process request from API to do cleanup on services.

Here we retrieve from the DB which services we want to clean up based on the request from the user.

Then send individual cleanup requests to each of the services that are up, and we finally return a tuple with services that we have sent a cleanup request and those that were not up and we couldn’t send it.

Creative Commons Attribution 3.0 License

Except where otherwise noted, this document is licensed under Creative Commons Attribution 3.0 License. See all OpenStack Legal Documents.