diff options
| author | Dana Powers <dana.powers@gmail.com> | 2015-03-29 15:43:51 -0700 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2015-03-29 15:43:51 -0700 |
| commit | 1dd7b17788b229345559f2817745282ebdb6c44e (patch) | |
| tree | d6d6f8c0b0e0b46d503b870fff543ac7abfe9b97 | |
| parent | d02276eb2b9cee77672b95a7a78e9fe9103d58b5 (diff) | |
| parent | 83cee06a33ec822d747b3259f859179c63c5f39a (diff) | |
| download | kafka-python-1dd7b17788b229345559f2817745282ebdb6c44e.tar.gz | |
Merge pull request #338 from dpkp/structs_reorg
Fixup indentation in kafka/common.py; add links to protocol definitions
| -rw-r--r-- | kafka/common.py | 49 |
1 files changed, 26 insertions, 23 deletions
diff --git a/kafka/common.py b/kafka/common.py index f40c9fa..8207bec 100644 --- a/kafka/common.py +++ b/kafka/common.py @@ -6,43 +6,46 @@ from collections import namedtuple # Structs # ############### -# Request payloads -ProduceRequest = namedtuple("ProduceRequest", - ["topic", "partition", "messages"]) - -FetchRequest = namedtuple("FetchRequest", - ["topic", "partition", "offset", "max_bytes"]) - -OffsetRequest = namedtuple("OffsetRequest", - ["topic", "partition", "time", "max_offsets"]) - -OffsetCommitRequest = namedtuple("OffsetCommitRequest", - ["topic", "partition", "offset", "metadata"]) - +# https://cwiki.apache.org/confluence/display/KAFKA/A+Guide+To+The+Kafka+Protocol#AGuideToTheKafkaProtocol-MetadataAPI MetadataRequest = namedtuple("MetadataRequest", ["topics"]) -OffsetFetchRequest = namedtuple("OffsetFetchRequest", ["topic", "partition"]) - MetadataResponse = namedtuple("MetadataResponse", ["brokers", "topics"]) -# Response payloads +# https://cwiki.apache.org/confluence/display/KAFKA/A+Guide+To+The+Kafka+Protocol#AGuideToTheKafkaProtocol-ProduceAPI +ProduceRequest = namedtuple("ProduceRequest", + ["topic", "partition", "messages"]) + ProduceResponse = namedtuple("ProduceResponse", - ["topic", "partition", "error", "offset"]) + ["topic", "partition", "error", "offset"]) + +# https://cwiki.apache.org/confluence/display/KAFKA/A+Guide+To+The+Kafka+Protocol#AGuideToTheKafkaProtocol-FetchAPI +FetchRequest = namedtuple("FetchRequest", + ["topic", "partition", "offset", "max_bytes"]) -FetchResponse = namedtuple("FetchResponse", ["topic", "partition", "error", - "highwaterMark", "messages"]) +FetchResponse = namedtuple("FetchResponse", + ["topic", "partition", "error", "highwaterMark", "messages"]) + +# https://cwiki.apache.org/confluence/display/KAFKA/A+Guide+To+The+Kafka+Protocol#AGuideToTheKafkaProtocol-OffsetAPI +OffsetRequest = namedtuple("OffsetRequest", + ["topic", "partition", "time", "max_offsets"]) OffsetResponse = namedtuple("OffsetResponse", - ["topic", "partition", "error", "offsets"]) + ["topic", "partition", "error", "offsets"]) + +# https://cwiki.apache.org/confluence/display/KAFKA/A+Guide+To+The+Kafka+Protocol#AGuideToTheKafkaProtocol-OffsetCommit/FetchAPI +OffsetCommitRequest = namedtuple("OffsetCommitRequest", + ["topic", "partition", "offset", "metadata"]) OffsetCommitResponse = namedtuple("OffsetCommitResponse", - ["topic", "partition", "error"]) + ["topic", "partition", "error"]) + +OffsetFetchRequest = namedtuple("OffsetFetchRequest", + ["topic", "partition"]) OffsetFetchResponse = namedtuple("OffsetFetchResponse", - ["topic", "partition", "offset", - "metadata", "error"]) + ["topic", "partition", "offset", "metadata", "error"]) |