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
  • Adapter
    • Adapter.call()
  • Cell
    • Cell.get_fobs_context()
    • Cell.update_fobs_context()
  • SimpleWaiter
• nvflare.fuel.f3.cellnet.cell_cipher module
  • InvalidCertChain
  • SessionKeyManager
    • SessionKeyManager.get_key()
    • SessionKeyManager.get_latest_key()
    • SessionKeyManager.key_available()
    • SessionKeyManager.key_request()
    • SessionKeyManager.process_key_response()
    • SessionKeyManager.validate_cert_chain()
  • SessionKeyUnavailable
  • SimpleCellCipher
    • SimpleCellCipher.decrypt()
    • SimpleCellCipher.encrypt()
  • get_hash()
• nvflare.fuel.f3.cellnet.connector_manager module
  • ConnectorData
    • ConnectorData.get_connection_params()
    • 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.core_cell module
  • CellAgent
    • CellAgent.get_fqcn()
  • CertificateExchanger
    • CertificateExchanger.exchange_certificate()
    • CertificateExchanger.get_certificate()
  • CoreCell
    • CoreCell.ALL_CELLS
    • CoreCell.APP_ID
    • CoreCell.ERR_TYPE_COMM
    • CoreCell.ERR_TYPE_MSG_TOO_BIG
    • CoreCell.SUB_TYPE_CHILD
    • CoreCell.SUB_TYPE_CLIENT
    • CoreCell.SUB_TYPE_NONE
    • CoreCell.add_error_handler()
    • CoreCell.add_incoming_filter()
    • CoreCell.add_incoming_reply_filter()
    • CoreCell.add_incoming_request_filter()
    • CoreCell.add_outgoing_reply_filter()
    • CoreCell.add_outgoing_request_filter()
    • CoreCell.broadcast_multi_requests()
    • CoreCell.broadcast_request()
    • CoreCell.change_server_root()
    • CoreCell.decrypt_payload()
    • CoreCell.drop_agents()
    • CoreCell.drop_connectors()
    • CoreCell.encrypt_payload()
    • CoreCell.fire_and_forget()
    • CoreCell.fire_multi_requests_and_forget()
    • CoreCell.get_fobs_context()
    • CoreCell.get_fqcn()
    • CoreCell.get_internal_listener_params()
    • CoreCell.get_internal_listener_url()
    • CoreCell.get_root_url_for_child()
    • CoreCell.get_sub_cell_names()
    • CoreCell.is_backbone_ready()
    • CoreCell.is_cell_connected()
    • CoreCell.is_cell_reachable()
    • CoreCell.is_secure()
    • CoreCell.log_error()
    • CoreCell.log_warning()
    • CoreCell.make_internal_listener()
    • CoreCell.process_message()
    • CoreCell.queue_message()
    • CoreCell.register_request_cb()
    • CoreCell.send_reply()
    • CoreCell.send_request()
    • CoreCell.set_cell_connected_cb()
    • CoreCell.set_cell_disconnected_cb()
    • CoreCell.set_message_interceptor()
    • CoreCell.start()
    • CoreCell.state_change()
    • CoreCell.stop()
    • CoreCell.update_fobs_context()
  • TargetMessage
    • TargetMessage.from_dict()
    • TargetMessage.to_dict()
  • log_messaging_error()
• nvflare.fuel.f3.cellnet.credential_manager module
  • CredentialManager
    • CredentialManager.create_request()
    • CredentialManager.decrypt()
    • CredentialManager.encrypt()
    • CredentialManager.get_ca_cert()
    • CredentialManager.get_certificate()
    • CredentialManager.get_local_cert()
    • CredentialManager.get_local_key()
    • CredentialManager.process_request()
    • CredentialManager.process_response()
    • CredentialManager.read_file()
