misha_cafex v0.0.5 Cafex.Protocol.Decoder behaviour

Kafka server response decoder implementation specification.

Summary

Types

The modules which implement the Decoder interface

The decode function in each decoder will return there own response struct

Callbacks

Decode the response message in the Kafka server response

Types

decoder ::
  Cafex.Protocol.Metadata |
  Cafex.Protocol.Produce |
  Cafex.Protocol.Fetch |
  Cafex.Protocol.Offset |
  Cafex.Protocol.GroupCoordinator |
  Cafex.Protocol.OffsetCommit |
  Cafex.Protocol.OffsetFetch |
  Cafex.Protocol.JoinGroup |
  Cafex.Protocol.SyncGroup |
  Cafex.Protocol.LeaveGroup |
  Cafex.Protocol.Heartbeat |
  Cafex.Protocol.ListGroups |
  Cafex.Protocol.DescribeGroups

The modules which implement the Decoder interface

See Cafex.Protocol

response ::
  Cafex.Protocol.Metadata.Response.t |
  Cafex.Protocol.Produce.Response.t |
  Cafex.Protocol.Fetch.Response.t |
  Cafex.Protocol.Offset.Response.t |
  Cafex.Protocol.GroupCoordinator.Response.t |
  Cafex.Protocol.OffsetCommit.Response.t |
  Cafex.Protocol.OffsetFetch.Response.t |
  Cafex.Protocol.JoinGroup.Response.t |
  Cafex.Protocol.SyncGroup.Response.t |
  Cafex.Protocol.LeaveGroup.Response.t |
  Cafex.Protocol.Heartbeat.Response.t |
  Cafex.Protocol.ListGroups.Response.t |
  Cafex.Protocol.DescribeGroups.Response.t

The decode function in each decoder will return there own response struct

See Cafex.Protocol

Callbacks

decode(binary)

Specs

decode(binary) :: response

Decode the response message in the Kafka server response