codec

Documentation

Index

• Variables

Variables

var MessageDecoderMapping = map[int16]map[int16]message.Decoder{
	implAPIVersion.Key: {
		implAPIVersionV0.Version: &apiVersionV0.Decoder{},
		implAPIVersionV2.Version: &apiVersionV2.Decoder{},
	},
	metadata.Key: {
		implMetadatav8.Version: &metadatav8.Decoder{},
		implMetadatav0.Version: &metadatav0.Decoder{},
		implMetadatav1.Version: &metadatav1.Decoder{},
		implMetadatav4.Version: &metadatav4.Decoder{},
	},
	init_producer_id.Key: {
		initProducerIDV0.Version: &initProducerV0.Decoder{},
		initProducerIDV1.Version: &initProducerV1.Decoder{},
	},
	produce.Key: {
		implProducev1.Version: &producev1.Decoder{},
		implProducev2.Version: &producev2.Decoder{},
		implProducev3.Version: &producev3.Decoder{},
		implProducev7.Version: &producev7.Decoder{},
	},
	find_coordinator.Key: {
		implFindCoordinatorV0.Version: &findCoordinatorV0.Decoder{},
		implFindCoordinatorV2.Version: &findCoordinatorV2.Decoder{},
	},
	join_group.Key: {
		implJoinGroupV5.Version: &joinGroupV5.Decoder{},
	},
	sync_group.Key: {
		implSyncGroupV0.Version: &syncGroupV0.Decoder{},
		implSyncGroupV3.Version: &syncGroupV3.Decoder{},
	},
	leave_group.Key: {
		implLeaveGroupV0.Version: &leaveGroupV0.Decoder{},
		implLeaveGroupV3.Version: &leaveGroupV3.Decoder{},
	},
	offset_fetch.Key: {
		implOffsetFetchv1.Version: &offsetFetchv1.Decoder{},
		implOffsetFetchv4.Version: &offsetFetchv4.Decoder{},
	},
	list_offsets.Key: {
		implListOffsetsV1.Version: &listOffsetsV1.Decoder{},
		implListOffsetsV5.Version: &listOffsetsV5.Decoder{},
	},
	fetch.Key: {
		implFetchV1.Version:  &fetchV1.Decoder{},
		implFetchV2.Version:  &fetchV2.Decoder{},
		implFetchV4.Version:  &fetchV4.Decoder{},
		implFetchV11.Version: &fetchV11.Decoder{},
	},
	heartbeat.Key: {
		implHeartbeatV0.Version: &heartbeatV0.Decoder{},
		implHeartbeatV3.Version: &heartbeatV3.Decoder{},
	},
	offset_commit.Key: {
		implOffsetCommitV1.Version: &offsetCommitV1.Decoder{},
		implOffsetCommitV2.Version: &offsetCommitV2.Decoder{},
		implOffsetCommitV4.Version: &offsetCommitV4.Decoder{},
	},
	describe_groups.Key: {
		implDescribeGroupsV0.Version: &describeGroupsV0.Decoder{},
	},
	describe_configs.Key: {
		implDescribeConfigsV0.Version: &describeConfigsV0.Decoder{},
	},
	describe_acls.Key: {
		implDescribeAclsV1.Version: &describeAclsV1.Decoder{},
	},
	create_acls.Key: {
		implCreateAclsV1.Version: &createAclsV1.Decoder{},
	},
}

var MessageEncoderMapping = map[reflect.Type]message.Encoder{
	reflect.TypeOf(implAPIVersionV0.Response{}):      &apiVersionV0.Encoder{},
	reflect.TypeOf(implAPIVersionV2.Response{}):      &apiVersionV2.Encoder{},
	reflect.TypeOf(implMetadatav0.Response{}):        &metadatav0.Encoder{},
	reflect.TypeOf(implMetadatav1.Response{}):        &metadatav1.Encoder{},
	reflect.TypeOf(implMetadatav4.Response{}):        &metadatav4.Encoder{},
	reflect.TypeOf(implMetadatav8.Response{}):        &metadatav8.Encoder{},
	reflect.TypeOf(initProducerIDV0.Response{}):      &initProducerV0.Encoder{},
	reflect.TypeOf(initProducerIDV1.Response{}):      &initProducerV1.Encoder{},
	reflect.TypeOf(implProducev1.Response{}):         &producev1.Encoder{},
	reflect.TypeOf(implProducev2.Response{}):         &producev2.Encoder{},
	reflect.TypeOf(implProducev3.Response{}):         &producev3.Encoder{},
	reflect.TypeOf(implProducev7.Response{}):         &producev7.Encoder{},
	reflect.TypeOf(implFindCoordinatorV0.Response{}): &findCoordinatorV0.Encoder{},
	reflect.TypeOf(implFindCoordinatorV2.Response{}): &findCoordinatorV2.Encoder{},
	reflect.TypeOf(implJoinGroupV5.Response{}):       &joinGroupV5.Encoder{},
	reflect.TypeOf(implSyncGroupV0.Response{}):       &syncGroupV0.Encoder{},
	reflect.TypeOf(implSyncGroupV3.Response{}):       &syncGroupV3.Encoder{},
	reflect.TypeOf(implLeaveGroupV3.Response{}):      &leaveGroupV3.Encoder{},
	reflect.TypeOf(implOffsetFetchv1.Response{}):     &offsetFetchv1.Encoder{},
	reflect.TypeOf(implOffsetFetchv4.Response{}):     &offsetFetchv4.Encoder{},
	reflect.TypeOf(implListOffsetsV1.Response{}):     &listOffsetsV1.Encoder{},
	reflect.TypeOf(implListOffsetsV5.Response{}):     &listOffsetsV5.Encoder{},
	reflect.TypeOf(implFetchV1.Response{}):           &fetchV1.Encoder{},
	reflect.TypeOf(implFetchV2.Response{}):           &fetchV2.Encoder{},
	reflect.TypeOf(implFetchV4.Response{}):           &fetchV4.Encoder{},
	reflect.TypeOf(implFetchV11.Response{}):          &fetchV11.Encoder{},
	reflect.TypeOf(implHeartbeatV0.Response{}):       &heartbeatV0.Encoder{},
	reflect.TypeOf(implHeartbeatV3.Response{}):       &heartbeatV3.Encoder{},
	reflect.TypeOf(implOffsetCommitV1.Response{}):    &offsetCommitV1.Encoder{},
	reflect.TypeOf(implOffsetCommitV2.Response{}):    &offsetCommitV2.Encoder{},
	reflect.TypeOf(implOffsetCommitV4.Response{}):    &offsetCommitV4.Encoder{},
	reflect.TypeOf(implDescribeGroupsV0.Response{}):  &describeGroupsV0.Encoder{},
	reflect.TypeOf(implDescribeConfigsV0.Response{}): &describeConfigsV0.Encoder{},
	reflect.TypeOf(implDescribeAclsV1.Response{}):    &describeAclsV1.Encoder{},
	reflect.TypeOf(implCreateAclsV1.Response{}):      &createAclsV1.Encoder{},
}