summaryrefslogtreecommitdiff
path: root/kafka/protocol
Commit message (Expand)AuthorAgeFilesLines
...
* Add pylint hints to AbstractType because we cant mark a classmethod as abstractDana Powers2015-12-101-2/+2
* Handle python3 in kafka.protocol.pickleDana Powers2015-12-101-2/+6
* Convert OffsetCommit and OffsetFetch protocol encode/decodeDana Powers2015-12-101-82/+46
* Change KafkaProtocol to encode/decode Structs, not bytesDana Powers2015-12-091-246/+106
* Support pickling of Structs -- _encode_self instance method needs some magicDana Powers2015-12-092-0/+26
* Return PartialMessage object in MessageSet.decode if message is truncated by ...Dana Powers2015-12-091-3/+10
* Fallback to simple repr() in Schema.repr()Dana Powers2015-12-091-7/+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
* few small cleanupsZack Dever2015-12-042-7/+1
* administration api schemasZack Dever2015-12-041-0/+44
* group membership api schemasZack Dever2015-12-041-0/+108
* 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-044-5/+27
* Use simply counting instead of buffer.tell() -- socket.makefile does not supp...Dana Powers2015-12-041-2/+4
* Add simple BrokerConnection class; add request.RESPONSE_TYPE class varsDana Powers2015-12-045-58/+65
* Rework protocol type definition: AbstractType, Schema, StructDana Powers2015-12-0410-371/+461
* Fix __init__ legacy relative module importDana Powers2015-12-041-1/+1
* Switch crc32 back to signed integer -- this is consistent with protocol encod...Dana Powers2015-12-041-2/+2
* Fix tests broken by legacy module moveDana Powers2015-12-041-0/+2
* Move ProduceRequest to kafka.protocol.produceDana Powers2015-12-042-54/+59
* Basic 0.8 Request protocol classes, with encoding onlyDana Powers2015-12-041-0/+355
* Add base api type classes w/ encoders in kafka.protocol.typesDana Powers2015-12-041-0/+55
* Rename kafka.protocol -> kafka.protocol.legacyDana Powers2015-12-042-0/+652