nvflare.private.fed.server package

Submodules

• nvflare.private.fed.server.admin module
  • ClientReply
  • FedAdminServer
    • FedAdminServer.accept_reply()
    • FedAdminServer.client_dead()
    • FedAdminServer.client_heartbeat()
    • FedAdminServer.get_client_tokens()
    • FedAdminServer.get_outgoing_requests()
    • FedAdminServer.send_request_to_client()
    • FedAdminServer.send_requests()
    • FedAdminServer.send_requests_and_get_reply_dict()
    • FedAdminServer.stop()
  • check_client_replies()
  • new_message()
• nvflare.private.fed.server.client_manager module
  • ClientManager
    • ClientManager.authenticate()
    • ClientManager.authenticated_client()
    • ClientManager.get_clients()
    • ClientManager.get_max_clients()
    • ClientManager.get_min_clients()
    • ClientManager.heartbeat()
    • ClientManager.is_from_authorized_client()
    • ClientManager.is_valid_task()
    • ClientManager.login_client()
    • ClientManager.remove_client()
    • ClientManager.validate_client()
• nvflare.private.fed.server.cmd_utils module
  • CommandUtil
    • CommandUtil.JOB
    • CommandUtil.JOB_ID
    • CommandUtil.TARGET_CLIENTS
    • CommandUtil.TARGET_CLIENT_NAMES
    • CommandUtil.TARGET_CLIENT_TOKENS
    • CommandUtil.TARGET_TYPE
    • CommandUtil.TARGET_TYPE_ALL
    • CommandUtil.TARGET_TYPE_CLIENT
    • CommandUtil.TARGET_TYPE_SERVER
    • CommandUtil.authorize_abort_client_task()
    • CommandUtil.authorize_client_operation()
    • CommandUtil.authorize_server_operation()
    • CommandUtil.command_authz_required()
    • CommandUtil.get_job_name()
    • CommandUtil.process_replies_to_table()
    • CommandUtil.send_request_to_clients()
    • CommandUtil.validate_command_targets()
• nvflare.private.fed.server.fed_server module
  • BaseServer
    • BaseServer.client_cleanup()
    • BaseServer.close()
    • BaseServer.deploy()
    • BaseServer.fl_shutdown()
    • BaseServer.get_all_clients()
    • BaseServer.remove_client_data()
    • BaseServer.remove_dead_clients()
    • BaseServer.set_admin_server()
  • FederatedServer
    • FederatedServer.AuxCommunicate()
    • FederatedServer.GetTask()
    • FederatedServer.Heartbeat()
    • FederatedServer.Quit()
    • FederatedServer.Register()
    • FederatedServer.Retrieve()
    • FederatedServer.SendReply()
    • FederatedServer.SendResult()
    • FederatedServer.SubmitUpdate()
    • FederatedServer.abort_run()
    • FederatedServer.close()
    • FederatedServer.create_run_manager()
    • FederatedServer.deploy()
    • FederatedServer.fl_shutdown()
    • FederatedServer.get_current_model_meta_data()
    • FederatedServer.overseer_callback()
    • FederatedServer.remove_client_data()
    • FederatedServer.reset_tokens()
    • FederatedServer.run_engine()
    • FederatedServer.start_run()
    • FederatedServer.stop_training()
    • FederatedServer.task_meta_info
• nvflare.private.fed.server.info_coll_cmd module
  • InfoCollectorCommandModule
    • InfoCollectorCommandModule.CONN_KEY_COLLECTOR
    • InfoCollectorCommandModule.authorize_info_collection()
    • InfoCollectorCommandModule.get_spec()
    • InfoCollectorCommandModule.reset_errors()
    • InfoCollectorCommandModule.show_errors()
    • InfoCollectorCommandModule.show_stats()
• nvflare.private.fed.server.job_cmds module
  • JobCommandModule
    • JobCommandModule.abort_job()
    • JobCommandModule.abort_task()
    • JobCommandModule.authorize_job()
    • JobCommandModule.authorize_list_files()
    • JobCommandModule.clone_job()
    • JobCommandModule.delete_job()
    • JobCommandModule.delete_job_id()
    • JobCommandModule.download_job()
    • JobCommandModule.get_spec()
    • JobCommandModule.list_files()
    • JobCommandModule.list_jobs()
    • JobCommandModule.start_app()
    • JobCommandModule.submit_job()
• nvflare.private.fed.server.job_meta_validator module
  • JobMetaValidator
    • JobMetaValidator.validate()
• nvflare.private.fed.server.job_runner module
  • JobRunner
    • JobRunner.abort_client_run()
    • JobRunner.handle_event()
    • JobRunner.restore_running_job()
    • JobRunner.run()
    • JobRunner.stop_all_runs()
    • JobRunner.stop_run()
