path	# lines of code
codegen/include/google/type/date.proto	46
codegen/include/google/type/timeofday.proto	37
codegen/include/google/protobuf/api.proto	187
codegen/include/google/protobuf/field_mask.proto	241
codegen/include/google/protobuf/wrappers.proto	111
codegen/include/google/protobuf/type.proto	181
codegen/include/google/protobuf/struct.proto	88
codegen/include/google/protobuf/timestamp.proto	139
codegen/include/google/protobuf/any.proto	156
codegen/include/google/protobuf/source_context.proto	44
codegen/include/google/protobuf/descriptor.proto	885
codegen/include/google/protobuf/empty.proto	47
codegen/include/google/protobuf/duration.proto	110
codegen/include/google/protobuf/compiler/plugin.proto	163
codegen/include/dtdl/protobuf/dtdl_options.proto	9
codegen/src/Azure.Iot.Operations.ProtocolCompiler/ModelSelector.cs	107
codegen/src/Azure.Iot.Operations.ProtocolCompiler/TypeGenerator/TypesGenerator.cs	53
codegen/src/Azure.Iot.Operations.ProtocolCompiler/TypeGenerator/AvroSchemaStandardizer.cs	115
codegen/src/Azure.Iot.Operations.ProtocolCompiler/TypeGenerator/JsonSchemaStandardizer.cs	200
codegen/src/Azure.Iot.Operations.ProtocolCompiler/TypeGenerator/ITypeGenerator.cs	7
codegen/src/Azure.Iot.Operations.ProtocolCompiler/TypeGenerator/GoTypeGenerator.cs	58
codegen/src/Azure.Iot.Operations.ProtocolCompiler/TypeGenerator/RustTypeGenerator.cs	31
codegen/src/Azure.Iot.Operations.ProtocolCompiler/TypeGenerator/DotNetTypeGenerator.cs	30
codegen/src/Azure.Iot.Operations.ProtocolCompiler/TypeGenerator/ISchemaStandardizer.cs	9
codegen/src/Azure.Iot.Operations.ProtocolCompiler/TypeGenerator/TypeGeneratorSupport.cs	34
codegen/src/Azure.Iot.Operations.ProtocolCompiler/ReservedCSharp.cs	131
codegen/src/Azure.Iot.Operations.ProtocolCompiler/CommandHandler.cs	166
codegen/src/Azure.Iot.Operations.ProtocolCompiler/SchemaGenerator/AnnexFileProperties.cs	42
codegen/src/Azure.Iot.Operations.ProtocolCompiler/SchemaGenerator/ErrorSchemaInfo.cs	10
codegen/src/Azure.Iot.Operations.ProtocolCompiler/SchemaGenerator/SchemaNames.cs	10
codegen/src/Azure.Iot.Operations.ProtocolCompiler/SchemaGenerator/TelemetrySchemaInfo.cs	4
codegen/src/Azure.Iot.Operations.ProtocolCompiler/SchemaGenerator/SchemaGenerator.cs	374
codegen/src/Azure.Iot.Operations.ProtocolCompiler/SchemaGenerator/DtdlMqttExtensionValues.cs	26
codegen/src/Azure.Iot.Operations.ProtocolCompiler/SchemaGenerator/SchemaTransformFactory.cs	212
codegen/src/Azure.Iot.Operations.ProtocolCompiler/SchemaGenerator/TopicCollisionDetector.cs	63
codegen/src/Azure.Iot.Operations.ProtocolCompiler/SchemaGenerator/CommandSchemaInfo.cs	4
codegen/src/Azure.Iot.Operations.ProtocolCompiler/SchemaGenerator/MqttTopicTokens.cs	12
codegen/src/Azure.Iot.Operations.ProtocolCompiler/SchemaGenerator/SchemaWriter.cs	39
codegen/src/Azure.Iot.Operations.ProtocolCompiler/SchemaGenerator/SchemaTransform.cs	19
codegen/src/Azure.Iot.Operations.ProtocolCompiler/EnvoyGenerator/CommandEnvoyInfo.cs	4
codegen/src/Azure.Iot.Operations.ProtocolCompiler/EnvoyGenerator/EnvoyTransformFactory.cs	434
codegen/src/Azure.Iot.Operations.ProtocolCompiler/EnvoyGenerator/TelemetryEnvoyInfo.cs	4
codegen/src/Azure.Iot.Operations.ProtocolCompiler/EnvoyGenerator/ResourceTransform.cs	19
codegen/src/Azure.Iot.Operations.ProtocolCompiler/EnvoyGenerator/EnvoyGenerator.cs	71
codegen/src/Azure.Iot.Operations.ProtocolCompiler/OptionContainer.cs	20
codegen/src/Azure.Iot.Operations.ProtocolCompiler/ArgBinder.cs	81
codegen/src/Azure.Iot.Operations.ProtocolCompiler/CustomTypeName.cs	17
codegen/src/Azure.Iot.Operations.ProtocolCompiler/InternalsVisibleTo.cs	2
codegen/src/Azure.Iot.Operations.ProtocolCompiler/ReservedGo.cs	34
codegen/src/Azure.Iot.Operations.ProtocolCompiler/ThingGenerator/ThingGenerator.cs	40
codegen/src/Azure.Iot.Operations.ProtocolCompiler/ThingGenerator/RecursionException.cs	14
codegen/src/Azure.Iot.Operations.ProtocolCompiler/CodeName.cs	219
codegen/src/Azure.Iot.Operations.ProtocolCompiler/ReservedRust.cs	65
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/PayloadFormat.cs	25
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/translation/common/ThingDescriber.cs	102
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/translation/Map/code/MapThingSchema.cs	18
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/translation/Array/code/ArrayThingSchema.cs	18
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/translation/Interface/code/InterfaceThing.cs	53
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/translation/Object/code/ObjectThingSchema.cs	23
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/translation/Command/code/CommandAffordance.cs	41
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/translation/Telemetry/code/TelemetriesAffordance.cs	27
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/translation/Telemetry/code/TelemetryAffordance.cs	25
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/translation/Enum/code/EnumThingSchema.cs	20
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/SerializationFormat.cs	9
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/communication/java/Command/code/JavaCommandInvoker.cs	25
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/communication/java/Command/code/JavaCommandExecutor.cs	25
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/communication/java/Telemetry/code/JavaTelemetrySender.cs	22
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/communication/java/Telemetry/code/JavaTelemetryReceiver.cs	22
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/communication/java/Service/code/JavaService.cs	47
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/communication/c/Command/code/CCommandInvoker.cs	44
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/communication/c/Command/code/CCommandExecutor.cs	44
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/communication/rust/Serialization/code/RustSerialization.cs	102
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/communication/rust/Project/code/RustCargoToml.cs	30
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/communication/rust/Project/code/RustLib.cs	34
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/communication/rust/Error/code/RustError.cs	21
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/communication/rust/Command/code/RustCommandExecutor.cs	62
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/communication/rust/Command/code/RustCommandInvoker.cs	56
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/communication/rust/Telemetry/code/RustTelemetrySender.cs	21
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/communication/rust/Telemetry/code/RustTelemetryReceiver.cs	23
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/communication/rust/Service/code/RustShared.cs	18
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/communication/rust/Service/code/RustService.cs	41
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/communication/common/SubPaths.cs	7
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/communication/python/Command/code/PythonCommandInvoker.cs	25
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/communication/python/Command/code/PythonCommandExecutor.cs	25
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/communication/python/Telemetry/code/PythonTelemetrySender.cs	22
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/communication/python/Telemetry/code/PythonTelemetryReceiver.cs	22
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/communication/python/Service/code/PythonService.cs	51
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/communication/go/Error/code/GoError.cs	21
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/communication/go/Command/code/GoCommandInvoker.cs	44
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/communication/go/Command/code/GoCommandExecutor.cs	47
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/communication/go/Telemetry/code/GoTelemetrySender.cs	21
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/communication/go/Telemetry/code/GoTelemetryReceiver.cs	21
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/communication/go/Service/code/GoService.cs	53
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/communication/dotnet/Serialization/code/DotNetSerialization.cs	29
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/communication/dotnet/Project/code/DotNetProject.cs	169
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/communication/dotnet/Error/code/DotNetError.cs	23
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/communication/dotnet/Command/code/DotNetCommandInvoker.cs	35
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/communication/dotnet/Command/code/DotNetCommandExecutor.cs	39
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/communication/dotnet/Telemetry/code/DotNetTelemetrySender.cs	30
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/communication/dotnet/Telemetry/code/DotNetTelemetryReceiver.cs	30
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/communication/dotnet/Service/code/DotNetService.cs	65
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/ITemplateTransform.cs	9
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/encapsulation/rust/code/RustObject.cs	18
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/encapsulation/rust/code/RustIntegerEnum.cs	14
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/encapsulation/rust/code/RustBareEnum.cs	14
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/encapsulation/rust/code/RustStringEnum.cs	14
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/encapsulation/rust/common/RustSchemaSupport.cs	48
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/encapsulation/common/UuidType.cs	10
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/encapsulation/common/ObjectType.cs	33
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/encapsulation/common/DoubleType.cs	10
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/encapsulation/common/SchemaKind.cs	32
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/encapsulation/common/ReferenceType.cs	30
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/encapsulation/common/TimeType.cs	10
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/encapsulation/common/UnsignedLongType.cs	10
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/encapsulation/common/SchemaType.cs	7
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/encapsulation/common/EnumType.cs	37
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/encapsulation/common/LongType.cs	10
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/encapsulation/common/ByteType.cs	10
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/encapsulation/common/IntegerType.cs	10
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/encapsulation/common/DurationType.cs	10
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/encapsulation/common/ArrayType.cs	12
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/encapsulation/common/DateTimeType.cs	10
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/encapsulation/common/UnsignedShortType.cs	10
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/encapsulation/common/ShortType.cs	10
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/encapsulation/common/BytesType.cs	10
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/encapsulation/common/BooleanType.cs	10
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/encapsulation/common/MapType.cs	12
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/encapsulation/common/StringType.cs	10
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/encapsulation/common/FloatType.cs	10
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/encapsulation/common/UnsignedIntegerType.cs	10
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/encapsulation/common/UnsignedByteType.cs	10
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/encapsulation/common/DecimalType.cs	10
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/encapsulation/common/DateType.cs	10
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/encapsulation/go/code/GoStringEnum.cs	14
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/encapsulation/go/code/GoObject.cs	16
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/encapsulation/go/code/GoIntegerEnum.cs	14
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/encapsulation/go/common/GoSchemaSupport.cs	60
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/encapsulation/dotnet/code/DotNetStringEnum.cs	16
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/encapsulation/dotnet/code/DotNetIntegerEnum.cs	16
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/encapsulation/dotnet/code/DotNetBareEnum.cs	16
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/encapsulation/dotnet/code/DotNetObject.cs	22
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/encapsulation/dotnet/common/DotNetSchemaSupport.cs	51
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/IUpdatingTransform.cs	8
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/serialization/common/CommonSchemaSupport.cs	11
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/serialization/common/JsonSchemaSupport.cs	75
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/serialization/common/AvroSchemaSupport.cs	74
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/serialization/common/ProtobufSupport.cs	85
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/serialization/Map/code/MapProto2.cs	22
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/serialization/Map/code/MapProto3.cs	22
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/serialization/Map/code/MapAvroSchema.cs	23
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/serialization/Array/code/ArrayAvroSchema.cs	23
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/serialization/Array/code/ArrayProto2.cs	23
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/serialization/Array/code/ArrayProto3.cs	23
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/serialization/Interface/code/InterfaceAnnex.cs	89
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/serialization/Object/code/ObjectJsonSchema.cs	28
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/serialization/Object/code/ObjectAvroSchema.cs	26
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/serialization/Object/code/ObjectProto3.cs	25
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/serialization/Object/code/ObjectProto2.cs	25
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/serialization/Object/code/ResultAvroSchema.cs	25
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/serialization/Nullable/code/NullableAvroSchema.cs	21
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/serialization/Command/code/CommandProto2.cs	26
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/serialization/Command/code/CommandProto3.cs	26
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/serialization/Command/code/CommandAvroSchema.cs	33
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/serialization/Command/code/CommandJsonSchema.cs	32
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/serialization/Telemetry/code/TelemetryProto3.cs	25
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/serialization/Telemetry/code/TelemetryAvroSchema.cs	26
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/serialization/Telemetry/code/TelemetryJsonSchema.cs	25
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/serialization/Telemetry/code/TelemetryProto2.cs	25
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/serialization/Enum/code/EnumProto3.cs	25
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/serialization/Enum/code/EnumProto2.cs	25
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/serialization/Enum/code/EnumAvroSchema.cs	20
codegen/src/Azure.Iot.Operations.ProtocolCompiler/T4/serialization/Enum/code/EnumJsonSchema.cs	25
codegen/src/Azure.Iot.Operations.ProtocolCompiler/RawTypeName.cs	17
codegen/src/Azure.Iot.Operations.ProtocolCompiler/TargetLanguage.cs	12
codegen/src/Azure.Iot.Operations.ProtocolCompiler/EmptyTypeName.cs	127
codegen/src/Azure.Iot.Operations.ProtocolCompiler/Program.cs	99
codegen/src/Azure.Iot.Operations.ProtocolCompiler/ITypeName.cs	8
codegen/src/Azure.Iot.Operations.ProtocolCompiler/ResourceNames.cs	9
codegen/res/rust/custom/common_types/custom_payload.rs	3
codegen/res/rust/custom/common_types.rs	3
codegen/res/rust/common/common_types/decimal.rs	30
codegen/res/rust/common/common_types/options.rs	41
codegen/res/rust/common/common_types/time_only.rs	59
codegen/res/rust/common/common_types/date_only.rs	46
codegen/res/rust/common/common_types.rs	5
codegen/res/rust/AVRO/common_types/b64.rs	30
codegen/res/rust/AVRO/common_types/empty_avro.rs	37
codegen/res/rust/AVRO/common_types.rs	7
codegen/res/rust/raw/common_types.rs	2
codegen/res/rust/JSON/common_types/b64.rs	29
codegen/res/rust/JSON/common_types/empty_json.rs	23
codegen/res/rust/JSON/common_types.rs	7
rust/rust-toolchain.toml	5
rust/azure_iot_operations_mqtt/src/interface.rs	100
rust/azure_iot_operations_mqtt/src/control_packet.rs	7
rust/azure_iot_operations_mqtt/src/auth.rs	125
rust/azure_iot_operations_mqtt/src/session/state.rs	150
rust/azure_iot_operations_mqtt/src/session/wrapper.rs	176
rust/azure_iot_operations_mqtt/src/session/managed_client.rs	123
rust/azure_iot_operations_mqtt/src/session/session.rs	374
rust/azure_iot_operations_mqtt/src/session/receiver.rs	1576
rust/azure_iot_operations_mqtt/src/session/reconnect_policy.rs	52
rust/azure_iot_operations_mqtt/src/session/receiver/ordered_acker.rs	296
rust/azure_iot_operations_mqtt/src/session/receiver/plenary_ack.rs	435
rust/azure_iot_operations_mqtt/src/session.rs	66
rust/azure_iot_operations_mqtt/src/interface_mocks.rs	21
rust/azure_iot_operations_mqtt/src/lib.rs	21
rust/azure_iot_operations_mqtt/src/error.rs	198
rust/azure_iot_operations_mqtt/src/rumqttc_adapter.rs	558
rust/azure_iot_operations_mqtt/src/connection_settings.rs	687
rust/azure_iot_operations_mqtt/src/topic.rs	386
rust/azure_iot_operations_mqtt/Cargo.toml	38
rust/ci/jq/coverage.jq	64
rust/sample_applications/event_driven_app/output_client/src/main.rs	233
rust/sample_applications/event_driven_app/output_client/Cargo.toml	17
rust/sample_applications/event_driven_app/input_client/src/main.rs	198
rust/sample_applications/event_driven_app/input_client/Cargo.toml	16
rust/sample_applications/counter/counter_client/src/main.rs	150
rust/sample_applications/counter/counter_client/Cargo.toml	13
rust/sample_applications/counter/counter_server/src/main.rs	114
rust/sample_applications/counter/counter_server/Cargo.toml	13
rust/sample_applications/counter/envoy/src/common_types/common_options.rs	21
rust/sample_applications/counter/envoy/src/common_types/decimal.rs	30
rust/sample_applications/counter/envoy/src/common_types/b64.rs	29
rust/sample_applications/counter/envoy/src/common_types/options.rs	41
rust/sample_applications/counter/envoy/src/common_types/empty_json.rs	23
rust/sample_applications/counter/envoy/src/common_types/time_only.rs	59
rust/sample_applications/counter/envoy/src/common_types/date_only.rs	53
rust/sample_applications/counter/envoy/src/common_types.rs	7
rust/sample_applications/counter/envoy/src/counter.rs	43
rust/sample_applications/counter/envoy/src/lib.rs	7
rust/sample_applications/counter/envoy/src/counter/reset_command_executor.rs	74
rust/sample_applications/counter/envoy/src/counter/telemetry_collection.rs	16
rust/sample_applications/counter/envoy/src/counter/read_counter_command_executor.rs	84
rust/sample_applications/counter/envoy/src/counter/increment_request_payload.rs	14
rust/sample_applications/counter/envoy/src/counter/telemetry_sender.rs	90
rust/sample_applications/counter/envoy/src/counter/read_counter_command_invoker.rs	109
rust/sample_applications/counter/envoy/src/counter/telemetry_collection_serialization.rs	31
rust/sample_applications/counter/envoy/src/counter/increment_request_payload_serialization.rs	31
rust/sample_applications/counter/envoy/src/counter/increment_command_invoker.rs	116
rust/sample_applications/counter/envoy/src/counter/telemetry_receiver.rs	56
rust/sample_applications/counter/envoy/src/counter/increment_command_executor.rs	85
rust/sample_applications/counter/envoy/src/counter/increment_response_payload.rs	14
rust/sample_applications/counter/envoy/src/counter/increment_response_payload_serialization.rs	31
rust/sample_applications/counter/envoy/src/counter/read_counter_response_payload.rs	14
rust/sample_applications/counter/envoy/src/counter/reset_command_invoker.rs	101
rust/sample_applications/counter/envoy/src/counter/read_counter_response_payload_serialization.rs	31
rust/sample_applications/counter/envoy/Cargo.toml	17
rust/azure_iot_operations_protocol/src/rpc_command/invoker.rs	1543
rust/azure_iot_operations_protocol/src/rpc_command/executor.rs	1415
rust/azure_iot_operations_protocol/src/common/aio_protocol_error.rs	557
rust/azure_iot_operations_protocol/src/common/payload_serialize.rs	123
rust/azure_iot_operations_protocol/src/common/user_properties.rs	119
rust/azure_iot_operations_protocol/src/common/topic_processor.rs	491
rust/azure_iot_operations_protocol/src/common/hybrid_logical_clock.rs	492
rust/azure_iot_operations_protocol/src/common.rs	10
rust/azure_iot_operations_protocol/src/application.rs	37
rust/azure_iot_operations_protocol/src/rpc_command.rs	104
rust/azure_iot_operations_protocol/src/telemetry/sender.rs	524
rust/azure_iot_operations_protocol/src/telemetry/cloud_event.rs	80
rust/azure_iot_operations_protocol/src/telemetry/receiver.rs	469
rust/azure_iot_operations_protocol/src/telemetry.rs	10
rust/azure_iot_operations_protocol/src/lib.rs	147
rust/azure_iot_operations_protocol/Cargo.toml	44
rust/Cargo.toml	32
rust/azure_iot_operations_services/src/state_store.rs	131
rust/azure_iot_operations_services/src/schema_registry/client.rs	159
rust/azure_iot_operations_services/src/schema_registry/schemaregistry_gen/common_types/common_options.rs	21
rust/azure_iot_operations_services/src/schema_registry/schemaregistry_gen/common_types/decimal.rs	30
rust/azure_iot_operations_services/src/schema_registry/schemaregistry_gen/common_types/b64.rs	29
rust/azure_iot_operations_services/src/schema_registry/schemaregistry_gen/common_types/options.rs	41
rust/azure_iot_operations_services/src/schema_registry/schemaregistry_gen/common_types/empty_json.rs	23
rust/azure_iot_operations_services/src/schema_registry/schemaregistry_gen/common_types/time_only.rs	59
rust/azure_iot_operations_services/src/schema_registry/schemaregistry_gen/common_types/date_only.rs	53
rust/azure_iot_operations_services/src/schema_registry/schemaregistry_gen/schema_registry/schema_type.rs	7
rust/azure_iot_operations_services/src/schema_registry/schemaregistry_gen/schema_registry/get_request_payload_serialization.rs	31
rust/azure_iot_operations_services/src/schema_registry/schemaregistry_gen/schema_registry/schema.rs	47
rust/azure_iot_operations_services/src/schema_registry/schemaregistry_gen/schema_registry/get_command_invoker.rs	96
rust/azure_iot_operations_services/src/schema_registry/schemaregistry_gen/schema_registry/format.rs	9
rust/azure_iot_operations_services/src/schema_registry/schemaregistry_gen/schema_registry/put_command_invoker.rs	96
rust/azure_iot_operations_services/src/schema_registry/schemaregistry_gen/schema_registry/get_request_payload.rs	15
rust/azure_iot_operations_services/src/schema_registry/schemaregistry_gen/schema_registry/get_response_payload_serialization.rs	31
rust/azure_iot_operations_services/src/schema_registry/schemaregistry_gen/schema_registry/get_response_payload.rs	16
rust/azure_iot_operations_services/src/schema_registry/schemaregistry_gen/schema_registry/put_response_payload.rs	14
rust/azure_iot_operations_services/src/schema_registry/schemaregistry_gen/schema_registry/put_request_payload.rs	15
rust/azure_iot_operations_services/src/schema_registry/schemaregistry_gen/schema_registry/put_request_schema.rs	38
rust/azure_iot_operations_services/src/schema_registry/schemaregistry_gen/schema_registry/put_response_payload_serialization.rs	31
rust/azure_iot_operations_services/src/schema_registry/schemaregistry_gen/schema_registry/put_request_payload_serialization.rs	31
rust/azure_iot_operations_services/src/schema_registry/schemaregistry_gen/schema_registry/get_request_schema.rs	18
rust/azure_iot_operations_services/src/schema_registry/schemaregistry_gen/common_types.rs	7
rust/azure_iot_operations_services/src/schema_registry/schemaregistry_gen/schema_registry.rs	33
rust/azure_iot_operations_services/src/schema_registry/schemaregistry_gen/mod.rs	7
rust/azure_iot_operations_services/src/common.rs	54
rust/azure_iot_operations_services/src/leased_lock/client.rs	234
rust/azure_iot_operations_services/src/schema_registry.rs	87
rust/azure_iot_operations_services/src/leased_lock.rs	76
rust/azure_iot_operations_services/src/state_store/client.rs	738
rust/azure_iot_operations_services/src/state_store/resp3.rs	501
rust/azure_iot_operations_services/src/lib.rs	9
rust/azure_iot_operations_services/Cargo.toml	58
rust/clippy.toml	3
tools/statestore-cli/rust-toolchain.toml	3
tools/statestore-cli/src/main.rs	259
tools/statestore-cli/Cargo.toml	30
tools/deployment/yaml/cert-man.yaml	49
tools/deployment/yaml/broker-listeners.yaml	85
doc/dev/proto/MetlCasesProto.xml	52
doc/dev/proto/MetlSpecProto.xml	938
doc/dev/proto/ProtoDocument.xsd	156
go/services/magefile.go	2
go/services/schemaregistry/put.go	77
go/services/schemaregistry/alias.go	12
go/services/schemaregistry/schemaregistry/get_request_payload.go	4
go/services/schemaregistry/schemaregistry/schema.go	13
go/services/schemaregistry/schemaregistry/get_request_schema.go	5
go/services/schemaregistry/schemaregistry/get_response_payload.go	4
go/services/schemaregistry/schemaregistry/put_request_schema.go	10
go/services/schemaregistry/schemaregistry/put_request_payload.go	4
go/services/schemaregistry/schemaregistry/put_response_payload.go	4
go/services/schemaregistry/schemaregistry/get_command_invoker.go	50
go/services/schemaregistry/schemaregistry/schema_type.go	40
go/services/schemaregistry/schemaregistry/format.go	47
go/services/schemaregistry/schemaregistry/wrapper.go	53
go/services/schemaregistry/schemaregistry/put_command_invoker.go	50
go/services/schemaregistry/get.go	61
go/services/schemaregistry/client.go	91
go/services/schemaregistry/options.go	15
go/services/leasedlock/lock.go	117
go/services/leasedlock/util.go	14
go/services/leasedlock/options.go	64
go/services/leasedlock/lease.go	191
go/services/statestore/reconnect.go	31
go/services/statestore/notify.go	82
go/services/statestore/vdel.go	59
go/services/statestore/get.go	47
go/services/statestore/errors/errors.go	50
go/services/statestore/client.go	223
go/services/statestore/options.go	28
go/services/statestore/set.go	85
go/services/statestore/del.go	58
go/services/statestore/keynotify.go	84
go/services/statestore/internal/resp/format.go	35
go/services/statestore/internal/resp/parse.go	83
go/protocol/encoding.go	127
go/protocol/iso/types.go	93
go/protocol/telemetry_cloud_event.go	264
go/protocol/util.go	7
go/protocol/app.go	51
go/protocol/listener.go	190
go/protocol/telemetry_sender.go	158
go/protocol/magefile.go	2
go/protocol/common_options.go	154
go/protocol/command_executor.go	359
go/protocol/telemetry_receiver.go	218
go/protocol/errors/logging.go	65
go/protocol/errors/errors.go	97
go/protocol/types.go	38
go/protocol/hlc/hlc.go	192
go/protocol/publisher.go	83
go/protocol/internal/constants/metadata.go	22
go/protocol/internal/topic.go	176
go/protocol/internal/timeout.go	57
go/protocol/internal/container/priority_map.go	79
go/protocol/internal/caching/cache.go	82
go/protocol/internal/concurrency.go	33
go/protocol/internal/version/version.go	56
go/protocol/internal/errutil/util.go	53
go/protocol/internal/errutil/protocol.go	223
go/protocol/internal/errutil/context.go	44
go/protocol/internal/errutil/mqtt.go	33
go/protocol/command_invoker.go	331
go/mqtt/publish.go	151
go/mqtt/session_client.go	81
go/mqtt/retry/exponential_backoff.go	83
go/mqtt/retry/logger.go	48
go/mqtt/retry/types.go	8
go/mqtt/alias.go	27
go/mqtt/topic_filter.go	26
go/mqtt/env.go	180
go/mqtt/magefile.go	2
go/mqtt/username_password.go	28
go/mqtt/random_client_id.go	18
go/mqtt/subscribe.go	189
go/mqtt/fatal_error.go	44
go/mqtt/auth_utils.go	84
go/mqtt/auth.go	56
go/mqtt/errors.go	93
go/mqtt/net.go	87
go/mqtt/session_client_options.go	99
go/mqtt/constants.go	67
go/mqtt/internal/user_properties.go	19
go/mqtt/internal/connection_tracker.go	96
go/mqtt/internal/background.go	33
go/mqtt/internal/mqtt_string.go	19
go/mqtt/internal/log_utils.go	97
go/mqtt/internal/appendable_list_with_removal.go	60
go/mqtt/connect.go	278
go/mqtt/auth/mq_sat.go	84
go/mqtt/auth/types.go	12
go/internal/options/apply.go	16
go/internal/wallclock/wall_clock.go	46
go/internal/magefile.go	2
go/internal/log/logger.go	65
go/internal/container/sync_map.go	39
go/internal/mage/mage.go	134
go/internal/mqtt/types.go	25
go/internal/mqtt/options.go	128
dotnet/Directory.Build.props	9
dotnet/src/Azure.Iot.Operations.Protocol/ExecutionDispatcherCollection.cs	52
dotnet/src/Azure.Iot.Operations.Protocol/IPayloadSerializer.cs	11
dotnet/src/Azure.Iot.Operations.Protocol/Models/MqttClientPublishReasonCode.cs	15
dotnet/src/Azure.Iot.Operations.Protocol/Models/MqttEnhancedAuthenticationExchangeData.cs	12
dotnet/src/Azure.Iot.Operations.Protocol/Models/IMqttEnhancedAuthenticationHandler.cs	9
dotnet/src/Azure.Iot.Operations.Protocol/Models/MqttApplicationMessageReceivedReasonCode.cs	16
dotnet/src/Azure.Iot.Operations.Protocol/Models/MqttClientUnsubscribeOptions.cs	25
dotnet/src/Azure.Iot.Operations.Protocol/Models/MqttTopicFilterComparer.cs	123
dotnet/src/Azure.Iot.Operations.Protocol/Models/DefaultMqttCertificatesProvider.cs	29
dotnet/src/Azure.Iot.Operations.Protocol/Models/MqttClientCertificateValidationEventArgs.cs	14
dotnet/src/Azure.Iot.Operations.Protocol/Models/MqttClientCredentials.cs	17
dotnet/src/Azure.Iot.Operations.Protocol/Models/MqttEnhancedAuthenticationEventArgs.cs	22
dotnet/src/Azure.Iot.Operations.Protocol/Models/MqttClientUnsubscribeReasonCode.cs	13
dotnet/src/Azure.Iot.Operations.Protocol/Models/MqttClientSubscribeReasonCode.cs	18
dotnet/src/Azure.Iot.Operations.Protocol/Models/MqttClientWebSocketOptions.cs	24
dotnet/src/Azure.Iot.Operations.Protocol/Models/MqttClientSubscribeOptions.cs	26
dotnet/src/Azure.Iot.Operations.Protocol/Models/MqttUserProperty.cs	9
dotnet/src/Azure.Iot.Operations.Protocol/Models/IMqttClientCertificatesProvider.cs	9
dotnet/src/Azure.Iot.Operations.Protocol/Models/MqttClientTcpOptions.cs	19
dotnet/src/Azure.Iot.Operations.Protocol/Models/MqttClientTlsOptions.cs	27
dotnet/src/Azure.Iot.Operations.Protocol/Models/IMqttClientCredentialsProvider.cs	9
dotnet/src/Azure.Iot.Operations.Protocol/Models/MqttClientOptions.cs	145
dotnet/src/Azure.Iot.Operations.Protocol/Models/MqttExtendedAuthenticationExchangeContext.cs	13
dotnet/src/Azure.Iot.Operations.Protocol/Models/MqttClientDisconnectOptionsReason.cs	21
dotnet/src/Azure.Iot.Operations.Protocol/Models/MqttClientCertificateSelectionEventArgs.cs	19
dotnet/src/Azure.Iot.Operations.Protocol/Models/MqttQualityOfServiceLevel.cs	9
dotnet/src/Azure.Iot.Operations.Protocol/Models/MqttClientDisconnectReason.cs	36
dotnet/src/Azure.Iot.Operations.Protocol/Models/MqttClientUnsubscribeResultItem.cs	9
dotnet/src/Azure.Iot.Operations.Protocol/Models/MqttClientPublishResult.cs	12
dotnet/src/Azure.Iot.Operations.Protocol/Models/MqttClientWebSocketProxyOptions.cs	14
dotnet/src/Azure.Iot.Operations.Protocol/Models/MqttPayloadFormatIndicator.cs	8
dotnet/src/Azure.Iot.Operations.Protocol/Models/MqttTopicFilterCompareResult.cs	11
dotnet/src/Azure.Iot.Operations.Protocol/Models/MqttRetainHandling.cs	9
dotnet/src/Azure.Iot.Operations.Protocol/Models/MqttClientConnectResult.cs	27
dotnet/src/Azure.Iot.Operations.Protocol/Models/MqttProtocolVersion.cs	11
dotnet/src/Azure.Iot.Operations.Protocol/Models/MqttAuthPacket.cs	13
dotnet/src/Azure.Iot.Operations.Protocol/Models/MqttClientConnectResultCode.cs	29
dotnet/src/Azure.Iot.Operations.Protocol/Models/MqttClientSubscribeResultItem.cs	9
dotnet/src/Azure.Iot.Operations.Protocol/Models/MqttTopicFilter.cs	11
dotnet/src/Azure.Iot.Operations.Protocol/Models/MqttApplicationMessage.cs	82
dotnet/src/Azure.Iot.Operations.Protocol/Models/ProtocolVersion.cs	60
dotnet/src/Azure.Iot.Operations.Protocol/Models/IMqttClientChannelOptions.cs	8
dotnet/src/Azure.Iot.Operations.Protocol/Models/MqttClientSubscribeResult.cs	65
dotnet/src/Azure.Iot.Operations.Protocol/Models/MqttClientUnsubscribeResult.cs	60
dotnet/src/Azure.Iot.Operations.Protocol/Models/MqttClientDisconnectOptions.cs	17
dotnet/src/Azure.Iot.Operations.Protocol/Models/MqttPendingMessagesOverflowStrategy.cs	9
dotnet/src/Azure.Iot.Operations.Protocol/Models/MqttAuthenticateReasonCode.cs	10
dotnet/src/Azure.Iot.Operations.Protocol/AkriMqttException.cs	78
dotnet/src/Azure.Iot.Operations.Protocol/Connection/StringToDictionaryExtension.cs	32
dotnet/src/Azure.Iot.Operations.Protocol/Connection/MqttConnectionSettings.cs	352
dotnet/src/Azure.Iot.Operations.Protocol/Connection/X509ClientCertificateLocator.cs	21
dotnet/src/Azure.Iot.Operations.Protocol/ServiceGroupIdAttribute.cs	10
dotnet/src/Azure.Iot.Operations.Protocol/AkriMqttErrorKind.cs	20
dotnet/src/Azure.Iot.Operations.Protocol/ApplicationContext.cs	24
dotnet/src/Azure.Iot.Operations.Protocol/CommandBehaviorAttribute.cs	11
dotnet/src/Azure.Iot.Operations.Protocol/PatternValidity.cs	12
dotnet/src/Azure.Iot.Operations.Protocol/TelemetryTopicAttribute.cs	10
dotnet/src/Azure.Iot.Operations.Protocol/WallClock.cs	19
dotnet/src/Azure.Iot.Operations.Protocol/MqttUserPropertyListExtension.cs	23
dotnet/src/Azure.Iot.Operations.Protocol/Events/MqttClientConnectedEventArgs.cs	10
dotnet/src/Azure.Iot.Operations.Protocol/Events/MqttApplicationMessageReceivedEventArgs.cs	32
dotnet/src/Azure.Iot.Operations.Protocol/Events/MqttClientDisconnectedEventArgs.cs	22
dotnet/src/Azure.Iot.Operations.Protocol/AttributeRetriever.cs	26
dotnet/src/Azure.Iot.Operations.Protocol/IMqttClient.cs	21
dotnet/src/Azure.Iot.Operations.Protocol/Retry/RetryExpiredException.cs	17
dotnet/src/Azure.Iot.Operations.Protocol/Retry/NoRetryPolicy.cs	15
dotnet/src/Azure.Iot.Operations.Protocol/Retry/ExponentialBackoffRetryPolicy.cs	56
dotnet/src/Azure.Iot.Operations.Protocol/Retry/IRetryPolicy.cs	8
dotnet/src/Azure.Iot.Operations.Protocol/ExecutionDispatcher.cs	48
dotnet/src/Azure.Iot.Operations.Protocol/SerializedPayloadContext.cs	12
dotnet/src/Azure.Iot.Operations.Protocol/IWallClock.cs	13
dotnet/src/Azure.Iot.Operations.Protocol/GuidExtensions.cs	26
dotnet/src/Azure.Iot.Operations.Protocol/CommandTopicAttribute.cs	10
dotnet/src/Azure.Iot.Operations.Protocol/HybridLogicalClock.cs	244
dotnet/src/Azure.Iot.Operations.Protocol/BuildConfiguration.cs	5
dotnet/src/Azure.Iot.Operations.Protocol/HybridLogicalClockException.cs	10
dotnet/src/Azure.Iot.Operations.Protocol/Telemetry/IncomingTelemetryMetadata.cs	93
dotnet/src/Azure.Iot.Operations.Protocol/Telemetry/TelemetrySender.cs	184
dotnet/src/Azure.Iot.Operations.Protocol/Telemetry/TelemetryReceiver.cs	209
dotnet/src/Azure.Iot.Operations.Protocol/Telemetry/CloudEvent.cs	16
dotnet/src/Azure.Iot.Operations.Protocol/Telemetry/OutgoingTelemetryMetadata.cs	16
dotnet/src/Azure.Iot.Operations.Protocol/Telemetry/TelemetryVersion.cs	9
dotnet/src/Azure.Iot.Operations.Protocol/RPC/RpcCallAsync.cs	33
dotnet/src/Azure.Iot.Operations.Protocol/RPC/CommandExecutor.cs	568
dotnet/src/Azure.Iot.Operations.Protocol/RPC/CommandStatusCode.cs	14
dotnet/src/Azure.Iot.Operations.Protocol/RPC/ICommandResponseCache.cs	15
dotnet/src/Azure.Iot.Operations.Protocol/RPC/ExtendedRequest.cs	10
dotnet/src/Azure.Iot.Operations.Protocol/RPC/CommandResponseMetadata.cs	58
dotnet/src/Azure.Iot.Operations.Protocol/RPC/CommandVersion.cs	9
dotnet/src/Azure.Iot.Operations.Protocol/RPC/ExtendedResponse.cs	68
dotnet/src/Azure.Iot.Operations.Protocol/RPC/CommandInvoker.cs	624
dotnet/src/Azure.Iot.Operations.Protocol/RPC/CommandResponseCache.cs	270
dotnet/src/Azure.Iot.Operations.Protocol/RPC/CommandRequestMetadata.cs	75
dotnet/src/Azure.Iot.Operations.Protocol/Dispatcher.cs	7
dotnet/src/Azure.Iot.Operations.Protocol/AkriSystemProperties.cs	34
dotnet/src/Azure.Iot.Operations.Protocol/MqttTopicProcessor.cs	142
dotnet/src/Azure.Iot.Operations.Protocol/IMqttPubSubClient.cs	19
dotnet/src/Azure.Iot.Operations.Connector/MqttSessionClientFactoryProvider.cs	27
dotnet/src/Azure.Iot.Operations.Connector/IDatasetSampler.cs	9
dotnet/src/Azure.Iot.Operations.Connector/PollingTelemetryConnectorWorker.cs	85
dotnet/src/Azure.Iot.Operations.Connector/ConnectorLeaderElectionConfiguration.cs	22
dotnet/src/Azure.Iot.Operations.Connector/IDatasetSamplerFactory.cs	9
dotnet/src/Azure.Iot.Operations.Connector/TelemetryConnectorWorker.cs	303
dotnet/src/Azure.Iot.Operations.Connector/AssetAvailabileEventArgs.cs	17
dotnet/src/Azure.Iot.Operations.Connector/ConnectorBackgroundService.cs	9
dotnet/src/Azure.Iot.Operations.Connector/NoMessageSchemaProvider.cs	24
dotnet/src/Azure.Iot.Operations.Connector/ConnectorMessageSchema.cs	27
dotnet/src/Azure.Iot.Operations.Connector/IMessageSchemaProvider.cs	10
dotnet/src/Azure.Iot.Operations.Connector/AssetUnavailableEventArgs.cs	12
dotnet/src/Azure.Iot.Operations.Connector/Exceptions/AssetConfigurationException.cs	22
dotnet/src/Azure.Iot.Operations.Connector/AssetMonitorFactoryProvider.cs	12
dotnet/src/Azure.Iot.Operations.Connector/IConnectorLeaderElectionConfigurationProvider.cs	8
dotnet/src/Azure.Iot.Operations.Services/SchemaRegistry/SchemaRegistry/PutRequestSchema.g.cs	33
dotnet/src/Azure.Iot.Operations.Services/SchemaRegistry/SchemaRegistry/PutCommandExecutor.g.cs	28
dotnet/src/Azure.Iot.Operations.Services/SchemaRegistry/SchemaRegistry/PutRequestPayload.g.cs	30
dotnet/src/Azure.Iot.Operations.Services/SchemaRegistry/SchemaRegistry/PutResponsePayload.g.cs	30
dotnet/src/Azure.Iot.Operations.Services/SchemaRegistry/SchemaRegistry/GetCommandExecutor.g.cs	29
dotnet/src/Azure.Iot.Operations.Services/SchemaRegistry/SchemaRegistry/SchemaRegistry.g.cs	163
dotnet/src/Azure.Iot.Operations.Services/SchemaRegistry/SchemaRegistry/GetRequestSchema.g.cs	18
dotnet/src/Azure.Iot.Operations.Services/SchemaRegistry/SchemaRegistry/PutCommandInvoker.g.cs	27
dotnet/src/Azure.Iot.Operations.Services/SchemaRegistry/SchemaRegistry/SchemaType.g.cs	10
dotnet/src/Azure.Iot.Operations.Services/SchemaRegistry/SchemaRegistry/Format.g.cs	12
dotnet/src/Azure.Iot.Operations.Services/SchemaRegistry/SchemaRegistry/Schema.g.cs	42
dotnet/src/Azure.Iot.Operations.Services/SchemaRegistry/SchemaRegistry/GetCommandInvoker.g.cs	27
dotnet/src/Azure.Iot.Operations.Services/SchemaRegistry/SchemaRegistry/GetRequestPayload.g.cs	30
dotnet/src/Azure.Iot.Operations.Services/SchemaRegistry/SchemaRegistry/GetResponsePayload.g.cs	15
dotnet/src/Azure.Iot.Operations.Services/SchemaRegistry/ISchemaRegistryClient.cs	10
dotnet/src/Azure.Iot.Operations.Services/SchemaRegistry/gen.cmd	4
dotnet/src/Azure.Iot.Operations.Services/SchemaRegistry/SchemaRegistryClientStub.cs	6
dotnet/src/Azure.Iot.Operations.Services/SchemaRegistry/SchemaRegistryClient.cs	83
dotnet/src/Azure.Iot.Operations.Services/SchemaRegistry/SchemaRegistryServiceException.cs	29
dotnet/src/Azure.Iot.Operations.Services/SchemaRegistry/Common/DecimalString.cs	73
dotnet/src/Azure.Iot.Operations.Services/SchemaRegistry/Common/TimeJsonConverter.cs	18
dotnet/src/Azure.Iot.Operations.Services/SchemaRegistry/Common/DateJsonConverter.cs	18
dotnet/src/Azure.Iot.Operations.Services/SchemaRegistry/Common/UuidJsonConverter.cs	17
dotnet/src/Azure.Iot.Operations.Services/SchemaRegistry/Common/DurationJsonConverter.cs	18
dotnet/src/Azure.Iot.Operations.Services/SchemaRegistry/Common/EmptyJson.cs	6
dotnet/src/Azure.Iot.Operations.Services/SchemaRegistry/Common/DecimalJsonConverter.cs	18
dotnet/src/Azure.Iot.Operations.Services/SchemaRegistry/Common/BytesJsonConverter.cs	17
dotnet/src/Azure.Iot.Operations.Services/SchemaRegistry/Common/Utf8JsonSerializer.cs	75
dotnet/src/Azure.Iot.Operations.Services/SchemaRegistry/Common/ValueExtractor.cs	13
dotnet/src/Azure.Iot.Operations.Services/StateStore/StateStoreResponse.cs	13
dotnet/src/Azure.Iot.Operations.Services/StateStore/StateStoreClientStub.cs	11
dotnet/src/Azure.Iot.Operations.Services/StateStore/StateStoreKeyNotification.cs	19
dotnet/src/Azure.Iot.Operations.Services/StateStore/StateStoreClient.cs	293
dotnet/src/Azure.Iot.Operations.Services/StateStore/StateStoreKey.cs	35
dotnet/src/Azure.Iot.Operations.Services/StateStore/StateStoreGeneratedClient.cs	11
dotnet/src/Azure.Iot.Operations.Services/StateStore/StateStoreDeleteRequestOptions.cs	10
dotnet/src/Azure.Iot.Operations.Services/StateStore/gen.cmd	7
dotnet/src/Azure.Iot.Operations.Services/StateStore/StateStoreOperationException.cs	78
dotnet/src/Azure.Iot.Operations.Services/StateStore/StateStoreObject.cs	104
dotnet/src/Azure.Iot.Operations.Services/StateStore/StateStoreGen/InvokeCommandExecutor.g.cs	28
dotnet/src/Azure.Iot.Operations.Services/StateStore/StateStoreGen/PassthroughSerializer.cs	40
dotnet/src/Azure.Iot.Operations.Services/StateStore/StateStoreGen/InvokeCommandInvoker.g.cs	27
dotnet/src/Azure.Iot.Operations.Services/StateStore/StateStoreGen/StateStore.g.cs	119
dotnet/src/Azure.Iot.Operations.Services/StateStore/StateStoreGetResponse.cs	14
dotnet/src/Azure.Iot.Operations.Services/StateStore/RESP3/Resp3SimpleErrorException.cs	13
dotnet/src/Azure.Iot.Operations.Services/StateStore/RESP3/Resp3ArrayBuilder.cs	21
dotnet/src/Azure.Iot.Operations.Services/StateStore/RESP3/Resp3ProtocolException.cs	12
dotnet/src/Azure.Iot.Operations.Services/StateStore/RESP3/Resp3Protocol.cs	261
dotnet/src/Azure.Iot.Operations.Services/StateStore/StateStoreDeleteResponse.cs	12
dotnet/src/Azure.Iot.Operations.Services/StateStore/StateStoreSetResponse.cs	14
dotnet/src/Azure.Iot.Operations.Services/StateStore/StateStorePayloadParser.cs	195
dotnet/src/Azure.Iot.Operations.Services/StateStore/IStateStoreClient.cs	14
dotnet/src/Azure.Iot.Operations.Services/StateStore/StateStoreSetRequestOptions.cs	11
dotnet/src/Azure.Iot.Operations.Services/StateStore/StateStoreValue.cs	33
dotnet/src/Azure.Iot.Operations.Services/StateStore/SetCondition.cs	10
dotnet/src/Azure.Iot.Operations.Services/StateStore/IStateStoreClientStub.cs	9
dotnet/src/Azure.Iot.Operations.Services/StateStore/KeyState.cs	9
dotnet/src/Azure.Iot.Operations.Services/StateStore/KeyChangeMessageReceivedEventArgs.cs	18
dotnet/src/Azure.Iot.Operations.Services/LeasedLock/RetryPolicyWithAutoReset.cs	34
dotnet/src/Azure.Iot.Operations.Services/LeasedLock/LockChangeEventArgs.cs	16
dotnet/src/Azure.Iot.Operations.Services/LeasedLock/LeasedLockClient.cs	357
dotnet/src/Azure.Iot.Operations.Services/LeasedLock/AcquireLockResponse.cs	18
dotnet/src/Azure.Iot.Operations.Services/LeasedLock/LeasedLockHolder.cs	66
dotnet/src/Azure.Iot.Operations.Services/LeasedLock/LockState.cs	9
dotnet/src/Azure.Iot.Operations.Services/LeasedLock/ReleaseLockRequestOptions.cs	9
dotnet/src/Azure.Iot.Operations.Services/LeasedLock/LeasedLockAutomaticRenewalOptions.cs	10
dotnet/src/Azure.Iot.Operations.Services/LeasedLock/GetLockHolderResponse.cs	12
dotnet/src/Azure.Iot.Operations.Services/LeasedLock/ReleaseLockResponse.cs	12
dotnet/src/Azure.Iot.Operations.Services/LeasedLock/AcquireLockRequestOptions.cs	8
dotnet/src/Azure.Iot.Operations.Services/LeaderElection/ResignationRequestOptions.cs	9
dotnet/src/Azure.Iot.Operations.Services/LeaderElection/ILeaderElectionClient.cs	19
dotnet/src/Azure.Iot.Operations.Services/LeaderElection/CampaignRequestOptions.cs	8
dotnet/src/Azure.Iot.Operations.Services/LeaderElection/LeaderElectionClient.cs	196
dotnet/src/Azure.Iot.Operations.Services/LeaderElection/ResignationResponse.cs	12
dotnet/src/Azure.Iot.Operations.Services/LeaderElection/LeaderElectionCandidate.cs	66
dotnet/src/Azure.Iot.Operations.Services/LeaderElection/CampaignResponse.cs	15
dotnet/src/Azure.Iot.Operations.Services/LeaderElection/LeaderElectionAutomaticRenewalOptions.cs	10
dotnet/src/Azure.Iot.Operations.Services/LeaderElection/LeadershipChangeEventArgs.cs	16
dotnet/src/Azure.Iot.Operations.Services/LeaderElection/LeadershipPositionState.cs	9
dotnet/src/Azure.Iot.Operations.Services/LeaderElection/GetCurrentLeaderResponse.cs	12
dotnet/src/Azure.Iot.Operations.Services/Akri/gen.cmd	4
dotnet/src/Azure.Iot.Operations.Services/Akri/DiscoveredAssetResourcesClient.cs	49
dotnet/src/Azure.Iot.Operations.Services/Akri/DiscoveredAssetResources/DiscoveredTopicRetain.g.cs	12
dotnet/src/Azure.Iot.Operations.Services/Akri/DiscoveredAssetResources/CreateDiscoveredAssetResponsePayload.g.cs	30
dotnet/src/Azure.Iot.Operations.Services/Akri/DiscoveredAssetResources/DataPointsSchemaElementSchema.g.cs	24
dotnet/src/Azure.Iot.Operations.Services/Akri/DiscoveredAssetResources/CreateDiscoveredAssetEndpointProfileCommandExecutor.g.cs	28
dotnet/src/Azure.Iot.Operations.Services/Akri/DiscoveredAssetResources/CreateDiscoveredAssetRequestPayload.g.cs	30
dotnet/src/Azure.Iot.Operations.Services/Akri/DiscoveredAssetResources/DefaultTopicSchema.g.cs	18
dotnet/src/Azure.Iot.Operations.Services/Akri/DiscoveredAssetResources/CreateDiscoveredAssetResponseSchema.g.cs	15
dotnet/src/Azure.Iot.Operations.Services/Akri/DiscoveredAssetResources/EventsSchemaElementSchema.g.cs	27
dotnet/src/Azure.Iot.Operations.Services/Akri/DiscoveredAssetResources/CreateDiscoveredAssetCommandInvoker.g.cs	27
dotnet/src/Azure.Iot.Operations.Services/Akri/DiscoveredAssetResources/CreateDiscoveredAssetEndpointProfileRequestSchema.g.cs	27
dotnet/src/Azure.Iot.Operations.Services/Akri/DiscoveredAssetResources/DatasetsSchemaElementSchema.g.cs	24
dotnet/src/Azure.Iot.Operations.Services/Akri/DiscoveredAssetResources/SupportedAuthenticationMethodsSchemaElementSchema.g.cs	14
dotnet/src/Azure.Iot.Operations.Services/Akri/DiscoveredAssetResources/CreateDiscoveredAssetCommandExecutor.g.cs	28
dotnet/src/Azure.Iot.Operations.Services/Akri/DiscoveredAssetResources/CreateDiscoveredAssetEndpointProfileResponseSchema.g.cs	15
dotnet/src/Azure.Iot.Operations.Services/Akri/DiscoveredAssetResources/StatusSchema.g.cs	14
dotnet/src/Azure.Iot.Operations.Services/Akri/DiscoveredAssetResources/CreateDiscoveredAssetRequestSchema.g.cs	57
dotnet/src/Azure.Iot.Operations.Services/Akri/DiscoveredAssetResources/CreateDiscoveredAssetEndpointProfileCommandInvoker.g.cs	27
dotnet/src/Azure.Iot.Operations.Services/Akri/DiscoveredAssetResources/CreateDiscoveredAssetEndpointProfileRequestPayload.g.cs	30
dotnet/src/Azure.Iot.Operations.Services/Akri/DiscoveredAssetResources/CreateDiscoveredAssetEndpointProfileResponsePayload.g.cs	30
dotnet/src/Azure.Iot.Operations.Services/Akri/DiscoveredAssetResources/TopicSchema.g.cs	18
dotnet/src/Azure.Iot.Operations.Services/Akri/DiscoveredAssetResources/DiscoveredAssetResources.g.cs	164
dotnet/src/Azure.Iot.Operations.Services/Akri/DiscoveredAssetResourcesClientStub.cs	6
dotnet/src/Azure.Iot.Operations.Services/Akri/Common/DecimalString.cs	73
dotnet/src/Azure.Iot.Operations.Services/Akri/Common/TimeJsonConverter.cs	18
dotnet/src/Azure.Iot.Operations.Services/Akri/Common/DateJsonConverter.cs	18
dotnet/src/Azure.Iot.Operations.Services/Akri/Common/UuidJsonConverter.cs	17
dotnet/src/Azure.Iot.Operations.Services/Akri/Common/DurationJsonConverter.cs	18
dotnet/src/Azure.Iot.Operations.Services/Akri/Common/EmptyJson.cs	6
dotnet/src/Azure.Iot.Operations.Services/Akri/Common/DecimalJsonConverter.cs	18
dotnet/src/Azure.Iot.Operations.Services/Akri/Common/BytesJsonConverter.cs	17
dotnet/src/Azure.Iot.Operations.Services/Akri/Common/Utf8JsonSerializer.cs	75
dotnet/src/Azure.Iot.Operations.Services/Akri/Common/ValueExtractor.cs	13
dotnet/src/Azure.Iot.Operations.Services/Akri/IDiscoveredAssetResourcesClient.cs	18
dotnet/src/Azure.Iot.Operations.Services/BuildConfiguration.cs	3
dotnet/src/Azure.Iot.Operations.Services/Assets/AssetEndpointProfile.cs	20
dotnet/src/Azure.Iot.Operations.Services/Assets/FilesMonitor/FileChangedEventArgs.cs	21
dotnet/src/Azure.Iot.Operations.Services/Assets/FilesMonitor/FilesMonitor.cs	108
dotnet/src/Azure.Iot.Operations.Services/Assets/ChangeType.cs	10
dotnet/src/Azure.Iot.Operations.Services/Assets/FileUtilities.cs	29
dotnet/src/Azure.Iot.Operations.Services/Assets/AssetEndpointProfileChangedEventArgs.cs	14
dotnet/src/Azure.Iot.Operations.Services/Assets/AssetMonitor.cs	224
dotnet/src/Azure.Iot.Operations.Services/Assets/IAssetMonitor.cs	16
dotnet/src/Azure.Iot.Operations.Services/Assets/Asset.cs	223
dotnet/src/Azure.Iot.Operations.Services/Assets/JsonDocumentConverter.cs	20
dotnet/src/Azure.Iot.Operations.Services/Assets/AssetChangedEventArgs.cs	16
dotnet/src/Azure.Iot.Operations.Services/Assets/AssetEndpointProfileCredentials.cs	16
dotnet/src/Azure.Iot.Operations.Mqtt/Session/QueuedPublishRequest.cs	23
dotnet/src/Azure.Iot.Operations.Mqtt/Session/MessagePurgedFromQueueException.cs	21
dotnet/src/Azure.Iot.Operations.Mqtt/Session/MqttSessionClient.cs	603
dotnet/src/Azure.Iot.Operations.Mqtt/Session/BlockingConcurrentList.cs	158
dotnet/src/Azure.Iot.Operations.Mqtt/Session/QueuedUnsubscribeRequest.cs	23
dotnet/src/Azure.Iot.Operations.Mqtt/Session/QueuedSubscribeRequest.cs	23
dotnet/src/Azure.Iot.Operations.Mqtt/Session/MqttSessionClientOptions.cs	32
dotnet/src/Azure.Iot.Operations.Mqtt/Session/QueuedRequest.cs	14
dotnet/src/Azure.Iot.Operations.Mqtt/Session/MqttSessionExpiredException.cs	16
dotnet/src/Azure.Iot.Operations.Mqtt/TokenRefreshTimer.cs	63
dotnet/src/Azure.Iot.Operations.Mqtt/IDelayableQueueItem.cs	9
dotnet/src/Azure.Iot.Operations.Mqtt/MqttConnectingFailedException.cs	15
dotnet/src/Azure.Iot.Operations.Mqtt/SatEnhancedAuthenticationHandler.cs	21
dotnet/src/Azure.Iot.Operations.Mqtt/OrderedAckMqttClientOptions.cs	12
dotnet/src/Azure.Iot.Operations.Mqtt/MqttNetTraceLogger.cs	22
dotnet/src/Azure.Iot.Operations.Mqtt/OrderedAckMqttClient.cs	269
dotnet/src/Azure.Iot.Operations.Mqtt/BlockingConcurrentDelayableQueue.cs	64
dotnet/src/Azure.Iot.Operations.Mqtt/QueuedMqttApplicationMessageReceivedEventArgs.cs	23
dotnet/src/Azure.Iot.Operations.Mqtt/BuildConfiguration.cs	4
dotnet/src/Azure.Iot.Operations.Mqtt/Converters/MqttNetConverter.cs	521
dotnet/src/Azure.Iot.Operations.Mqtt/Converters/GenericMqttEnhancedAuthenticationHandler.cs	33
dotnet/src/Azure.Iot.Operations.Mqtt/Converters/MqttNetMqttEnhancedAuthenticationHandler.cs	23
dotnet/src/Azure.Iot.Operations.Mqtt/Converters/MqttNetCertificateValidationHandler.cs	17
dotnet/src/Azure.Iot.Operations.Mqtt/Converters/GenericCertificateSelectionHandler.cs	18
dotnet/src/Azure.Iot.Operations.Mqtt/Converters/GenericCertificateValidationHandler.cs	17
dotnet/src/Azure.Iot.Operations.Mqtt/Converters/MqttNetHandler.cs	26
dotnet/src/Azure.Iot.Operations.Mqtt/Converters/MqttNetMqttClientCertificatesProvider.cs	15
dotnet/src/Azure.Iot.Operations.Mqtt/Converters/GenericMqttClientCredentialsProvider.cs	23
dotnet/src/Azure.Iot.Operations.Mqtt/Converters/GenericMqttClientCertificatesProvider.cs	15
dotnet/src/Azure.Iot.Operations.Mqtt/Converters/MqttNetMqttClientCredentialsProvider.cs	23
dotnet/src/Azure.Iot.Operations.Mqtt/Converters/MqttNetCertificateSelectionHandler.cs	18
dotnet/templates/EventDrivenTelemetryConnector/LeaderElectionConfigurationProvider.cs	16
dotnet/templates/EventDrivenTelemetryConnector/MessageSchemaProvider.cs	21
dotnet/templates/EventDrivenTelemetryConnector/ConnectorWorker.cs	43
dotnet/templates/EventDrivenTelemetryConnector/Program.cs	15
dotnet/templates/PollingTelemetryConnector/LeaderElectionConfigurationProvider.cs	16
dotnet/templates/PollingTelemetryConnector/MessageSchemaProvider.cs	21
dotnet/templates/PollingTelemetryConnector/DatasetSampler.cs	13
dotnet/templates/PollingTelemetryConnector/DatasetSamplerFactory.cs	17
dotnet/templates/PollingTelemetryConnector/Program.cs	16