handler

Documentation

Index

• Variables

Variables

var MessageHandlerMapping = map[int16]map[int16]handler.MessageHandler{
	implAPIVersion.Key: {
		implAPIVersionV0.Version: &handlerAPIVersionV0.Handler{},
		implAPIVersionV2.Version: &handlerAPIVersionV2.Handler{},
	},
	metadata.Key: {
		implMetadataV0.Version: &handlerMetadataV0.Handler{},
		implMetadataV1.Version: &handlerMetadataV1.Handler{},
		implMetadataV4.Version: &handlerMetadataV4.Handler{},
		metadatav8.Version:     &v8.Handler{},
	},
	init_producer_id.Key: {
		initProducerIDV0.Version: &handlerInitProducerIDV0.Handler{},
		initProducerIDV1.Version: &handlerInitProducerIDV1.Handler{},
	},
	produce.Key: {
		producev1.Version: &handlerProduceV1.Handler{},
		producev2.Version: &handlerProduceV2.Handler{},
		producev3.Version: &handlerProduceV3.Handler{},
		producev7.Version: &handlerProduceV7.Handler{},
	},
	find_coordinator.Key: {
		implFindCoordinatorV0.Version: &handlerFindCoordinatorV0.Handler{},
		implFindCoordinatorV2.Version: &handlerFindCoordinatorV2.Handler{},
	},
	join_group.Key: {
		implJoinGroupV0.Version: &handlerJoinGroupV0.Handler{},
		implJoinGroupV5.Version: &handlerJoinGroupV5.Handler{},
	},
	sync_group.Key: {
		implSyncGroupV0.Version: &handlerSyncGroupV0.Handler{},
		implSyncGroupV3.Version: &handlerSyncGroupV3.Handler{},
	},
	leave_group.Key: {
		implLeaveGroupV0.Version: &handlerLeaveGroupV0.Handler{},
		implLeaveGroupV3.Version: &handlerLeaveGroupV3.Handler{},
	},
	offset_fetch.Key: {
		implOffsetFetchv1.Version: &handlerOffsetFetchV1.Handler{},
		implOffsetFetchv4.Version: &handlerOffsetFetchV4.Handler{},
	},
	list_offsets.Key: {
		implListOffsetsV1.Version: &handlerListOffsetsV1.Handler{},
		implListOffsetsV5.Version: &handlerListOffsetsV5.Handler{},
	},
	fetch.Key: {
		implFetchV1.Version:  &handlerFetchV1.Handler{},
		implFetchV2.Version:  &handlerFetchV2.Handler{},
		implFetchV4.Version:  &handlerFetchV4.Handler{},
		implFetchV11.Version: &handlerFetchV11.Handler{},
	},
	heartbeat.Key: {
		implHeartbeatV0.Version: &handlerHeartbeatV0.Handler{},
		implHeartbeatV3.Version: &handlerHeartbeatV3.Handler{},
	},
	offset_commit.Key: {
		implOffsetCommitV1.Version: &handlerOffsetCommitV1.Handler{},
		implOffsetCommitV2.Version: &handlerOffsetCommitV2.Handler{},
		implOffsetCommitV4.Version: &handlerOffsetCommitV4.Handler{},
	},
	describe_groups.Key: {
		implDescribeGroupsV0.Version: &handlerDescribeGroupsV0.Handler{},
	},
	describe_configs.Key: {
		implDescribeConfigsV0.Version: &handlerDescribeConfigsV0.Handler{},
	},
	describe_acls.Key: {
		implDescribeAclsV1.Version: &handlerDescribeAclsV1.Handler{},
	},
	create_acls.Key: {
		implCreateAclsV1.Version: &handlerCreateAclsV1.Handler{},
	},
}