nvflare.edge package

Subpackages

• nvflare.edge.aggregators package
  • Submodules
    • nvflare.edge.aggregators.model_update_dxo module
      • ModelUpdateDXOAggregator
    • nvflare.edge.aggregators.model_update_dxo_factory module
      • ModelUpdateDXOAggrFactory
    • nvflare.edge.aggregators.num_dxo module
      • NumDXOAggregator
    • nvflare.edge.aggregators.num_dxo_factory module
      • NumDXOAggrFactory
  • Module contents
• nvflare.edge.assessors package
  • Submodules
    • nvflare.edge.assessors.async_num module
      • AsyncNumAssessor
    • nvflare.edge.assessors.buff_device_manager module
      • BuffDeviceManager
    • nvflare.edge.assessors.buff_model_manager module
      • BuffModelManager
    • nvflare.edge.assessors.count module
      • CountAssessor
    • nvflare.edge.assessors.device_manager module
      • DeviceManager
    • nvflare.edge.assessors.model_manager module
      • ModelManager
    • nvflare.edge.assessors.model_update module
      • ModelUpdateAssessor
    • nvflare.edge.assessors.num module
      • NumAssessor
    • nvflare.edge.assessors.sgap module
      • SGAPAssessor
    • nvflare.edge.assessors.timeout module
      • TimeoutAssessor
  • Module contents
• nvflare.edge.controllers package
  • Submodules
    • nvflare.edge.controllers.sage module
      • ScatterAndGatherForEdge
      • TaskDoneReason
  • Module contents
• nvflare.edge.device package
  • Subpackages
    • nvflare.edge.device.pt package
      • Submodules
      • Module contents
  • Submodules
    • nvflare.edge.device.config module
      • ComponentResolver
      • ConfigError
      • ConfigKey
      • TrainConfig
      • process_train_config()
    • nvflare.edge.device.config_process_test module
      • BCELossResolver
      • DLTrainer
      • DPFilter
      • Rotate
      • SGDOptimizer
      • StatsKeeper
      • bce_loss()
    • nvflare.edge.device.defs module
      • Batch
      • Context
      • ContextKey
      • DataSource
      • Dataset
      • EventHandler
      • EventType
      • Executor
      • Filter
      • Transform
    • nvflare.edge.device.sdk_spec module
      • FlareRunner
  • Module contents
• nvflare.edge.executors package
  • Submodules
    • nvflare.edge.executors.edge_model_executor module
      • EdgeModelExecutor
    • nvflare.edge.executors.et_edge_model_executor module
      • ETEdgeModelExecutor
    • nvflare.edge.executors.ete module
      • EdgeTaskExecutor
    • nvflare.edge.executors.hug module
      • HierarchicalUpdateGatherer
      • TaskInfo
    • nvflare.edge.executors.simple_edge_executor module
      • SimpleEdgeExecutor
  • Module contents
• nvflare.edge.filters package
  • Submodules
    • nvflare.edge.filters.add_update_header module
      • AddUpdateHeader
  • Module contents
• nvflare.edge.models package
  • Submodules
    • nvflare.edge.models.model module
      • DeviceModel
      • export_model()
      • export_model_to_bytes()
  • Module contents
• nvflare.edge.simulation package
  • Subpackages
    • nvflare.edge.simulation.devices package
      • Submodules
      • Module contents
  • Submodules
    • nvflare.edge.simulation.config module
      • ConfigParser
      • load_class()
    • nvflare.edge.simulation.device_task_processor module
      • DeviceTaskProcessor
    • nvflare.edge.simulation.et_task_processor module
      • ETTaskProcessor
      • calc_params_diff()
      • clone_params()
      • tensor_dict_to_json()
    • nvflare.edge.simulation.feg_api module
      • FegApi
    • nvflare.edge.simulation.run_device_simulator module
      • main()
      • run_simulator()
    • nvflare.edge.simulation.simulated_device module
      • DeviceFactory
      • DeviceState
      • SimulatedDevice
    • nvflare.edge.simulation.simulator module
      • Simulator
  • Module contents
• nvflare.edge.tools package
  • Submodules
    • nvflare.edge.tools.edge_fed_buff_recipe module
      • DeviceManagerConfig
      • EdgeFedBuffRecipe
      • EvaluatorConfig
      • ModelManagerConfig
      • SimulationConfig
    • nvflare.edge.tools.edge_job module
      • EdgeJob
    • nvflare.edge.tools.et_fed_buff_recipe module
      • ETFedBuffRecipe
    • nvflare.edge.tools.et_job module
      • ETJob
  • Module contents
• nvflare.edge.updaters package
  • Submodules
    • nvflare.edge.updaters.aggr module
      • AggrUpdater
    • nvflare.edge.updaters.emd module
      • AggregatorFactory
      • EdgeModelUpdater
      • ModelAggrState
  • Module contents
• nvflare.edge.web package
  • Subpackages
    • nvflare.edge.web.models package
      • Submodules
      • Module contents
    • nvflare.edge.web.service package
      • Submodules
      • Module contents
    • nvflare.edge.web.views package
      • Submodules
      • Module contents
  • Submodules
    • nvflare.edge.web.routing_proxy module
      • FilteredJSONProvider
      • clean_dict()
      • handle_api_error()
      • parse_args()
    • nvflare.edge.web.web_server module
      • FilteredJSONProvider
      • clean_dict()
      • handle_api_error()
      • run_server()
  • Module contents
