nvflare.fuel.f3.message module

class AppIds[source]

Bases: object

Reserved application IDs

ALL = 0

CELL_NET = 2

DEFAULT = 1

PUB_SUB = 3

class Message(headers: dict | None = None, payload: Any | None = None)[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]