Search documentation of kayrock
kayrock
▼
Project version
v0.2.0
v0.2.0-rc.1
v0.1.15
v0.1.14
v0.1.12
v0.1.11
v0.1.10
v0.1.9
v0.1.8
v0.1.7
v0.1.6
v0.1.5
v0.1.4
v0.1.3
v0.1.2
v0.1.1
v0.1.0
Pages
Modules
Mix
Tasks
API Reference
Modules
Mix Tasks
Kayrock
Basic architecture and usage
Messages Compression
Relationship to other libraries
Testing
Kayrock
Summary
Types
api_response/0
api_version/0
broker_pid/0
client_pid/0
node_id/0
node_selector/0
partition_id/0
topic_name/0
Functions
api_versions/3
broker_sync_call/2
client_call/3
create_topics/5
delete_topics/5
fetch/4
produce/6
topics_metadata/2
Kayrock.AddOffsetsToTxn
Summary
Types
request_t/0
response_t/0
Functions
deserialize/2
get_request_struct/1
max_vsn/0
min_vsn/0
Kayrock.AddOffsetsToTxn.V0.Request
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
response_deserializer/0
schema/0
serialize/1
Kayrock.AddOffsetsToTxn.V0.Response
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
deserialize/1
schema/0
Kayrock.AddPartitionsToTxn
Summary
Types
request_t/0
response_t/0
Functions
deserialize/2
get_request_struct/1
max_vsn/0
min_vsn/0
Kayrock.AddPartitionsToTxn.V0.Request
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
response_deserializer/0
schema/0
serialize/1
Kayrock.AddPartitionsToTxn.V0.Response
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
deserialize/1
schema/0
Kayrock.AlterConfigs
Summary
Types
request_t/0
response_t/0
Functions
deserialize/2
get_request_struct/1
max_vsn/0
min_vsn/0
Kayrock.AlterConfigs.V0.Request
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
response_deserializer/0
schema/0
serialize/1
Kayrock.AlterConfigs.V0.Response
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
deserialize/1
schema/0
Kayrock.AlterReplicaLogDirs
Summary
Types
request_t/0
response_t/0
Functions
deserialize/2
get_request_struct/1
max_vsn/0
min_vsn/0
Kayrock.AlterReplicaLogDirs.V0.Request
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
response_deserializer/0
schema/0
serialize/1
Kayrock.AlterReplicaLogDirs.V0.Response
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
deserialize/1
schema/0
Kayrock.ApiVersions
Summary
Types
request_t/0
response_t/0
Functions
deserialize/2
get_request_struct/1
max_vsn/0
min_vsn/0
Kayrock.ApiVersions.V0.Request
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
response_deserializer/0
schema/0
serialize/1
Kayrock.ApiVersions.V0.Response
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
deserialize/1
schema/0
Kayrock.ApiVersions.V1.Request
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
response_deserializer/0
schema/0
serialize/1
Kayrock.ApiVersions.V1.Response
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
deserialize/1
schema/0
Kayrock.BrokerConnection
Summary
Functions
close/1
recv/2
send/2
start_link/4
stop/1
Kayrock.Client
Summary
Functions
broker_call/3
child_spec/1
cluster_metadata/1
start_link/2
stop/1
Kayrock.Client.ClusterMetadata
Summary
Types
node_select_error/0
t/0
Functions
broker_by_node_id/2
from_metadata_v1_response/1
get_and_update_broker/3
known_topics/1
merge_brokers/2
select_node/2
Kayrock.Compression
Summary
Types
attribute_t/0
compression_type_t/0
Functions
compress/2
decompress/2
snappy_decompress_chunk/2
Kayrock.Convenience
Summary
Functions
get_partition_leaders/2
partition_last_offset/3
partitions_last_offset/3
topic_exists?/2
topic_last_offsets/2
Kayrock.CreateAcls
Summary
Types
request_t/0
response_t/0
Functions
deserialize/2
get_request_struct/1
max_vsn/0
min_vsn/0
Kayrock.CreateAcls.V0.Request
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
response_deserializer/0
schema/0
serialize/1
Kayrock.CreateAcls.V0.Response
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
deserialize/1
schema/0
Kayrock.CreateDelegationToken
Summary
Types
request_t/0
response_t/0
Functions
deserialize/2
get_request_struct/1
max_vsn/0
min_vsn/0
Kayrock.CreateDelegationToken.V0.Request
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
response_deserializer/0
schema/0
serialize/1
Kayrock.CreateDelegationToken.V0.Response
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
deserialize/1
schema/0
Kayrock.CreatePartitions
Summary
Types
request_t/0
response_t/0
Functions
deserialize/2
get_request_struct/1
max_vsn/0
min_vsn/0
Kayrock.CreatePartitions.V0.Request
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
response_deserializer/0
schema/0
serialize/1
Kayrock.CreatePartitions.V0.Response
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
deserialize/1
schema/0
Kayrock.CreateTopics
Summary
Types
request_t/0
response_t/0
Functions
deserialize/2
get_request_struct/1
max_vsn/0
min_vsn/0
Kayrock.CreateTopics.V0.Request
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
response_deserializer/0
schema/0
serialize/1
Kayrock.CreateTopics.V0.Response
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
deserialize/1
schema/0
Kayrock.CreateTopics.V1.Request
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
response_deserializer/0
schema/0
serialize/1
Kayrock.CreateTopics.V1.Response
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
deserialize/1
schema/0
Kayrock.CreateTopics.V2.Request
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
response_deserializer/0
schema/0
serialize/1
Kayrock.CreateTopics.V2.Response
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
deserialize/1
schema/0
Kayrock.DeleteAcls
Summary
Types
request_t/0
response_t/0
Functions
deserialize/2
get_request_struct/1
max_vsn/0
min_vsn/0
Kayrock.DeleteAcls.V0.Request
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
response_deserializer/0
schema/0
serialize/1
Kayrock.DeleteAcls.V0.Response
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
deserialize/1
schema/0
Kayrock.DeleteGroups
Summary
Types
request_t/0
response_t/0
Functions
deserialize/2
get_request_struct/1
max_vsn/0
min_vsn/0
Kayrock.DeleteGroups.V0.Request
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
response_deserializer/0
schema/0
serialize/1
Kayrock.DeleteGroups.V0.Response
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
deserialize/1
schema/0
Kayrock.DeleteRecords
Summary
Types
request_t/0
response_t/0
Functions
deserialize/2
get_request_struct/1
max_vsn/0
min_vsn/0
Kayrock.DeleteRecords.V0.Request
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
response_deserializer/0
schema/0
serialize/1
Kayrock.DeleteRecords.V0.Response
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
deserialize/1
schema/0
Kayrock.DeleteTopics
Summary
Types
request_t/0
response_t/0
Functions
deserialize/2
get_request_struct/1
max_vsn/0
min_vsn/0
Kayrock.DeleteTopics.V0.Request
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
response_deserializer/0
schema/0
serialize/1
Kayrock.DeleteTopics.V0.Response
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
deserialize/1
schema/0
Kayrock.DeleteTopics.V1.Request
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
response_deserializer/0
schema/0
serialize/1
Kayrock.DeleteTopics.V1.Response
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
deserialize/1
schema/0
Kayrock.DescribeAcls
Summary
Types
request_t/0
response_t/0
Functions
deserialize/2
get_request_struct/1
max_vsn/0
min_vsn/0
Kayrock.DescribeAcls.V0.Request
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
response_deserializer/0
schema/0
serialize/1
Kayrock.DescribeAcls.V0.Response
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
deserialize/1
schema/0
Kayrock.DescribeConfigs
Summary
Types
request_t/0
response_t/0
Functions
deserialize/2
get_request_struct/1
max_vsn/0
min_vsn/0
Kayrock.DescribeConfigs.V0.Request
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
response_deserializer/0
schema/0
serialize/1
Kayrock.DescribeConfigs.V0.Response
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
deserialize/1
schema/0
Kayrock.DescribeConfigs.V1.Request
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
response_deserializer/0
schema/0
serialize/1
Kayrock.DescribeConfigs.V1.Response
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
deserialize/1
schema/0
Kayrock.DescribeDelegationToken
Summary
Types
request_t/0
response_t/0
Functions
deserialize/2
get_request_struct/1
max_vsn/0
min_vsn/0
Kayrock.DescribeDelegationToken.V0.Request
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
response_deserializer/0
schema/0
serialize/1
Kayrock.DescribeDelegationToken.V0.Response
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
deserialize/1
schema/0
Kayrock.DescribeGroups
Summary
Types
request_t/0
response_t/0
Functions
deserialize/2
get_request_struct/1
max_vsn/0
min_vsn/0
Kayrock.DescribeGroups.V0.Request
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
response_deserializer/0
schema/0
serialize/1
Kayrock.DescribeGroups.V0.Response
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
deserialize/1
schema/0
Kayrock.DescribeGroups.V1.Request
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
response_deserializer/0
schema/0
serialize/1
Kayrock.DescribeGroups.V1.Response
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
deserialize/1
schema/0
Kayrock.DescribeLogDirs
Summary
Types
request_t/0
response_t/0
Functions
deserialize/2
get_request_struct/1
max_vsn/0
min_vsn/0
Kayrock.DescribeLogDirs.V0.Request
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
response_deserializer/0
schema/0
serialize/1
Kayrock.DescribeLogDirs.V0.Response
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
deserialize/1
schema/0
Kayrock.Deserialize
Summary
Functions
deserialize/2
deserialize_array/2
primitive_types/0
Kayrock.EndTxn
Summary
Types
request_t/0
response_t/0
Functions
deserialize/2
get_request_struct/1
max_vsn/0
min_vsn/0
Kayrock.EndTxn.V0.Request
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
response_deserializer/0
schema/0
serialize/1
Kayrock.EndTxn.V0.Response
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
deserialize/1
schema/0
Kayrock.ErrorCode
Summary
Types
error_atom/0
error_code/0
Functions
atom_to_code/1
atom_to_code!/1
code_to_atom/1
code_to_atom!/1
unknown_topic/0
Kayrock.ExpireDelegationToken
Summary
Types
request_t/0
response_t/0
Functions
deserialize/2
get_request_struct/1
max_vsn/0
min_vsn/0
Kayrock.ExpireDelegationToken.V0.Request
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
response_deserializer/0
schema/0
serialize/1
Kayrock.ExpireDelegationToken.V0.Response
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
deserialize/1
schema/0
Kayrock.Fetch
Summary
Types
request_t/0
response_t/0
Functions
deserialize/2
get_request_struct/1
max_vsn/0
min_vsn/0
Kayrock.Fetch.V0.Request
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
response_deserializer/0
schema/0
serialize/1
Kayrock.Fetch.V0.Response
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
deserialize/1
schema/0
Kayrock.Fetch.V1.Request
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
response_deserializer/0
schema/0
serialize/1
Kayrock.Fetch.V1.Response
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
deserialize/1
schema/0
Kayrock.Fetch.V2.Request
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
response_deserializer/0
schema/0
serialize/1
Kayrock.Fetch.V2.Response
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
deserialize/1
schema/0
Kayrock.Fetch.V3.Request
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
response_deserializer/0
schema/0
serialize/1
Kayrock.Fetch.V3.Response
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
deserialize/1
schema/0
Kayrock.Fetch.V4.Request
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
response_deserializer/0
schema/0
serialize/1
Kayrock.Fetch.V4.Response
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
deserialize/1
schema/0
Kayrock.Fetch.V5.Request
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
response_deserializer/0
schema/0
serialize/1
Kayrock.Fetch.V5.Response
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
deserialize/1
schema/0
Kayrock.Fetch.V6.Request
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
response_deserializer/0
schema/0
serialize/1
Kayrock.Fetch.V6.Response
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
deserialize/1
schema/0
Kayrock.Fetch.V7.Request
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
response_deserializer/0
schema/0
serialize/1
Kayrock.Fetch.V7.Response
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
deserialize/1
schema/0
Kayrock.FindCoordinator
Summary
Types
request_t/0
response_t/0
Functions
deserialize/2
get_request_struct/1
max_vsn/0
min_vsn/0
Kayrock.FindCoordinator.V0.Request
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
response_deserializer/0
schema/0
serialize/1
Kayrock.FindCoordinator.V0.Response
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
deserialize/1
schema/0
Kayrock.FindCoordinator.V1.Request
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
response_deserializer/0
schema/0
serialize/1
Kayrock.FindCoordinator.V1.Response
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
deserialize/1
schema/0
Kayrock.Generate
Summary
Functions
build_all/2
build_modules/3
describe_type/3
generate_field_deserializer/3
generate_request_struct/5
generate_response_struct/4
generate_schema_metadata/1
generate_serializer/1
make_request_getter/1
make_request_module/3
make_response_deserializer/1
make_response_module/3
make_types/3
Kayrock.GroupProtocolMetadata
Summary
Functions
serialize/1
Kayrock.Heartbeat
Summary
Types
request_t/0
response_t/0
Functions
deserialize/2
get_request_struct/1
max_vsn/0
min_vsn/0
Kayrock.Heartbeat.V0.Request
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
response_deserializer/0
schema/0
serialize/1
Kayrock.Heartbeat.V0.Response
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
deserialize/1
schema/0
Kayrock.Heartbeat.V1.Request
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
response_deserializer/0
schema/0
serialize/1
Kayrock.Heartbeat.V1.Response
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
deserialize/1
schema/0
Kayrock.InitProducerId
Summary
Types
request_t/0
response_t/0
Functions
deserialize/2
get_request_struct/1
max_vsn/0
min_vsn/0
Kayrock.InitProducerId.V0.Request
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
response_deserializer/0
schema/0
serialize/1
Kayrock.InitProducerId.V0.Response
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
deserialize/1
schema/0
Kayrock.JoinGroup
Summary
Types
request_t/0
response_t/0
Functions
deserialize/2
get_request_struct/1
max_vsn/0
min_vsn/0
Kayrock.JoinGroup.V0.Request
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
response_deserializer/0
schema/0
serialize/1
Kayrock.JoinGroup.V0.Response
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
deserialize/1
schema/0
Kayrock.JoinGroup.V1.Request
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
response_deserializer/0
schema/0
serialize/1
Kayrock.JoinGroup.V1.Response
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
deserialize/1
schema/0
Kayrock.JoinGroup.V2.Request
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
response_deserializer/0
schema/0
serialize/1
Kayrock.JoinGroup.V2.Response
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
deserialize/1
schema/0
Kayrock.LeaveGroup
Summary
Types
request_t/0
response_t/0
Functions
deserialize/2
get_request_struct/1
max_vsn/0
min_vsn/0
Kayrock.LeaveGroup.V0.Request
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
response_deserializer/0
schema/0
serialize/1
Kayrock.LeaveGroup.V0.Response
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
deserialize/1
schema/0
Kayrock.LeaveGroup.V1.Request
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
response_deserializer/0
schema/0
serialize/1
Kayrock.LeaveGroup.V1.Response
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
deserialize/1
schema/0
Kayrock.ListGroups
Summary
Types
request_t/0
response_t/0
Functions
deserialize/2
get_request_struct/1
max_vsn/0
min_vsn/0
Kayrock.ListGroups.V0.Request
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
response_deserializer/0
schema/0
serialize/1
Kayrock.ListGroups.V0.Response
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
deserialize/1
schema/0
Kayrock.ListGroups.V1.Request
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
response_deserializer/0
schema/0
serialize/1
Kayrock.ListGroups.V1.Response
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
deserialize/1
schema/0
Kayrock.ListOffsets
Summary
Types
request_t/0
response_t/0
Functions
deserialize/2
get_request_struct/1
max_vsn/0
min_vsn/0
Kayrock.ListOffsets.V0.Request
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
response_deserializer/0
schema/0
serialize/1
Kayrock.ListOffsets.V0.Response
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
deserialize/1
schema/0
Kayrock.ListOffsets.V1.Request
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
response_deserializer/0
schema/0
serialize/1
Kayrock.ListOffsets.V1.Response
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
deserialize/1
schema/0
Kayrock.ListOffsets.V2.Request
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
response_deserializer/0
schema/0
serialize/1
Kayrock.ListOffsets.V2.Response
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
deserialize/1
schema/0
Kayrock.Macros
Summary
Functions
earliest_offset/0
full_isr_acks/0
latest_offset/0
leader_ack/0
no_acks/0
no_error/0
Kayrock.MemberAssignment
Summary
Types
t/0
Functions
deserialize/1
serialize/1
Kayrock.MemberAssignment.PartitionAssignment
Summary
Types
t/0
Kayrock.MessageSet
Summary
Types
t/0
Functions
deserialize/1
deserialize/2
serialize/1
Kayrock.MessageSet.Message
Summary
Types
t/0
Kayrock.Metadata
Summary
Types
request_t/0
response_t/0
Functions
deserialize/2
get_request_struct/1
max_vsn/0
min_vsn/0
Kayrock.Metadata.V0.Request
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
response_deserializer/0
schema/0
serialize/1
Kayrock.Metadata.V0.Response
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
deserialize/1
schema/0
Kayrock.Metadata.V1.Request
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
response_deserializer/0
schema/0
serialize/1
Kayrock.Metadata.V1.Response
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
deserialize/1
schema/0
Kayrock.Metadata.V2.Request
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
response_deserializer/0
schema/0
serialize/1
Kayrock.Metadata.V2.Response
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
deserialize/1
schema/0
Kayrock.Metadata.V3.Request
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
response_deserializer/0
schema/0
serialize/1
Kayrock.Metadata.V3.Response
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
deserialize/1
schema/0
Kayrock.Metadata.V4.Request
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
response_deserializer/0
schema/0
serialize/1
Kayrock.Metadata.V4.Response
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
deserialize/1
schema/0
Kayrock.Metadata.V5.Request
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
response_deserializer/0
schema/0
serialize/1
Kayrock.Metadata.V5.Response
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
deserialize/1
schema/0
Kayrock.OffsetCommit
Summary
Types
request_t/0
response_t/0
Functions
deserialize/2
get_request_struct/1
max_vsn/0
min_vsn/0
Kayrock.OffsetCommit.V0.Request
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
response_deserializer/0
schema/0
serialize/1
Kayrock.OffsetCommit.V0.Response
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
deserialize/1
schema/0
Kayrock.OffsetCommit.V1.Request
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
response_deserializer/0
schema/0
serialize/1
Kayrock.OffsetCommit.V1.Response
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
deserialize/1
schema/0
Kayrock.OffsetCommit.V2.Request
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
response_deserializer/0
schema/0
serialize/1
Kayrock.OffsetCommit.V2.Response
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
deserialize/1
schema/0
Kayrock.OffsetCommit.V3.Request
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
response_deserializer/0
schema/0
serialize/1
Kayrock.OffsetCommit.V3.Response
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
deserialize/1
schema/0
Kayrock.OffsetFetch
Summary
Types
request_t/0
response_t/0
Functions
deserialize/2
get_request_struct/1
max_vsn/0
min_vsn/0
Kayrock.OffsetFetch.V0.Request
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
response_deserializer/0
schema/0
serialize/1
Kayrock.OffsetFetch.V0.Response
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
deserialize/1
schema/0
Kayrock.OffsetFetch.V1.Request
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
response_deserializer/0
schema/0
serialize/1
Kayrock.OffsetFetch.V1.Response
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
deserialize/1
schema/0
Kayrock.OffsetFetch.V2.Request
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
response_deserializer/0
schema/0
serialize/1
Kayrock.OffsetFetch.V2.Response
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
deserialize/1
schema/0
Kayrock.OffsetFetch.V3.Request
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
response_deserializer/0
schema/0
serialize/1
Kayrock.OffsetFetch.V3.Response
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
deserialize/1
schema/0
Kayrock.Produce
Summary
Types
request_t/0
response_t/0
Functions
deserialize/2
get_request_struct/1
max_vsn/0
min_vsn/0
Kayrock.Produce.V0.Request
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
response_deserializer/0
schema/0
serialize/1
Kayrock.Produce.V0.Response
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
deserialize/1
schema/0
Kayrock.Produce.V1.Request
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
response_deserializer/0
schema/0
serialize/1
Kayrock.Produce.V1.Response
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
deserialize/1
schema/0
Kayrock.Produce.V2.Request
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
response_deserializer/0
schema/0
serialize/1
Kayrock.Produce.V2.Response
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
deserialize/1
schema/0
Kayrock.Produce.V3.Request
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
response_deserializer/0
schema/0
serialize/1
Kayrock.Produce.V3.Response
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
deserialize/1
schema/0
Kayrock.Produce.V4.Request
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
response_deserializer/0
schema/0
serialize/1
Kayrock.Produce.V4.Response
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
deserialize/1
schema/0
Kayrock.Produce.V5.Request
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
response_deserializer/0
schema/0
serialize/1
Kayrock.Produce.V5.Response
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
deserialize/1
schema/0
Kayrock.RecordBatch
Summary
Types
t/0
Functions
deserialize/1
deserialize/2
from_binary_list/2
serialize/1
Kayrock.RecordBatch.Record
Summary
Types
t/0
Kayrock.RecordBatch.RecordHeader
Summary
Types
t/0
Kayrock.RenewDelegationToken
Summary
Types
request_t/0
response_t/0
Functions
deserialize/2
get_request_struct/1
max_vsn/0
min_vsn/0
Kayrock.RenewDelegationToken.V0.Request
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
response_deserializer/0
schema/0
serialize/1
Kayrock.RenewDelegationToken.V0.Response
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
deserialize/1
schema/0
Kayrock.Request
Summary
Types
t/0
Functions
api_vsn/1
response_deserializer/1
serialize/1
Kayrock.SaslAuthenticate
Summary
Types
request_t/0
response_t/0
Functions
deserialize/2
get_request_struct/1
max_vsn/0
min_vsn/0
Kayrock.SaslAuthenticate.V0.Request
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
response_deserializer/0
schema/0
serialize/1
Kayrock.SaslAuthenticate.V0.Response
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
deserialize/1
schema/0
Kayrock.SaslHandshake
Summary
Types
request_t/0
response_t/0
Functions
deserialize/2
get_request_struct/1
max_vsn/0
min_vsn/0
Kayrock.SaslHandshake.V0.Request
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
response_deserializer/0
schema/0
serialize/1
Kayrock.SaslHandshake.V0.Response
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
deserialize/1
schema/0
Kayrock.SaslHandshake.V1.Request
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
response_deserializer/0
schema/0
serialize/1
Kayrock.SaslHandshake.V1.Response
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
deserialize/1
schema/0
Kayrock.Serialize
Summary
Functions
primitive_types/0
serialize/2
serialize_array/2
Kayrock.Socket
Summary
Types
t/0
Functions
close/1
create/4
info/1
open?/1
recv/2
recv/3
send/2
setopts/2
Kayrock.SyncGroup
Summary
Types
request_t/0
response_t/0
Functions
deserialize/2
get_request_struct/1
max_vsn/0
min_vsn/0
Kayrock.SyncGroup.V0.Request
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
response_deserializer/0
schema/0
serialize/1
Kayrock.SyncGroup.V0.Response
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
deserialize/1
schema/0
Kayrock.SyncGroup.V1.Request
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
response_deserializer/0
schema/0
serialize/1
Kayrock.SyncGroup.V1.Response
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
deserialize/1
schema/0
Kayrock.TxnOffsetCommit
Summary
Types
request_t/0
response_t/0
Functions
deserialize/2
get_request_struct/1
max_vsn/0
min_vsn/0
Kayrock.TxnOffsetCommit.V0.Request
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
response_deserializer/0
schema/0
serialize/1
Kayrock.TxnOffsetCommit.V0.Response
Summary
Types
t/0
Functions
api_key/0
api_vsn/0
deserialize/1
schema/0
Exceptions
Kayrock.ErrorCode.InvalidAtomException
Kayrock.ErrorCode.InvalidErrorCodeException
Kayrock.InvalidRequestError
mix gen.kafka_protocol
Summary
Functions
run/1
Settings
View Source
Kayrock.Generate
(kayrock v0.2.0)
Macros for generating modules for the protocol schema
Summary
Functions
build_all(api, schema_module)
build_modules(api, schema_module, modname)
describe_type(api, field, mapspec)
generate_field_deserializer(scope, arg, next_field_name)
generate_request_struct(api, vsn, modname, response_modname, schema)
generate_response_struct(api, vsn, modname, schema)
generate_schema_metadata(schema_module)
generate_serializer(modname)
make_request_getter(vsn)
make_request_module(api, vsn, schema_module)
make_response_deserializer(vsn)
make_response_module(api, vsn, schema_module)
make_types(root_module, vmin, vmax)
Functions
Link to this function
build_all(api, schema_module)
View Source
Link to this function
build_modules(api, schema_module, modname)
View Source
Link to this function
describe_type(api, field, mapspec)
View Source
Link to this function
generate_field_deserializer(scope, arg, next_field_name)
View Source
Link to this function
generate_request_struct(api, vsn, modname, response_modname, schema)
View Source
Link to this function
generate_response_struct(api, vsn, modname, schema)
View Source
Link to this function
generate_schema_metadata(schema_module)
View Source
Link to this function
generate_serializer(modname)
View Source
Link to this function
make_request_getter(vsn)
View Source
Link to this function
make_request_module(api, vsn, schema_module)
View Source
Link to this function
make_response_deserializer(vsn)
View Source
Link to this function
make_response_module(api, vsn, schema_module)
View Source
Link to this function
make_types(root_module, vmin, vmax)
View Source
×