Path	Lines of Code
admin/admin.go	215
admin/option.go	96
admin/response.go	62
api.go	59
benchmark/consumer.go	224
benchmark/main.go	48
benchmark/message.go	13
benchmark/producer.go	237
benchmark/stable.go	165
config.go	1
consumer/consumer.go	876
consumer/interceptor.go	86
consumer/limiter.go	2
consumer/lock.go	15
consumer/message_util.go	30
consumer/mock_offset_store.go	76
consumer/offset_store.go	373
consumer/option.go	241
consumer/process_queue.go	368
consumer/pull_consumer.go	736
consumer/push_consumer.go	1207
consumer/statistics.go	406
consumer/strategy.go	191
errors/errors.go	33
hooks/filter_message_hook.go	10
internal/callback.go	10
internal/client.go	878
internal/constants.go	19
internal/mock_client.go	271
internal/mock_namesrv.go	122
internal/model.go	384
internal/mq_version.go	4
internal/namesrv.go	111
internal/perm.go	32
internal/remote/codec.go	391
internal/remote/future.go	44
internal/remote/interceptor.go	57
internal/remote/mock_remote_client.go	69
internal/remote/remote_client.go	299
internal/remote/rpchook.go	5
internal/remote/tcp_conn.go	39
internal/request.go	515
internal/request_response_future.go	107
internal/response.go	30
internal/route.go	556
internal/trace.go	454
internal/transaction.go	3
internal/utils/compression.go	61
internal/utils/errors.go	11
internal/utils/files.go	67
internal/utils/math.go	13
internal/utils/namespace.go	38
internal/utils/net.go	47
internal/utils/set.go	72
internal/utils/string.go	13
internal/validators.go	25
primitive/auth.go	9
primitive/base.go	90
primitive/ctx.go	121
primitive/errors.go	34
primitive/interceptor.go	25
primitive/message.go	437
primitive/nsresolver.go	186
primitive/pool.go	32
primitive/result.go	84
primitive/trace.go	9
producer/interceptor.go	72
producer/option.go	128
producer/producer.go	655
producer/selector.go	101
rlog/log.go	177