• nvflare.fuel.f3.cellnet.defs module
  • AbortRun
  • AuthenticationError
  • CellChannel
    • CellChannel.AUX_COMMUNICATION
    • CellChannel.CLIENT_COMMAND
    • CellChannel.CLIENT_MAIN
    • CellChannel.CLIENT_SUB_WORKER_COMMAND
    • CellChannel.EDGE_REQUEST
    • CellChannel.HCI
    • CellChannel.MULTI_PROCESS_EXECUTOR
    • CellChannel.RETURN_ONLY
    • CellChannel.SERVER_COMMAND
    • CellChannel.SERVER_MAIN
    • CellChannel.SERVER_PARENT_LISTENER
    • CellChannel.SIMULATOR_RUNNER
  • CellChannelTopic
    • CellChannelTopic.Challenge
    • CellChannelTopic.EXECUTE_RESULT
    • CellChannelTopic.FIRE_EVENT
    • CellChannelTopic.GET_TASK
    • CellChannelTopic.HEART_BEAT
    • CellChannelTopic.Quit
    • CellChannelTopic.REPORT_JOB_FAILURE
    • CellChannelTopic.Register
    • CellChannelTopic.SIMULATOR_WORKER_INIT
    • CellChannelTopic.SUBMIT_RESULT
  • CellPropertyKey
    • CellPropertyKey.FQCN
  • ConnectorRequirementKey
    • ConnectorRequirementKey.HOST
    • ConnectorRequirementKey.SECURE
    • ConnectorRequirementKey.URL
  • Encoding
    • Encoding.BYTES
    • Encoding.FOBS
    • Encoding.NONE
  • IdentityChallengeKey
    • IdentityChallengeKey.CERT
    • IdentityChallengeKey.COMMON_NAME
    • IdentityChallengeKey.NONCE
    • IdentityChallengeKey.SIGNATURE
  • InvalidRequest
  • InvalidSession
  • MessageHeaderKey
    • MessageHeaderKey.CHANNEL
    • MessageHeaderKey.CLEAR_PAYLOAD_LEN
    • MessageHeaderKey.CONN_URL
    • MessageHeaderKey.DESTINATION
    • MessageHeaderKey.ENCRYPTED
    • MessageHeaderKey.ERROR
    • MessageHeaderKey.FROM_CELL
    • MessageHeaderKey.MSG_ROOT_ID
    • MessageHeaderKey.MSG_ROOT_TTL
    • MessageHeaderKey.MSG_TYPE
    • MessageHeaderKey.OPTIONAL
    • MessageHeaderKey.ORIGIN
    • MessageHeaderKey.ORIGINAL_HEADERS
    • MessageHeaderKey.PAYLOAD_ENCODING
    • MessageHeaderKey.PAYLOAD_LEN
    • MessageHeaderKey.REPLY_EXPECTED
    • MessageHeaderKey.REQ_ID
    • MessageHeaderKey.RETURN_CODE
    • MessageHeaderKey.RETURN_REASON
    • MessageHeaderKey.ROUTE
    • MessageHeaderKey.SECURE
    • MessageHeaderKey.SEND_TIME
    • MessageHeaderKey.TOPIC
    • MessageHeaderKey.TO_CELL
  • MessagePropKey
    • MessagePropKey.COMMON_NAME
    • MessagePropKey.ENDPOINT
    • MessagePropKey.FUTURES
  • 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
  • SSLConstants
    • SSLConstants.CERT
    • SSLConstants.PRIVATE_KEY
    • SSLConstants.ROOT_CERT
  • ServiceUnavailable
  • TargetCellUnreachable
• nvflare.fuel.f3.cellnet.fqcn module
  • FQCN
  • 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.registry module
  • Callback
  • Registry
    • Registry.append()
    • Registry.find()
    • Registry.set()
• nvflare.fuel.f3.cellnet.utils module
  • MsgHighWaterInfo
    • MsgHighWaterInfo.update()
  • buffer_len()
  • decode_payload()
  • encode_payload()
  • format_log_message()
  • format_size()
  • get_msg_header_value()
  • make_reply()
  • new_cell_message()
  • shorten_fqcn()
  • shorten_string()

Module contents