heat.db.api module

Implementation of SQLAlchemy backend.

heat.db.api.engine_get_all_locked_by_stack(context, stack_id)

heat.db.api.event_count_all_by_stack(context, stack_id)

heat.db.api.event_create(context, values)

heat.db.api.event_get_all_by_stack(context, stack_id, limit=None, marker=None, sort_keys=None, sort_dir=None, filters=None)

heat.db.api.event_get_all_by_tenant(context, limit=None, marker=None, sort_keys=None, sort_dir=None, filters=None)

heat.db.api.get_engine()

heat.db.api.persist_state_and_release_lock(context, stack_id, engine_id, values)

heat.db.api.purge_deleted(age, granularity='days', project_id=None, batch_size=20)

heat.db.api.raw_template_create(context, values)

heat.db.api.raw_template_delete(context, template_id)

heat.db.api.raw_template_files_create(context, values)

heat.db.api.raw_template_files_get(context, files_id)

heat.db.api.raw_template_get(context, template_id)

heat.db.api.raw_template_update(context, template_id, values)

heat.db.api.reset_stack_status(context, stack_id)

heat.db.api.resource_attr_data_delete(context, resource_id, attr_id)

heat.db.api.resource_attr_id_set(context, resource_id, atomic_key, attr_id)

heat.db.api.resource_create(context, values)

heat.db.api.resource_create_replacement(context, existing_res_id, new_res_values, atomic_key, expected_engine_id=None)

heat.db.api.resource_data_delete(context, resource_id, key)

heat.db.api.resource_data_get(context, resource_id, key)

Lookup value of resource’s data by key.

Decrypts resource data if necessary.

heat.db.api.resource_data_get_all(context, resource_id, data=None)

Looks up resource_data by resource.id.

If data is encrypted, this method will decrypt the results.

heat.db.api.resource_data_get_by_key(context, resource_id, key)

heat.db.api.resource_data_set(context, resource_id, key, value, redact=False)

Save resource’s key/value pair to database.

heat.db.api.resource_delete(context, resource_id)

heat.db.api.resource_exchange_stacks(context, resource_id1, resource_id2)

heat.db.api.resource_get(context, resource_id, refresh=False, refresh_data=False)

heat.db.api.resource_get_all(context)

heat.db.api.resource_get_all_active_by_stack(context, stack_id)

heat.db.api.resource_get_all_by_physical_resource_id(context, physical_resource_id)

heat.db.api.resource_get_all_by_root_stack(context, stack_id, filters=None, stack_id_only=False)

heat.db.api.resource_get_all_by_stack(context, stack_id, filters=None)

heat.db.api.resource_get_by_name_and_stack(context, resource_name, stack_id)

heat.db.api.resource_get_by_physical_resource_id(context, physical_resource_id)

heat.db.api.resource_prop_data_create(context, values)

heat.db.api.resource_prop_data_create_or_update(context, values, rpd_id=None)

heat.db.api.resource_prop_data_get(context, resource_prop_data_id)

heat.db.api.resource_purge_deleted(context, stack_id)

heat.db.api.resource_update(context, resource_id, values, atomic_key, expected_engine_id=None)

heat.db.api.resource_update_and_save(context, resource_id, values)

heat.db.api.retry_on_db_error(func)

heat.db.api.service_create(context, values)

heat.db.api.service_delete(context, service_id, soft_delete=True)

heat.db.api.service_get(context, service_id)

heat.db.api.service_get_all(context)

heat.db.api.service_get_all_by_args(context, host, binary, hostname)

heat.db.api.service_update(context, service_id, values)

heat.db.api.snapshot_count_all_by_stack(context, stack_id)

heat.db.api.snapshot_create(context, values)

heat.db.api.snapshot_delete(context, snapshot_id)

heat.db.api.snapshot_get(context, snapshot_id)

heat.db.api.snapshot_get_all_by_stack(context, stack_id)

heat.db.api.snapshot_get_by_stack(context, snapshot_id, stack)

heat.db.api.snapshot_update(context, snapshot_id, values)

heat.db.api.software_config_count_all(context)

heat.db.api.software_config_create(context, values)

heat.db.api.software_config_delete(context, config_id)

heat.db.api.software_config_get(context, config_id)

heat.db.api.software_config_get_all(context, limit=None, marker=None)

heat.db.api.software_deployment_count_all(context)

heat.db.api.software_deployment_create(context, values)

heat.db.api.software_deployment_delete(context, deployment_id)

heat.db.api.software_deployment_get(context, deployment_id)

heat.db.api.software_deployment_get_all(context, server_id=None)

heat.db.api.software_deployment_update(context, deployment_id, values)

heat.db.api.stack_count_all(context, filters=None, show_deleted=False, show_nested=False, show_hidden=False, tags=None, tags_any=None, not_tags=None, not_tags_any=None)

heat.db.api.stack_count_total_resources(context, stack_id)

heat.db.api.stack_create(context, values)

heat.db.api.stack_delete(context, stack_id)

heat.db.api.stack_get(context, stack_id, show_deleted=False, eager_load=True)

heat.db.api.stack_get_all(context, limit=None, sort_keys=None, marker=None, sort_dir=None, filters=None, show_deleted=False, show_nested=False, show_hidden=False, tags=None, tags_any=None, not_tags=None, not_tags_any=None, eager_load=False)

heat.db.api.stack_get_all_by_owner_id(context, owner_id)

heat.db.api.stack_get_all_by_root_owner_id(context, owner_id)

heat.db.api.stack_get_by_name(context, stack_name)

heat.db.api.stack_get_by_name_and_owner_id(context, stack_name, owner_id)

heat.db.api.stack_get_root_id(context, stack_id)

heat.db.api.stack_get_status(context, stack_id)

heat.db.api.stack_lock_create(context, stack_id, engine_id)

heat.db.api.stack_lock_get_engine_id(context, stack_id)

heat.db.api.stack_lock_release(context, stack_id, engine_id)

heat.db.api.stack_lock_steal(context, stack_id, old_engine_id, new_engine_id)

heat.db.api.stack_tags_delete(context, stack_id)

heat.db.api.stack_tags_get(context, stack_id)

heat.db.api.stack_tags_set(context, stack_id, tags)

heat.db.api.stack_update(context, stack_id, values, exp_trvsl=None)

heat.db.api.sync_point_create(context, values)

heat.db.api.sync_point_delete_all_by_stack_and_traversal(context, stack_id, traversal_id)

heat.db.api.sync_point_get(context, entity_id, traversal_id, is_update)

heat.db.api.sync_point_update_input_data(context, entity_id, traversal_id, is_update, atomic_key, input_data)

heat.db.api.user_creds_create(context)

heat.db.api.user_creds_delete(context, user_creds_id)

heat.db.api.user_creds_get(context, user_creds_id)