path	# lines of code
api.go	63
primitive/interceptor.go	25
primitive/result.go	88
primitive/nsresolver.go	190
primitive/trace.go	9
primitive/ctx.go	121
primitive/pool.go	32
primitive/auth.go	9
primitive/errors.go	34
primitive/message.go	443
primitive/base.go	99
admin/admin.go	223
admin/response.go	62
admin/option.go	96
consumer/interceptor.go	86
consumer/lock.go	15
consumer/pull_consumer.go	857
consumer/statistics.go	406
consumer/mock_offset_store.go	76
consumer/push_consumer.go	1215
consumer/offset_store.go	375
consumer/message_util.go	30
consumer/process_queue.go	368
consumer/consumer.go	974
consumer/limiter.go	2
consumer/strategy.go	191
consumer/option.go	260
rlog/log.go	178
benchmark/producer.go	237
benchmark/stable.go	165
benchmark/consumer.go	224
benchmark/main.go	48
benchmark/message.go	13
errors/errors.go	36
hooks/filter_message_hook.go	10
config.go	1
producer/interceptor.go	72
producer/producer.go	658
producer/selector.go	101
producer/option.go	140
internal/namesrv.go	111
internal/mock_client.go	271
internal/model.go	394
internal/utils/math.go	13
internal/utils/namespace.go	38
internal/utils/compression.go	62
internal/utils/files.go	67
internal/utils/errors.go	17
internal/utils/net.go	47
internal/utils/set.go	72
internal/utils/string.go	13
internal/callback.go	10
internal/mock_namesrv.go	122
internal/transaction.go	3
internal/perm.go	32
internal/trace.go	461
internal/client.go	878
internal/validators.go	25
internal/request_response_future.go	107
internal/constants.go	19
internal/route.go	556
internal/request.go	532
internal/remote/interceptor.go	57
internal/remote/tcp_conn.go	48
internal/remote/mock_remote_client.go	69
internal/remote/future.go	44
internal/remote/codec.go	391
internal/remote/rpchook.go	5
internal/remote/remote_client.go	320
internal/response.go	30
internal/mq_version.go	4