nvflare.fuel.f3.cellnet package

Submodules

• nvflare.fuel.f3.cellnet.cbs module
  • cell_connected_cb_signature()
  • cell_disconnected_cb_signature()
  • cleanup_cb_signature()
  • filter_cb_signature()
  • message_interceptor_signature()
  • request_cb_signature()
• nvflare.fuel.f3.cellnet.cell module
  • Cell
    • Cell.ALL_CELLS
    • Cell.APP_ID
    • Cell.ERR_TYPE_COMM
    • Cell.ERR_TYPE_MSG_TOO_BIG
    • Cell.SUB_TYPE_CHILD
    • Cell.SUB_TYPE_CLIENT
    • Cell.SUB_TYPE_NONE
    • Cell.add_error_handler()
    • Cell.add_incoming_reply_filter()
    • Cell.add_incoming_request_filter()
    • Cell.add_outgoing_reply_filter()
    • Cell.add_outgoing_request_filter()
    • Cell.broadcast_multi_requests()
    • Cell.broadcast_request()
    • Cell.change_server_root()
    • Cell.drop_agents()
    • Cell.drop_connectors()
    • Cell.fire_and_forget()
    • Cell.fire_multi_requests_and_forget()
    • Cell.get_fqcn()
    • Cell.get_internal_listener_url()
    • Cell.get_root_url_for_child()
    • Cell.get_sub_cell_names()
    • Cell.is_backbone_ready()
    • Cell.is_cell_connected()
    • Cell.is_cell_reachable()
    • Cell.log_error()
    • Cell.log_warning()
    • Cell.make_internal_listener()
    • Cell.process_message()
    • Cell.queue_message()
    • Cell.register_request_cb()
    • Cell.send_reply()
    • Cell.send_request()
    • Cell.set_cell_connected_cb()
    • Cell.set_cell_disconnected_cb()
    • Cell.set_message_interceptor()
    • Cell.start()
    • Cell.state_change()
    • Cell.stop()
  • CellAgent
    • CellAgent.get_fqcn()
  • TargetMessage
    • TargetMessage.from_dict()
    • TargetMessage.to_dict()
  • log_messaging_error()
• nvflare.fuel.f3.cellnet.connector_manager module
  • ConnectorData
    • ConnectorData.get_connection_url()
  • ConnectorManager
    • ConnectorManager.get_config_info()
    • ConnectorManager.get_external_connector()
    • ConnectorManager.get_external_listener()
    • ConnectorManager.get_internal_connector()
    • ConnectorManager.get_internal_listener()
    • ConnectorManager.is_adhoc_allowed()
    • ConnectorManager.should_connect_to_server()
• nvflare.fuel.f3.cellnet.defs module
  • AbortRun
  • AuthenticationError
  • CellPropertyKey
    • CellPropertyKey.FQCN
  • ConnectorRequirementKey
    • ConnectorRequirementKey.HOST
    • ConnectorRequirementKey.SECURE
    • ConnectorRequirementKey.URL
  • Encoding
    • Encoding.BYTES
    • Encoding.FOBS
    • Encoding.NONE
  • InvalidRequest
  • InvalidSession
  • MessageHeaderKey
    • MessageHeaderKey.CHANNEL
    • MessageHeaderKey.CONN_URL
    • MessageHeaderKey.DESTINATION
    • MessageHeaderKey.ERROR
    • MessageHeaderKey.FROM_CELL
    • MessageHeaderKey.MSG_TYPE
    • MessageHeaderKey.OPTIONAL
    • MessageHeaderKey.ORIGIN
    • MessageHeaderKey.ORIGINAL_HEADERS
    • MessageHeaderKey.PAYLOAD_ENCODING
    • MessageHeaderKey.REPLY_EXPECTED
    • MessageHeaderKey.REQ_ID
    • MessageHeaderKey.RETURN_CODE
    • MessageHeaderKey.RETURN_REASON
    • MessageHeaderKey.ROUTE
    • MessageHeaderKey.SEND_TIME
    • MessageHeaderKey.TOPIC
    • MessageHeaderKey.TO_CELL
    • MessageHeaderKey.WAIT_UNTIL
  • MessagePropKey
    • MessagePropKey.COMMON_NAME
    • MessagePropKey.ENDPOINT
  • MessageType
    • MessageType.REPLY
    • MessageType.REQ
    • MessageType.RETURN
  • ReturnCode
    • ReturnCode.ABORT_RUN
    • ReturnCode.AUTHENTICATION_ERROR
    • ReturnCode.COMM_ERROR
    • ReturnCode.FILTER_ERROR
    • ReturnCode.INVALID_REQUEST
    • ReturnCode.INVALID_SESSION
    • ReturnCode.INVALID_TARGET
    • ReturnCode.MSG_TOO_BIG
    • ReturnCode.OK
    • ReturnCode.PROCESS_EXCEPTION
    • ReturnCode.SERVICE_UNAVAILABLE
    • ReturnCode.TARGET_UNREACHABLE
    • ReturnCode.TIMEOUT
    • ReturnCode.UNAUTHENTICATED
  • ReturnReason
    • ReturnReason.CANT_FORWARD
    • ReturnReason.INTERCEPT
  • ServiceUnavailable
  • TargetCellUnreachable
• nvflare.fuel.f3.cellnet.fqcn module
  • FQCN
    • FQCN.ROOT_SERVER
    • FQCN.SEPARATOR
    • FQCN.get_parent()
    • FQCN.get_root()
    • FQCN.is_ancestor()
    • FQCN.is_parent()
    • FQCN.join()
    • FQCN.normalize()
    • FQCN.split()
    • FQCN.validate()
  • FqcnInfo
  • same_family()
• nvflare.fuel.f3.cellnet.net_agent module
  • NetAgent
    • NetAgent.add_subnet_monitor()
    • NetAgent.add_to_subnet()
    • NetAgent.change_root()
    • NetAgent.close()
    • NetAgent.delete_subnet_monitor()
    • NetAgent.get_comm_config()
    • NetAgent.get_config_vars()
    • NetAgent.get_connectors()
    • NetAgent.get_msg_stats_table()
    • NetAgent.get_peers()
    • NetAgent.get_pool_list()
    • NetAgent.get_process_info()
    • NetAgent.get_route_info()
    • NetAgent.get_url_use()
    • NetAgent.request_cells_info()
    • NetAgent.show_pool()
    • NetAgent.speed_test()
    • NetAgent.start_bulk_test()
    • NetAgent.start_route()
    • NetAgent.start_stress_test()
    • NetAgent.stop()
    • NetAgent.stop_cell()
    • NetAgent.stop_subnet()
  • SubnetMonitor
    • SubnetMonitor.member_offline()
    • SubnetMonitor.member_online()
    • SubnetMonitor.put_member_offline()
    • SubnetMonitor.put_member_online()
    • SubnetMonitor.stop_subnet()
• nvflare.fuel.f3.cellnet.net_manager module
  • NetManager
    • NetManager.get_spec()
• nvflare.fuel.f3.cellnet.utils module
  • decode_payload()
  • encode_payload()
  • format_log_message()
  • make_reply()
  • new_message()

Module contents