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