• nvflare.private.fed.server.run_manager module
  • RunInfo
  • RunManager
    • RunManager.add_component()
    • RunManager.add_handler()
    • RunManager.create_job_processing_context_properties()
    • RunManager.fire_event()
    • RunManager.get_component()
    • RunManager.get_handlers()
    • RunManager.get_run_info()
    • RunManager.get_server_name()
    • RunManager.get_workspace()
    • RunManager.new_context()
• nvflare.private.fed.server.server_app_runner module
  • ServerAppRunner
    • ServerAppRunner.start_server_app()
    • ServerAppRunner.sync_up_parents_process()
    • ServerAppRunner.update_job_run_status()
• nvflare.private.fed.server.server_aux_runner module
  • ServerAuxRunner
    • ServerAuxRunner.send_aux_request()
• nvflare.private.fed.server.server_cmd_modules module
  • ServerCommandModules
    • ServerCommandModules.cmd_modules
    • ServerCommandModules.register_cmd_module()
• nvflare.private.fed.server.server_command_agent module
  • ServerCommandAgent
    • ServerCommandAgent.execute_command()
    • ServerCommandAgent.shutdown()
    • ServerCommandAgent.start()
• nvflare.private.fed.server.server_commands module
  • AbortCommand
    • AbortCommand.get_command_name()
    • AbortCommand.process()
  • AuxCommunicateCommand
    • AuxCommunicateCommand.get_command_name()
    • AuxCommunicateCommand.process()
  • ByeCommand
    • ByeCommand.get_command_name()
    • ByeCommand.process()
  • CommandProcessor
    • CommandProcessor.get_command_name()
    • CommandProcessor.process()
  • GetErrorsCommand
    • GetErrorsCommand.get_command_name()
    • GetErrorsCommand.process()
  • GetRunInfoCommand
    • GetRunInfoCommand.get_command_name()
    • GetRunInfoCommand.process()
  • GetTaskCommand
    • GetTaskCommand.get_command_name()
    • GetTaskCommand.process()
  • ServerCommands
    • ServerCommands.commands
    • ServerCommands.get_command()
    • ServerCommands.register_command()
  • ShowStatsCommand
    • ShowStatsCommand.get_command_name()
    • ShowStatsCommand.process()
  • SubmitUpdateCommand
    • SubmitUpdateCommand.get_command_name()
    • SubmitUpdateCommand.process()
• nvflare.private.fed.server.server_engine module
  • ClientConnection
    • ClientConnection.recv()
    • ClientConnection.send()
  • ServerEngine
    • ServerEngine.abort_app_on_clients()
    • ServerEngine.abort_app_on_server()
    • ServerEngine.ask_to_stop()
    • ServerEngine.aux_send()
    • ServerEngine.build_component()
    • ServerEngine.cancel_client_resources()
    • ServerEngine.check_app_start_readiness()
    • ServerEngine.check_client_resources()
    • ServerEngine.close()
    • ServerEngine.create_parent_connection()
    • ServerEngine.delete_job_id()
    • ServerEngine.deploy_app()
    • ServerEngine.deploy_app_to_server()
    • ServerEngine.dispatch()
    • ServerEngine.fire_event()
    • ServerEngine.get_all_clients()
    • ServerEngine.get_app_data()
    • ServerEngine.get_app_run_info()
    • ServerEngine.get_client_from_name()
    • ServerEngine.get_client_name_from_token()
    • ServerEngine.get_clients()
    • ServerEngine.get_command_conn()
    • ServerEngine.get_component()
    • ServerEngine.get_engine_info()
    • ServerEngine.get_errors()
    • ServerEngine.get_job_clients()
    • ServerEngine.get_run_info()
    • ServerEngine.get_staging_path_of_app()
    • ServerEngine.get_widget()
    • ServerEngine.get_workspace()
    • ServerEngine.heartbeat_to_parent()
    • ServerEngine.new_context()
    • ServerEngine.parent_aux_send()
    • ServerEngine.persist_components()
    • ServerEngine.register_aux_message_handler()
    • ServerEngine.remove_clients()
    • ServerEngine.remove_custom_path()
    • ServerEngine.remove_exception_process()
    • ServerEngine.restart_server()
    • ServerEngine.restore_components()
    • ServerEngine.send_aux_request()
    • ServerEngine.send_command_to_child_runner_process()
    • ServerEngine.set_configurator()
    • ServerEngine.set_job_runner()
    • ServerEngine.set_run_manager()
    • ServerEngine.show_stats()
    • ServerEngine.shutdown_server()
    • ServerEngine.start_app_on_server()
    • ServerEngine.start_client_job()
    • ServerEngine.stop_all_jobs()
    • ServerEngine.sync_clients_from_main_process()
    • ServerEngine.update_job_run_status()
    • ServerEngine.validate_clients()
    • ServerEngine.wait_for_complete()
  • server_shutdown()
