summaryrefslogtreecommitdiff
path: root/kafka/protocol/message.py
Commit message (Expand)AuthorAgeFilesLines
* Support pickling of Structs -- _encode_self instance method needs some magicDana Powers2015-12-091-0/+1
* Return PartialMessage object in MessageSet.decode if message is truncated by ...Dana Powers2015-12-091-3/+10
* Fix BytesIO import in kafka.protocol.messageDana Powers2015-12-091-1/+3
* Handle special __init__ signature in Message decode()Dana Powers2015-12-091-0/+8
* Handle decoding partial messages in MessageSet - caused by FetchRequest max_b...Dana Powers2015-12-091-6/+24
* Add comment re bytes offset tracking in MessageSet decode()Dana Powers2015-12-041-1/+1
* Recursive repr, display all field names and values for StructsDana Powers2015-12-041-1/+5
* Use simply counting instead of buffer.tell() -- socket.makefile does not supp...Dana Powers2015-12-041-2/+4
* Rework protocol type definition: AbstractType, Schema, StructDana Powers2015-12-041-0/+67