diff options
| author | Dana Powers <dana.powers@gmail.com> | 2017-03-14 13:34:37 -0700 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2017-03-14 13:34:37 -0700 |
| commit | 65ba8822b10e6f8a3ba4e9a6b0a1e6f9b785c18e (patch) | |
| tree | c5b7144b04c9238ae459d80339f27b6af33b5a5c /kafka/protocol/group.py | |
| parent | a00f9ead161e8b05ac953b460950e42fa0e0b7d6 (diff) | |
| download | kafka-python-65ba8822b10e6f8a3ba4e9a6b0a1e6f9b785c18e.tar.gz | |
Derive all api classes from Request / Response base classes (#1030)
Diffstat (limited to 'kafka/protocol/group.py')
| -rw-r--r-- | kafka/protocol/group.py | 21 |
1 files changed, 11 insertions, 10 deletions
diff --git a/kafka/protocol/group.py b/kafka/protocol/group.py index 0e0b70e..5cab754 100644 --- a/kafka/protocol/group.py +++ b/kafka/protocol/group.py @@ -1,10 +1,11 @@ from __future__ import absolute_import +from .api import Request, Response from .struct import Struct from .types import Array, Bytes, Int16, Int32, Schema, String -class JoinGroupResponse_v0(Struct): +class JoinGroupResponse_v0(Response): API_KEY = 11 API_VERSION = 0 SCHEMA = Schema( @@ -19,13 +20,13 @@ class JoinGroupResponse_v0(Struct): ) -class JoinGroupResponse_v1(Struct): +class JoinGroupResponse_v1(Response): API_KEY = 11 API_VERSION = 1 SCHEMA = JoinGroupResponse_v0.SCHEMA -class JoinGroupRequest_v0(Struct): +class JoinGroupRequest_v0(Request): API_KEY = 11 API_VERSION = 0 RESPONSE_TYPE = JoinGroupResponse_v0 @@ -41,7 +42,7 @@ class JoinGroupRequest_v0(Struct): UNKNOWN_MEMBER_ID = '' -class JoinGroupRequest_v1(Struct): +class JoinGroupRequest_v1(Request): API_KEY = 11 API_VERSION = 1 RESPONSE_TYPE = JoinGroupResponse_v1 @@ -70,7 +71,7 @@ class ProtocolMetadata(Struct): ) -class SyncGroupResponse_v0(Struct): +class SyncGroupResponse_v0(Response): API_KEY = 14 API_VERSION = 0 SCHEMA = Schema( @@ -79,7 +80,7 @@ class SyncGroupResponse_v0(Struct): ) -class SyncGroupRequest_v0(Struct): +class SyncGroupRequest_v0(Request): API_KEY = 14 API_VERSION = 0 RESPONSE_TYPE = SyncGroupResponse_v0 @@ -107,7 +108,7 @@ class MemberAssignment(Struct): ) -class HeartbeatResponse_v0(Struct): +class HeartbeatResponse_v0(Response): API_KEY = 12 API_VERSION = 0 SCHEMA = Schema( @@ -115,7 +116,7 @@ class HeartbeatResponse_v0(Struct): ) -class HeartbeatRequest_v0(Struct): +class HeartbeatRequest_v0(Request): API_KEY = 12 API_VERSION = 0 RESPONSE_TYPE = HeartbeatResponse_v0 @@ -130,7 +131,7 @@ HeartbeatRequest = [HeartbeatRequest_v0] HeartbeatResponse = [HeartbeatResponse_v0] -class LeaveGroupResponse_v0(Struct): +class LeaveGroupResponse_v0(Response): API_KEY = 13 API_VERSION = 0 SCHEMA = Schema( @@ -138,7 +139,7 @@ class LeaveGroupResponse_v0(Struct): ) -class LeaveGroupRequest_v0(Struct): +class LeaveGroupRequest_v0(Request): API_KEY = 13 API_VERSION = 0 RESPONSE_TYPE = LeaveGroupResponse_v0 |