• nvflare.private.fed.server.server_engine_internal_spec module
  • EngineInfo
  • ServerEngineInternalSpec
    • ServerEngineInternalSpec.abort_app_on_clients()
    • ServerEngineInternalSpec.abort_app_on_server()
    • ServerEngineInternalSpec.ask_to_stop()
    • ServerEngineInternalSpec.aux_send()
    • ServerEngineInternalSpec.build_component()
    • ServerEngineInternalSpec.check_app_start_readiness()
    • ServerEngineInternalSpec.delete_job_id()
    • ServerEngineInternalSpec.deploy_app_to_server()
    • ServerEngineInternalSpec.get_app_data()
    • ServerEngineInternalSpec.get_app_run_info()
    • ServerEngineInternalSpec.get_client_from_name()
    • ServerEngineInternalSpec.get_client_name_from_token()
    • ServerEngineInternalSpec.get_engine_info()
    • ServerEngineInternalSpec.get_errors()
    • ServerEngineInternalSpec.get_job_clients()
    • ServerEngineInternalSpec.get_staging_path_of_app()
    • ServerEngineInternalSpec.remove_clients()
    • ServerEngineInternalSpec.restart_server()
    • ServerEngineInternalSpec.set_configurator()
    • ServerEngineInternalSpec.set_job_runner()
    • ServerEngineInternalSpec.set_run_manager()
    • ServerEngineInternalSpec.show_stats()
    • ServerEngineInternalSpec.shutdown_server()
    • ServerEngineInternalSpec.start_app_on_server()
• nvflare.private.fed.server.server_json_config module
  • ServerJsonConfigurator
    • ServerJsonConfigurator.build_component()
    • ServerJsonConfigurator.finalize_config()
    • ServerJsonConfigurator.process_config_element()
  • WorkFlow
• nvflare.private.fed.server.server_runner module
  • ServerRunner
    • ServerRunner.abort()
    • ServerRunner.get_persist_state()
    • ServerRunner.handle_event()
    • ServerRunner.process_submission()
    • ServerRunner.process_task_request()
    • ServerRunner.restore()
    • ServerRunner.run()
  • ServerRunnerConfig
    • ServerRunnerConfig.add_component()
• nvflare.private.fed.server.server_state module
  • Cold2HotState
    • Cold2HotState.aux_communicate()
    • Cold2HotState.get_task()
    • Cold2HotState.handle_sd_callback()
    • Cold2HotState.heartbeat()
    • Cold2HotState.register()
    • Cold2HotState.submit_result()
  • ColdState
    • ColdState.aux_communicate()
    • ColdState.get_task()
    • ColdState.handle_sd_callback()
    • ColdState.heartbeat()
    • ColdState.register()
    • ColdState.submit_result()
  • Hot2ColdState
    • Hot2ColdState.aux_communicate()
    • Hot2ColdState.get_task()
    • Hot2ColdState.handle_sd_callback()
    • Hot2ColdState.heartbeat()
    • Hot2ColdState.register()
    • Hot2ColdState.submit_result()
  • HotState
    • HotState.aux_communicate()
    • HotState.get_task()
    • HotState.handle_sd_callback()
    • HotState.heartbeat()
    • HotState.register()
    • HotState.submit_result()
  • ServerState
    • ServerState.ABORT_CURRENT_RUN
    • ServerState.IN_SERVICE
    • ServerState.NOT_IN_SERVICE
    • ServerState.aux_communicate()
    • ServerState.get_task()
    • ServerState.handle_sd_callback()
    • ServerState.heartbeat()
    • ServerState.register()
    • ServerState.submit_result()
  • ServiceSession
  • ShutdownState
    • ShutdownState.aux_communicate()
    • ShutdownState.get_task()
    • ShutdownState.handle_sd_callback()
    • ShutdownState.heartbeat()
    • ShutdownState.register()
    • ShutdownState.submit_result()
• nvflare.private.fed.server.server_status module
  • ServerStatus
    • ServerStatus.NOT_STARTED
    • ServerStatus.SHUTDOWN
    • ServerStatus.STARTED
    • ServerStatus.STARTING
    • ServerStatus.STOPPED
    • ServerStatus.status_messages
  • get_status_message()
• nvflare.private.fed.server.shell_cmd module
  • ShellCommandModule
    • ShellCommandModule.get_spec()
• nvflare.private.fed.server.sys_cmd module
  • SystemCommandModule
    • SystemCommandModule.get_spec()
    • SystemCommandModule.report_resources()
    • SystemCommandModule.sys_info()
• nvflare.private.fed.server.training_cmds module
  • TrainingCommandModule
    • TrainingCommandModule.check_status()
    • TrainingCommandModule.get_spec()
    • TrainingCommandModule.remove_client()
    • TrainingCommandModule.restart()
    • TrainingCommandModule.set_timeout()
    • TrainingCommandModule.show_scopes()
    • TrainingCommandModule.shutdown()

Module contents