misha_cafex

v0.0.6

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

api_key()
api_version()
error()

Functions

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

See Cafex.Protocol.Codec.encode_request/3

encode_string(data)

See Cafex.Protocol.Codec.encode_string/1

has_response?(request)

See Cafex.Protocol.Request.has_response?/1

Macros

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

Types 

api_key :: 0..16
api_version :: 0 | 1 | 2

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)