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]¶