nvflare.fuel.hci.conn module

class Connection(sock, server)

Bases: BaseContext

Object containing connection information and buffer to build and send a line with socket passed in at init.

Parameters:

• sock – sock for the connection

• server – server for the connection

append_any(data, flush=False, meta: dict | None = None)

append_command(cmd: str, flush=False)

append_dict(data: dict, flush=False, meta: dict | None = None)

append_error(data: str, flush=False, meta: dict | None = None)

append_shutdown(msg: str, flush=False)

append_string(data: str, flush=False, meta: dict | None = None)

append_success(data: str, flush=False, meta: dict | None = None)

append_table(headers: List[str], name=None) → Table

append_token(token: str, flush=False)

close()

flush()

flush_bytes(data)

update_meta(meta: dict)

receive_and_process(sock, process_json_func)

Receives and sends lines to process with process_json_func.

receive_bytes_and_process(sock, receiver)