nvflare.fuel.f3.message module

class AppIds[source]

Bases: object

Reserved application IDs

ALL = 0
CELL_NET = 2
DEFAULT = 1
PUB_SUB = 3
class Headers[source]

Bases: dict

DEST = '_DEST_'
JOB_ID = '_JOB_ID_'
MSG_ID = '_MSG_ID_'
TOPIC = '_TOPIC_'
class Message(headers: Headers, payload: Any)[source]

Bases: object

Construct an FCI message

add_headers(headers: dict)[source]
get_header(key: str, default=None)[source]
get_prop(key: str, default=None)[source]
remove_header(key: str)[source]
set_header(key: str, value)[source]
set_prop(key: str, value)[source]
class MessageReceiver[source]

Bases: ABC

abstract process_message(endpoint: Endpoint, connection: Connection, app_id: int, message: Message)[source]