`flow.record.packer`¶

Module Contents¶

Classes¶

Functions¶

identifier_to_str

Attributes¶

`packb`
`unpackb`
`RECORD_PACK_EXT_TYPE`
`RECORD_PACK_TYPE_RECORD`
`RECORD_PACK_TYPE_DESCRIPTOR`
`RECORD_PACK_TYPE_FIELDTYPE`
`RECORD_PACK_TYPE_DATETIME`
`RECORD_PACK_TYPE_VARINT`
`RECORD_PACK_TYPE_GROUPEDRECORD`
`UTC`

flow.record.packer.packb¶

flow.record.packer.unpackb¶

flow.record.packer.RECORD_PACK_EXT_TYPE = 14¶

flow.record.packer.RECORD_PACK_TYPE_RECORD = 1¶

flow.record.packer.RECORD_PACK_TYPE_DESCRIPTOR = 2¶

flow.record.packer.RECORD_PACK_TYPE_FIELDTYPE = 3¶

flow.record.packer.RECORD_PACK_TYPE_DATETIME = 16¶

flow.record.packer.RECORD_PACK_TYPE_VARINT = 17¶

flow.record.packer.RECORD_PACK_TYPE_GROUPEDRECORD = 18¶

flow.record.packer.UTC¶

flow.record.packer.identifier_to_str(identifier: tuple[str, int] | str) → tuple[str, int] | str¶

class flow.record.packer.RecordPacker¶

EXT_TYPE = 14¶

TYPES¶

descriptors¶

on_descriptor¶

register(desc: flow.record.base.RecordDescriptor, notify: bool = False) → None¶

pack_obj(obj: Any, unversioned: bool = False) → msgpack.ExtType¶

pack(obj: Any) → bytes¶

unpack_obj(t: int, data: bytes) → Any¶

unpack(d: bytes) → Any¶