Path	Lines of Code
go/internal/container/sync_map.go	39
go/internal/log/logger.go	65
go/internal/mage/mage.go	134
go/internal/magefile.go	2
go/internal/mqtt/options.go	128
go/internal/mqtt/types.go	25
go/internal/options/apply.go	16
go/internal/wallclock/wall_clock.go	46
go/mqtt/alias.go	27
go/mqtt/auth.go	56
go/mqtt/auth/mq_sat.go	84
go/mqtt/auth/types.go	12
go/mqtt/auth_utils.go	84
go/mqtt/connect.go	278
go/mqtt/constants.go	67
go/mqtt/env.go	180
go/mqtt/errors.go	93
go/mqtt/fatal_error.go	44
go/mqtt/internal/appendable_list_with_removal.go	60
go/mqtt/internal/background.go	33
go/mqtt/internal/connection_tracker.go	96
go/mqtt/internal/log_utils.go	97
go/mqtt/internal/mqtt_string.go	19
go/mqtt/internal/user_properties.go	19
go/mqtt/magefile.go	2
go/mqtt/net.go	87
go/mqtt/publish.go	151
go/mqtt/random_client_id.go	18
go/mqtt/retry/exponential_backoff.go	83
go/mqtt/retry/logger.go	48
go/mqtt/retry/types.go	8
go/mqtt/session_client.go	81
go/mqtt/session_client_options.go	99
go/mqtt/subscribe.go	189
go/mqtt/topic_filter.go	26
go/mqtt/username_password.go	28
go/protocol/app.go	51
go/protocol/command_executor.go	359
go/protocol/command_invoker.go	331
go/protocol/common_options.go	154
go/protocol/encoding.go	127
go/protocol/errors/errors.go	97
go/protocol/errors/logging.go	65
go/protocol/hlc/hlc.go	192
go/protocol/internal/caching/cache.go	82
go/protocol/internal/concurrency.go	33
go/protocol/internal/constants/metadata.go	22
go/protocol/internal/container/priority_map.go	79
go/protocol/internal/errutil/context.go	44
go/protocol/internal/errutil/mqtt.go	33
go/protocol/internal/errutil/protocol.go	223
go/protocol/internal/errutil/util.go	53
go/protocol/internal/timeout.go	57
go/protocol/internal/topic.go	176
go/protocol/internal/version/version.go	56
go/protocol/iso/types.go	93
go/protocol/listener.go	190
go/protocol/magefile.go	2
go/protocol/publisher.go	83
go/protocol/telemetry_cloud_event.go	264
go/protocol/telemetry_receiver.go	218
go/protocol/telemetry_sender.go	158
go/protocol/types.go	38
go/protocol/util.go	7
go/services/leasedlock/lease.go	191
go/services/leasedlock/lock.go	117
go/services/leasedlock/options.go	64
go/services/leasedlock/util.go	14
go/services/magefile.go	2
go/services/schemaregistry/alias.go	12
go/services/schemaregistry/client.go	91
go/services/schemaregistry/get.go	61
go/services/schemaregistry/options.go	15
go/services/schemaregistry/put.go	77
go/services/schemaregistry/schemaregistry/format.go	47
go/services/schemaregistry/schemaregistry/get_command_invoker.go	50
go/services/schemaregistry/schemaregistry/get_request_payload.go	4
go/services/schemaregistry/schemaregistry/get_request_schema.go	5
go/services/schemaregistry/schemaregistry/get_response_payload.go	4
go/services/schemaregistry/schemaregistry/put_command_invoker.go	50
go/services/schemaregistry/schemaregistry/put_request_payload.go	4
go/services/schemaregistry/schemaregistry/put_request_schema.go	10
go/services/schemaregistry/schemaregistry/put_response_payload.go	4
go/services/schemaregistry/schemaregistry/schema.go	13
go/services/schemaregistry/schemaregistry/schema_type.go	40
go/services/schemaregistry/schemaregistry/wrapper.go	53
go/services/statestore/client.go	223
go/services/statestore/del.go	58
go/services/statestore/errors/errors.go	50
go/services/statestore/get.go	47
go/services/statestore/internal/resp/format.go	35
go/services/statestore/internal/resp/parse.go	83
go/services/statestore/keynotify.go	84
go/services/statestore/notify.go	82
go/services/statestore/options.go	28
go/services/statestore/reconnect.go	31
go/services/statestore/set.go	85
go/services/statestore/vdel.go	59