The nova.conductor.manager Module

Handles database requests from other nova services.

class ComputeTaskManager

Bases: nova.db.base.Base

Namespace for compute methods.

This class presents an rpc API for nova-conductor under the ‘compute_task’ namespace. The methods here are compute operations that are invoked by the API service. These methods see the operation to completion, which may involve coordinating activities on multiple compute nodes.

build_instances(context, instances, image, filter_properties, admin_password, injected_files, requested_networks, security_groups, block_device_mapping=None, legacy_bdm=True)

migrate_server(*args, **kwargs)

rebuild_instance(context, instance, orig_image_ref, image_ref, injected_files, new_pass, orig_sys_metadata, bdms, recreate, on_shared_storage, preserve_ephemeral=False, host=None)

target = <Target namespace=compute_task, version=1.11>

unshelve_instance(context, instance)

class ConductorManager(*args, **kwargs)

Bases: nova.manager.Manager

Mission: Conduct things.

The methods in the base API for nova-conductor are various proxy operations performed on behalf of the nova-compute service running on compute nodes. Compute nodes are not allowed to directly access the database, so this set of methods allows them to get specific work done without locally accessing the database.

The nova-conductor service also exposes an API in the ‘compute_task’ namespace. See the ComputeTaskManager class for details.

action_event_finish(*args, **kwargs)

action_event_start(*args, **kwargs)

agent_build_get_by_triple(context, hypervisor, os, architecture)

aggregate_host_add(*args, **kwargs)

aggregate_host_delete(*args, **kwargs)

aggregate_metadata_get_by_host(context, host, key='availability_zone')

block_device_mapping_get_all_by_instance(context, instance, legacy)

block_device_mapping_update_or_create(context, values, create)

bw_usage_update(context, uuid, mac, start_period, bw_in, bw_out, last_ctr_in, last_ctr_out, last_refreshed, update_cells)

compute_api

compute_node_create(context, values)

compute_node_delete(context, node)

compute_node_update(context, node, values)

compute_unrescue(context, instance)

get_ec2_ids(context, instance)

instance_destroy(context, instance)

instance_fault_create(context, values)

instance_get_active_by_window_joined(context, begin, end, project_id, host)

instance_get_all_by_filters(context, filters, sort_key, sort_dir, columns_to_join, use_slave)

instance_get_all_by_host(context, host, node, columns_to_join)

instance_get_by_uuid(*args, **kwargs)

instance_update(*args, **kwargs)

migration_get_in_progress_by_host_and_node(context, host, node)

network_api

network_migrate_instance_finish(context, instance, migration)

network_migrate_instance_start(context, instance, migration)

notify_usage_exists(context, instance, current_period, ignore_missing_network_data, system_metadata, extra_usage_info)

object_action(context, objinst, objmethod, args, kwargs)

Perform an action on an object.

object_backport(context, objinst, target_version)

object_backport_versions(context, objinst, object_versions)

object_class_action(context, objname, objmethod, objver, args, kwargs)

Perform a classmethod action on an object.

object_class_action_versions(context, objname, objmethod, object_versions, args, kwargs)

provider_fw_rule_get_all(context)

quota_commit(context, reservations, project_id=None, user_id=None)

quota_rollback(context, reservations, project_id=None, user_id=None)

security_groups_trigger_handler(context, event, args)

security_groups_trigger_members_refresh(context, group_ids)

service_create(context, values)

service_destroy(*args, **kwargs)

service_get_all_by(*args, **kwargs)

service_update(*args, **kwargs)

target = <Target version=2.3>

task_log_begin_task(context, task_name, begin, end, host, task_items, message)

task_log_end_task(context, task_name, begin, end, host, errors, message)

task_log_get(context, task_name, begin, end, host, state)

vol_usage_update(context, vol_id, rd_req, rd_bytes, wr_req, wr_bytes, instance, last_refreshed, update_totals)