nvflare.private.admin_defs module

class Message(topic: str, body)[source]

Bases: object

To init a Message.

Parameters:

topic – message topic
body – message body.

get_header(key, default=None)[source]

get_meta()[source]

get_ref_id(default=None)[source]

set_header(key, value)[source]

set_headers(headers: dict)[source]

set_meta(meta: dict)[source]

set_ref_id(msg_id)[source]

class MsgHeader[source]

Bases: object

META = '_meta'

REF_MSG_ID = '_refMsgId'

RETURN_CODE = '_rtnCode'

class ReturnCode[source]

Bases: object

ERROR = '_error'

OK = '_ok'

error_reply(err: str, meta: dict | None = None) → Message[source]

ok_reply(topic=None, body=None, meta: dict | None = None) → Message[source]