nvflare.fuel.f3.sfm.sfm_endpoint module

class SfmEndpoint(endpoint: Endpoint)[source]

Bases: object

An endpoint wrapper to keep SFM internal data

add_connection(sfm_conn: SfmConnection)[source]
get_connection(stream_id: int) → SfmConnection | None[source]
next_stream_id() → int[source]

Get next stream_id for the endpoint stream_id is used to assemble fragmented data

remove_connection(sfm_conn: SfmConnection)[source]