nebula.frontend.database

nebula.frontend.database#

`setup_database`(db_file_location)
`initialize_databases`()
`list_users`([all_info])
`get_user_info`(user)
`verify`(user, password)
`delete_user_from_db`(user)
`add_user`(user, password, role)
`update_user`(user, password, role)
`list_nodes`([scenario_name, sort_by])
`list_nodes_by_scenario_name`(scenario_name)
`update_node_record`(node_uid, idx, ip, port, role, ...)
`remove_all_nodes`()
`remove_nodes_by_scenario_name`(scenario_name)
`get_run_hashes_scenario`(scenario_name)
`get_all_scenarios`([sort_by])
`get_all_scenarios_and_check_completed`([sort_by])
`scenario_update_record`(scenario_name, start_time, ...)
`scenario_set_all_status_to_finished`()
`scenario_set_status_to_finished`(scenario_name)
`scenario_set_status_to_completed`(scenario_name)
`get_running_scenario`()
`get_completed_scenario`()
`get_scenario_by_name`(scenario_name)
`remove_scenario_by_name`(scenario_name)
`check_scenario_federation_completed`(scenario_name)
`check_scenario_with_role`(role, scenario_name)
`save_notes`(scenario, notes)
`get_notes`(scenario)
`remove_note`(scenario)

nebula.frontend.database.scenario_db_file_location = 'databases/scenarios.db'#

nebula.frontend.database.PRAGMA_SETTINGS = ['PRAGMA journal_mode=WAL;', 'PRAGMA synchronous=NORMAL;', 'PRAGMA journal_size_limit=1048576;',...#

async nebula.frontend.database.update_node_record(node_uid, idx, ip, port, role, neighbors, latitude, longitude, timestamp, federation, federation_round, scenario, run_hash)#

nebula.frontend.database.get_all_scenarios_and_check_completed(sort_by='start_time')#

nebula.frontend.database.scenario_update_record(scenario_name, start_time, end_time, title, description, status, network_subnet, model, dataset, rounds, role)#

nebula.frontend.database.check_scenario_federation_completed(scenario_name)#