summaryrefslogtreecommitdiff
path: root/kafka/protocol
Commit message (Collapse)AuthorAgeFilesLines
...
* 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 ↵Dana Powers2015-12-041-2/+4
| | | | support tell()
* 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 ↵Dana Powers2015-12-041-2/+2
| | | | encoding spec
* 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