diff options
| author | Dana Powers <dana.powers@gmail.com> | 2017-03-12 19:57:36 -0700 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2017-03-13 11:16:18 -0700 |
| commit | 894cfec656e44f92766775baf84cfd1d2e257901 (patch) | |
| tree | 541b9074d0ea4aa67dc5f64904f7ebd3f44c2549 /kafka/protocol/metadata.py | |
| parent | 899f11730db5f209c03cfad20111ec131ee4c70b (diff) | |
| download | kafka-python-request_response_classes.tar.gz | |
Derive all api classes from Request / Response base classesrequest_response_classes
Diffstat (limited to 'kafka/protocol/metadata.py')
| -rw-r--r-- | kafka/protocol/metadata.py | 14 |
1 files changed, 7 insertions, 7 deletions
diff --git a/kafka/protocol/metadata.py b/kafka/protocol/metadata.py index e017c59..907ec25 100644 --- a/kafka/protocol/metadata.py +++ b/kafka/protocol/metadata.py @@ -1,10 +1,10 @@ from __future__ import absolute_import -from .struct import Struct +from .api import Request, Response from .types import Array, Boolean, Int16, Int32, Schema, String -class MetadataResponse_v0(Struct): +class MetadataResponse_v0(Response): API_KEY = 3 API_VERSION = 0 SCHEMA = Schema( @@ -24,7 +24,7 @@ class MetadataResponse_v0(Struct): ) -class MetadataResponse_v1(Struct): +class MetadataResponse_v1(Response): API_KEY = 3 API_VERSION = 1 SCHEMA = Schema( @@ -47,7 +47,7 @@ class MetadataResponse_v1(Struct): ) -class MetadataResponse_v2(Struct): +class MetadataResponse_v2(Response): API_KEY = 3 API_VERSION = 2 SCHEMA = Schema( @@ -71,7 +71,7 @@ class MetadataResponse_v2(Struct): ) -class MetadataRequest_v0(Struct): +class MetadataRequest_v0(Request): API_KEY = 3 API_VERSION = 0 RESPONSE_TYPE = MetadataResponse_v0 @@ -81,7 +81,7 @@ class MetadataRequest_v0(Struct): ALL_TOPICS = None # Empty Array (len 0) for topics returns all topics -class MetadataRequest_v1(Struct): +class MetadataRequest_v1(Request): API_KEY = 3 API_VERSION = 1 RESPONSE_TYPE = MetadataResponse_v1 @@ -90,7 +90,7 @@ class MetadataRequest_v1(Struct): NO_TOPICS = None # Empty array (len 0) for topics returns no topics -class MetadataRequest_v2(Struct): +class MetadataRequest_v2(Request): API_KEY = 3 API_VERSION = 2 RESPONSE_TYPE = MetadataResponse_v2 |