heat.engine.sync_point 模块

heat.engine.sync_point.create(context, entity_id, traversal_id, is_update, stack_id)

在数据库中创建同步点条目。

heat.engine.sync_point.delete_all(context, stack_id, traversal_id)

删除与 traversal_id 关联的堆栈的所有同步点。

heat.engine.sync_point.deserialize_input_data(db_input_data)

heat.engine.sync_point.get(context, entity_id, traversal_id, is_update)

从数据库中检索同步点条目。

heat.engine.sync_point.make_key(*components)

heat.engine.sync_point.serialize_input_data(input_data)

heat.engine.sync_point.str_pack_tuple(t)

heat.engine.sync_point.sync(cnxt, entity_id, current_traversal, is_update, propagate, predecessors, new_data)

heat.engine.sync_point.update_input_data(context, entity_id, current_traversal, is_update, atomic_key, input_data)