From 894cfec656e44f92766775baf84cfd1d2e257901 Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Sun, 12 Mar 2017 19:57:36 -0700 Subject: Derive all api classes from Request / Response base classes --- kafka/protocol/fetch.py | 18 +++++++++--------- 1 file changed, 9 insertions(+), 9 deletions(-) (limited to 'kafka/protocol/fetch.py') diff --git a/kafka/protocol/fetch.py b/kafka/protocol/fetch.py index 6a9ad5b..b441e63 100644 --- a/kafka/protocol/fetch.py +++ b/kafka/protocol/fetch.py @@ -1,11 +1,11 @@ from __future__ import absolute_import +from .api import Request, Response from .message import MessageSet -from .struct import Struct from .types import Array, Int16, Int32, Int64, Schema, String -class FetchResponse_v0(Struct): +class FetchResponse_v0(Response): API_KEY = 1 API_VERSION = 0 SCHEMA = Schema( @@ -19,7 +19,7 @@ class FetchResponse_v0(Struct): ) -class FetchResponse_v1(Struct): +class FetchResponse_v1(Response): API_KEY = 1 API_VERSION = 1 SCHEMA = Schema( @@ -34,19 +34,19 @@ class FetchResponse_v1(Struct): ) -class FetchResponse_v2(Struct): +class FetchResponse_v2(Response): API_KEY = 1 API_VERSION = 2 SCHEMA = FetchResponse_v1.SCHEMA # message format changed internally -class FetchResponse_v3(Struct): +class FetchResponse_v3(Response): API_KEY = 1 API_VERSION = 3 SCHEMA = FetchResponse_v2.SCHEMA -class FetchRequest_v0(Struct): +class FetchRequest_v0(Request): API_KEY = 1 API_VERSION = 0 RESPONSE_TYPE = FetchResponse_v0 @@ -63,21 +63,21 @@ class FetchRequest_v0(Struct): ) -class FetchRequest_v1(Struct): +class FetchRequest_v1(Request): API_KEY = 1 API_VERSION = 1 RESPONSE_TYPE = FetchResponse_v1 SCHEMA = FetchRequest_v0.SCHEMA -class FetchRequest_v2(Struct): +class FetchRequest_v2(Request): API_KEY = 1 API_VERSION = 2 RESPONSE_TYPE = FetchResponse_v2 SCHEMA = FetchRequest_v1.SCHEMA -class FetchRequest_v3(Struct): +class FetchRequest_v3(Request): API_KEY = 1 API_VERSION = 3 RESPONSE_TYPE = FetchResponse_v3 -- cgit v1.2.1