Handles all requests to the conductor service.
-
class API
Bases: object
Conductor API that does updates via RPC to the ConductorManager.
-
action_event_finish(context, values)
-
action_event_start(context, values)
-
agent_build_get_by_triple(context, hypervisor, os, architecture)
-
aggregate_get(context, aggregate_id)
-
aggregate_get_by_host(context, host, key=None)
-
aggregate_host_add(context, aggregate, host)
-
aggregate_host_delete(context, aggregate, host)
-
aggregate_metadata_add(context, aggregate, metadata, set_delete=False)
-
aggregate_metadata_delete(context, aggregate, key)
-
aggregate_metadata_get_by_host(context, host, key='availability_zone')
-
block_device_mapping_create(context, values)
-
block_device_mapping_destroy(context, bdms)
-
block_device_mapping_destroy_by_instance_and_device(context, instance, device_name)
-
block_device_mapping_destroy_by_instance_and_volume(context, instance, volume_id)
-
block_device_mapping_get_all_by_instance(context, instance)
-
block_device_mapping_update(context, bdm_id, values)
-
block_device_mapping_update_or_create(context, values)
-
bw_usage_get(context, uuid, start_period, mac)
-
bw_usage_update(context, uuid, mac, start_period, bw_in, bw_out, last_ctr_in, last_ctr_out, last_refreshed=None)
-
compute_confirm_resize(context, instance, migration_ref)
-
compute_node_create(context, values)
-
compute_node_delete(context, node)
-
compute_node_update(context, node, values, prune_stats=False)
-
compute_stop(context, instance, do_cast=True)
-
compute_unrescue(context, instance)
-
get_backdoor_port(context, host)
-
get_ec2_ids(context, instance)
-
instance_destroy(context, instance)
-
instance_fault_create(context, values)
-
instance_get(context, instance_id)
-
instance_get_active_by_window_joined(context, begin, end=None, project_id=None, host=None)
-
instance_get_all(context)
-
instance_get_all_by_filters(context, filters, sort_key='created_at', sort_dir='desc', columns_to_join=None)
-
instance_get_all_by_host(context, host, columns_to_join=None)
-
instance_get_all_by_host_and_node(context, host, node)
-
instance_get_all_hung_in_rebooting(context, timeout)
-
instance_get_by_uuid(context, instance_uuid)
-
instance_info_cache_delete(context, instance)
-
instance_info_cache_update(context, instance, values)
-
instance_type_get(context, instance_type_id)
-
instance_update(context, instance_uuid, **updates)
Perform an instance update in the database.
-
migration_create(context, instance, values)
-
migration_get(context, migration_id)
-
migration_get_in_progress_by_host_and_node(context, host, node)
-
migration_get_unconfirmed_by_dest_compute(context, confirm_window, dest_compute)
-
migration_update(context, migration, status)
-
network_migrate_instance_finish(context, instance, migration)
-
network_migrate_instance_start(context, instance, migration)
-
notify_usage_exists(context, instance, current_period=False, ignore_missing_network_data=True, system_metadata=None, extra_usage_info=None)
-
ping(context, arg, timeout=None)
-
provider_fw_rule_get_all(context)
-
quota_commit(context, reservations, project_id=None)
-
quota_rollback(context, reservations, project_id=None)
-
security_group_get_by_instance(context, instance)
-
security_group_rule_get_by_security_group(context, secgroup)
-
security_groups_trigger_handler(context, event, *args)
-
security_groups_trigger_members_refresh(context, group_ids)
-
service_create(context, values)
-
service_destroy(context, service_id)
-
service_get_all(context)
-
service_get_all_by_host(context, host)
-
service_get_all_by_topic(context, topic)
-
service_get_by_args(context, host, binary)
-
service_get_by_compute_host(context, host)
-
service_get_by_host_and_topic(context, host, topic)
-
service_update(context, service, values)
-
task_log_begin_task(context, task_name, begin, end, host, task_items=None, message=None)
-
task_log_end_task(context, task_name, begin, end, host, errors, message=None)
-
task_log_get(context, task_name, begin, end, host, state=None)
-
vol_get_usage_by_time(context, start_time)
-
vol_usage_update(context, vol_id, rd_req, rd_bytes, wr_req, wr_bytes, instance, last_refreshed=None, update_totals=False)
-
wait_until_ready(context, early_timeout=10, early_attempts=10)
Wait until a conductor service is up and running.
This method calls the remote ping() method on the conductor topic until
it gets a response. It starts with a shorter timeout in the loop
(early_timeout) up to early_attempts number of tries. It then drops
back to the globally configured timeout for rpc calls for each retry.
-
class LocalAPI
Bases: object
A local version of the conductor API that does database updates
locally instead of via RPC
-
action_event_finish(context, values)
-
action_event_start(context, values)
-
agent_build_get_by_triple(context, hypervisor, os, architecture)
-
aggregate_get(context, aggregate_id)
-
aggregate_get_by_host(context, host, key=None)
-
aggregate_host_add(context, aggregate, host)
-
aggregate_host_delete(context, aggregate, host)
-
aggregate_metadata_add(context, aggregate, metadata, set_delete=False)
-
aggregate_metadata_delete(context, aggregate, key)
-
aggregate_metadata_get_by_host(context, host, key='availability_zone')
-
block_device_mapping_create(context, values)
-
block_device_mapping_destroy(context, bdms)
-
block_device_mapping_destroy_by_instance_and_device(context, instance, device_name)
-
block_device_mapping_destroy_by_instance_and_volume(context, instance, volume_id)
-
block_device_mapping_get_all_by_instance(context, instance)
-
block_device_mapping_update(context, bdm_id, values)
-
block_device_mapping_update_or_create(context, values)
-
bw_usage_get(context, uuid, start_period, mac)
-
bw_usage_update(context, uuid, mac, start_period, bw_in, bw_out, last_ctr_in, last_ctr_out, last_refreshed=None)
-
compute_confirm_resize(context, instance, migration_ref)
-
compute_node_create(context, values)
-
compute_node_delete(context, node)
-
compute_node_update(context, node, values, prune_stats=False)
-
compute_stop(context, instance, do_cast=True)
-
compute_unrescue(context, instance)
-
get_backdoor_port(context, host)
-
get_ec2_ids(context, instance)
-
instance_destroy(context, instance)
-
instance_fault_create(context, values)
-
instance_get(context, instance_id)
-
instance_get_active_by_window_joined(context, begin, end=None, project_id=None, host=None)
-
instance_get_all(context)
-
instance_get_all_by_filters(context, filters, sort_key='created_at', sort_dir='desc', columns_to_join=None)
-
instance_get_all_by_host(context, host, columns_to_join=None)
-
instance_get_all_by_host_and_node(context, host, node)
-
instance_get_all_hung_in_rebooting(context, timeout)
-
instance_get_by_uuid(context, instance_uuid)
-
instance_info_cache_delete(context, instance)
-
instance_info_cache_update(context, instance, values)
-
instance_type_get(context, instance_type_id)
-
instance_update(context, instance_uuid, **updates)
Perform an instance update in the database.
-
migration_create(context, instance, values)
-
migration_get(context, migration_id)
-
migration_get_in_progress_by_host_and_node(context, host, node)
-
migration_get_unconfirmed_by_dest_compute(context, confirm_window, dest_compute)
-
migration_update(context, migration, status)
-
network_migrate_instance_finish(context, instance, migration)
-
network_migrate_instance_start(context, instance, migration)
-
notify_usage_exists(context, instance, current_period=False, ignore_missing_network_data=True, system_metadata=None, extra_usage_info=None)
-
ping(context, arg, timeout=None)
-
provider_fw_rule_get_all(context)
-
quota_commit(context, reservations, project_id=None)
-
quota_rollback(context, reservations, project_id=None)
-
security_group_get_by_instance(context, instance)
-
security_group_rule_get_by_security_group(context, secgroup)
-
security_groups_trigger_handler(context, event, *args)
-
security_groups_trigger_members_refresh(context, group_ids)
-
service_create(context, values)
-
service_destroy(context, service_id)
-
service_get_all(context)
-
service_get_all_by_host(context, host)
-
service_get_all_by_topic(context, topic)
-
service_get_by_args(context, host, binary)
-
service_get_by_compute_host(context, host)
-
service_get_by_host_and_topic(context, host, topic)
-
service_update(context, service, values)
-
task_log_begin_task(context, task_name, begin, end, host, task_items=None, message=None)
-
task_log_end_task(context, task_name, begin, end, host, errors, message=None)
-
task_log_get(context, task_name, begin, end, host, state=None)
-
vol_get_usage_by_time(context, start_time)
-
vol_usage_update(context, vol_id, rd_req, rd_bytes, wr_req, wr_bytes, instance, last_refreshed=None, update_totals=False)
-
wait_until_ready(context, *args, **kwargs)