misha_cafex v0.0.6 Cafex.Protocol

This module provide encode/decode functions for common structures in Kafka protocol.

And also provide conveniences for implementing API request and the Cafex.Protocol.Request.

APIs

Summary

Types

Functions

api_key(atom)
encode_request(client_id, correlation_id, request)

See Cafex.Protocol.Codec.encode_request/3.

has_response?(request)

See Cafex.Protocol.Request.has_response?/1.

Macros

defrequest(opts \\ [])
defresponse(list)
field(name, opts \\ [], type)