• nvflare.edge.widgets package
  • Submodules
    • nvflare.edge.widgets.api_service module
      • ApiService
    • nvflare.edge.widgets.device_runner module
      • DeviceRunner
    • nvflare.edge.widgets.etd module
      • EdgeTaskDispatcher
    • nvflare.edge.widgets.etr module
      • EdgeTaskReceiver
    • nvflare.edge.widgets.evaluator module
      • GlobalEvaluator
    • nvflare.edge.widgets.runner module
      • SimulationRunner
    • nvflare.edge.widgets.tp_runner module
      • TPRunner
    • nvflare.edge.widgets.tpo_runner module
      • TPORunner
  • Module contents

Submodules

• nvflare.edge.assessor module
  • Assessment
    • Assessment.CONTINUE
    • Assessment.TASK_DONE
    • Assessment.WORKFLOW_DONE
  • Assessor
    • Assessor.assess()
    • Assessor.end_task()
    • Assessor.finalize()
    • Assessor.process_child_update()
    • Assessor.start_task()
• nvflare.edge.constants module
  • CookieKey
    • CookieKey.DEVICE_SELECTION_ID
    • CookieKey.MODEL_VERSION
  • EdgeApiStatus
    • EdgeApiStatus.DONE
    • EdgeApiStatus.ERROR
    • EdgeApiStatus.INVALID_REQUEST
    • EdgeApiStatus.NO_JOB
    • EdgeApiStatus.NO_TASK
    • EdgeApiStatus.OK
    • EdgeApiStatus.RETRY
  • EdgeConfigFile
    • EdgeConfigFile.DEVICE_CONFIG
  • EdgeContextKey
    • EdgeContextKey.REPLY_TO_EDGE
    • EdgeContextKey.REQUEST_FROM_EDGE
  • EdgeEventType
    • EdgeEventType.EDGE_JOB_REQUEST_RECEIVED
    • EdgeEventType.EDGE_RESULT_REPORT_RECEIVED
    • EdgeEventType.EDGE_SELECTION_REQUEST_RECEIVED
    • EdgeEventType.EDGE_TASK_REQUEST_RECEIVED
  • EdgeMsgTopic
    • EdgeMsgTopic.RESULT_REPORT
    • EdgeMsgTopic.SELECTION_REQUEST
    • EdgeMsgTopic.TASK_REQUEST
  • EdgeTaskHeaderKey
    • EdgeTaskHeaderKey.HAS_UPDATE_DATA
    • EdgeTaskHeaderKey.TASK_SEQ
    • EdgeTaskHeaderKey.UPDATE_INTERVAL
  • HttpHeaderKey
    • HttpHeaderKey.DEVICE_ID
    • HttpHeaderKey.DEVICE_INFO
    • HttpHeaderKey.USER_INFO
  • JobDataKey
    • JobDataKey.CONFIG
  • MsgKey
    • MsgKey.MODE
    • MsgKey.MODEL_VERSION
    • MsgKey.NUM_DEVICES
    • MsgKey.PAYLOAD
    • MsgKey.RESULT
    • MsgKey.TASK_DONE
    • MsgKey.TASK_ID
    • MsgKey.WEIGHTS
  • SpecialDeviceId
    • SpecialDeviceId.DUMMY
    • SpecialDeviceId.MAX_INDICATOR
    • SpecialDeviceId.NUM_INDICATOR
• nvflare.edge.model_protocol module
  • ModelBufferType
    • ModelBufferType.EXECUTORCH
    • ModelBufferType.PYTORCH
  • ModelEncoding
    • ModelEncoding.ASCII
    • ModelEncoding.BASE64
    • ModelEncoding.HEX
    • ModelEncoding.NONE
    • ModelEncoding.UTF8
  • ModelExchangeFormat
    • ModelExchangeFormat.MODEL_BUFFER_ENCODING
    • ModelExchangeFormat.MODEL_BUFFER_NATIVE_FORMAT
    • ModelExchangeFormat.MODEL_BUFFER_TYPE
    • ModelExchangeFormat.MODEL_VERSION
  • ModelNativeFormat
    • ModelNativeFormat.BINARY
    • ModelNativeFormat.STRING
  • verify_payload()
• nvflare.edge.mud module
  • BaseState
    • BaseState.from_shareable()
    • BaseState.get_converted_model()
    • BaseState.is_device_selected()
    • BaseState.set_converted_model()
    • BaseState.to_shareable()
  • Device
    • Device.from_dict()
    • Device.to_dict()
  • ModelUpdate
    • ModelUpdate.from_dict()
    • ModelUpdate.to_dict()
  • PropKey
    • PropKey.CLIENT_NAME
    • PropKey.DEVICES
    • PropKey.DEVICE_ID
    • PropKey.DEVICE_LAST_ALIVE_TIME
    • PropKey.DEVICE_PROPS
    • PropKey.DEVICE_SELECTION
    • PropKey.DEVICE_SELECTION_VERSION
    • PropKey.MODEL
    • PropKey.MODEL_UPDATES
    • PropKey.MODEL_VERSION
    • PropKey.SELECTION_ID
  • StateUpdateReply
    • StateUpdateReply.from_shareable()
    • StateUpdateReply.to_shareable()
  • StateUpdateReport
    • StateUpdateReport.from_shareable()
    • StateUpdateReport.to_shareable()
• nvflare.edge.updater module
  • Updater
    • Updater.end_task()
    • Updater.get_current_state()
    • Updater.prepare_update_for_parent()
    • Updater.process_child_update()
    • Updater.process_parent_update_reply()
    • Updater.start_task()
• nvflare.edge.utils module
  • message_topic_for_task_end()
  • message_topic_for_task_update()
  • process_update_from_child()

Module contents