nvflare.fuel.f3.streaming.stream_const module

class StreamDataType

Bases: object

ACK = 3

CHUNK = 1

ERROR = 6

FINAL = 2

RESUME = 4

RESUME_ACK = 5

class StreamHeaderKey

Bases: object

CHANNEL = 'sm__ch'

DATA_TYPE = 'sm__dt'

ERROR_MSG = 'sm__em'

FILE_NAME = 'sm__fn'

OBJECT_INDEX = 'sm__oi'

OBJECT_STREAM_ID = 'sm__os'

OFFSET = 'sm__os'

PAYLOAD_ENCODING = 'sm__pe'

SEQUENCE = 'sm__sq'

SIZE = 'sm__sz'

STREAM_ID = 'sm__id'

STREAM_REQ_ID = 'sm__ri'

TOPIC = 'sm__tp'