Path Lines of Code CODE_OF_CONDUCT.md 6 README.md 71 SECURITY.md 24 SUPPORT.md 14 codegen/README.md 55 codegen/demo/dotnet/ProtocolCompiler.Demo/CmdClient/CmdClient.csproj 17 codegen/demo/dotnet/ProtocolCompiler.Demo/CmdClient/Program.cs 81 codegen/demo/dotnet/ProtocolCompiler.Demo/CmdServer/CmdServer.csproj 17 codegen/demo/dotnet/ProtocolCompiler.Demo/CmdServer/Program.cs 94 codegen/demo/dotnet/ProtocolCompiler.Demo/TelemClient/Program.cs 161 codegen/demo/dotnet/ProtocolCompiler.Demo/TelemClient/TelemClient.csproj 17 codegen/demo/dotnet/ProtocolCompiler.Demo/TelemServer/Program.cs 178 codegen/demo/dotnet/ProtocolCompiler.Demo/TelemServer/TelemServer.csproj 17 codegen/demo/dotnet/bld.sh 1 codegen/demo/dtdl/AvroModel.json 60 codegen/demo/dtdl/CounterCollection.json 118 codegen/demo/dtdl/CustomModel.json 17 codegen/demo/dtdl/JsonModel.json 60 codegen/demo/dtdl/RawModel.json 17 codegen/demo/gen.sh 37 codegen/demo/go/bld.sh 12 codegen/demo/go/cmdclient/go.mod 28 codegen/demo/go/cmdclient/main.go 85 codegen/demo/go/cmdserver/go.mod 28 codegen/demo/go/cmdserver/main.go 121 codegen/demo/go/telemclient/go.mod 28 codegen/demo/go/telemclient/main.go 132 codegen/demo/go/telemserver/go.mod 28 codegen/demo/go/telemserver/main.go 158 codegen/demo/rust/bld.sh 27 codegen/demo/rust/protocol_compiler_demo/cmd_client/Cargo.toml 12 codegen/demo/rust/protocol_compiler_demo/cmd_client/src/main.rs 161 codegen/demo/rust/protocol_compiler_demo/cmd_server/Cargo.toml 13 codegen/demo/rust/protocol_compiler_demo/cmd_server/src/main.rs 145 codegen/demo/rust/protocol_compiler_demo/telem_client/Cargo.toml 15 codegen/demo/rust/protocol_compiler_demo/telem_client/src/main.rs 235 codegen/demo/rust/protocol_compiler_demo/telem_server/Cargo.toml 16 codegen/demo/rust/protocol_compiler_demo/telem_server/src/main.rs 272 codegen/src/Azure.Iot.Operations.ProtocolCompiler/appsettings.json 19 codegen/test/ProtocolCompiler.UnitTests/EnvoyGeneratorTests/models/CommandWithBothTopics.json 17 codegen/test/ProtocolCompiler.UnitTests/EnvoyGeneratorTests/models/CommandWithCmdTopic.json 16 codegen/test/ProtocolCompiler.UnitTests/EnvoyGeneratorTests/models/CommandWithTelemTopic.json 16 codegen/test/ProtocolCompiler.UnitTests/EnvoyGeneratorTests/models/CommandWithoutTopic.json 15 codegen/test/ProtocolCompiler.UnitTests/EnvoyGeneratorTests/models/TelemetryWithBothTopics.json 18 codegen/test/ProtocolCompiler.UnitTests/EnvoyGeneratorTests/models/TelemetryWithCmdTopic.json 17 codegen/test/ProtocolCompiler.UnitTests/EnvoyGeneratorTests/models/TelemetryWithTelemTopic.json 17 codegen/test/ProtocolCompiler.UnitTests/EnvoyGeneratorTests/models/TelemetryWithoutTopic.json 16 codegen/test/ProtocolCompiler.UnitTests/ModelSelectorTests/dmr/dtmi/akri/dtdl/modelselector/extendsbase-1.json 18 codegen/test/ProtocolCompiler.UnitTests/ModelSelectorTests/dmr/dtmi/akri/dtdl/modelselector/interfacebase-1.json 15 codegen/test/ProtocolCompiler.UnitTests/ModelSelectorTests/models/InterfaceExtendsBase.json 18 codegen/test/ProtocolCompiler.UnitTests/ModelSelectorTests/models/InterfaceExtendsDI.json 18 codegen/test/ProtocolCompiler.UnitTests/ModelSelectorTests/models/InterfaceMqttAlpha.json 17 codegen/test/ProtocolCompiler.UnitTests/ModelSelectorTests/models/InterfaceMqttBeta.json 17 codegen/test/ProtocolCompiler.UnitTests/ModelSelectorTests/models/InterfaceNoCotype.json 15 codegen/test/ProtocolCompiler.UnitTests/SchemaGeneratorTests/metaSchemas/AVRO/avro-avsc.json 327 codegen/test/ProtocolCompiler.UnitTests/SchemaGeneratorTests/metaSchemas/JSON/json-schema.json 57 codegen/test/ProtocolCompiler.UnitTests/SchemaGeneratorTests/models/CommandRaw.json 24 codegen/test/ProtocolCompiler.UnitTests/SchemaGeneratorTests/models/CommandWithRequestArray.json 23 codegen/test/ProtocolCompiler.UnitTests/SchemaGeneratorTests/models/CommandWithRequestIntEnum.json 37 codegen/test/ProtocolCompiler.UnitTests/SchemaGeneratorTests/models/CommandWithRequestMap.json 30 codegen/test/ProtocolCompiler.UnitTests/SchemaGeneratorTests/models/CommandWithRequestObject.json 36 codegen/test/ProtocolCompiler.UnitTests/SchemaGeneratorTests/models/CommandWithRequestStringEnum.json 37 codegen/test/ProtocolCompiler.UnitTests/SchemaGeneratorTests/models/CommandWithResponseArray.json 23 codegen/test/ProtocolCompiler.UnitTests/SchemaGeneratorTests/models/CommandWithResponseIntEnum.json 41 codegen/test/ProtocolCompiler.UnitTests/SchemaGeneratorTests/models/CommandWithResponseMap.json 30 codegen/test/ProtocolCompiler.UnitTests/SchemaGeneratorTests/models/CommandWithResponseObject.json 36 codegen/test/ProtocolCompiler.UnitTests/SchemaGeneratorTests/models/CommandWithResponseResult.json 77 codegen/test/ProtocolCompiler.UnitTests/SchemaGeneratorTests/models/CommandWithResponseStringEnum.json 37 codegen/test/ProtocolCompiler.UnitTests/SchemaGeneratorTests/models/CommandWithServiceGroupId.json 37 codegen/test/ProtocolCompiler.UnitTests/SchemaGeneratorTests/models/CommandsExtended.json 85 codegen/test/ProtocolCompiler.UnitTests/SchemaGeneratorTests/models/OneCommand.json 16 codegen/test/ProtocolCompiler.UnitTests/SchemaGeneratorTests/models/OneTelemetry.json 17 codegen/test/ProtocolCompiler.UnitTests/SchemaGeneratorTests/models/TelemetryExtended.json 81 codegen/test/ProtocolCompiler.UnitTests/SchemaGeneratorTests/models/TelemetryNoIndices.json 47 codegen/test/ProtocolCompiler.UnitTests/SchemaGeneratorTests/models/TelemetryObjectNoIndices.json 49 codegen/test/ProtocolCompiler.UnitTests/SchemaGeneratorTests/models/TelemetryObjectSomeIndices.json 53 codegen/test/ProtocolCompiler.UnitTests/SchemaGeneratorTests/models/TelemetryRawSeparate.json 22 codegen/test/ProtocolCompiler.UnitTests/SchemaGeneratorTests/models/TelemetryRawSingle.json 17 codegen/test/ProtocolCompiler.UnitTests/SchemaGeneratorTests/models/TelemetrySomeIndices.json 49 codegen/test/ProtocolCompiler.UnitTests/SchemaGeneratorTests/models/TelemetryStringEnumNoIndices.json 50 codegen/test/ProtocolCompiler.UnitTests/SchemaGeneratorTests/models/TelemetryStringEnumSomeIndices.json 54 codegen/test/ProtocolCompiler.UnitTests/SchemaGeneratorTests/models/TelemetryWithArray.json 20 codegen/test/ProtocolCompiler.UnitTests/SchemaGeneratorTests/models/TelemetryWithIntEnum.json 30 codegen/test/ProtocolCompiler.UnitTests/SchemaGeneratorTests/models/TelemetryWithMap.json 27 codegen/test/ProtocolCompiler.UnitTests/SchemaGeneratorTests/models/TelemetryWithObject.json 29 codegen/test/ProtocolCompiler.UnitTests/SchemaGeneratorTests/models/TelemetryWithServiceGroupId.json 30 codegen/test/ProtocolCompiler.UnitTests/SchemaGeneratorTests/models/TelemetryWithStringEnum.json 30 codegen/test/ProtocolCompiler.UnitTests/SchemaGeneratorTests/models/TwoCommands.json 20 codegen/test/ProtocolCompiler.UnitTests/SchemaGeneratorTests/models/TwoTelemetries.json 22 codegen/test/ProtocolCompiler.UnitTests/ThingGeneratorTests/problematicModels/CommandWithRecursiveRequestObject.json 32 codegen/test/ProtocolCompiler.UnitTests/ThingGeneratorTests/problematicModels/CommandWithRecursiveResponseObject.json 32 codegen/test/ProtocolCompiler.UnitTests/ThingGeneratorTests/problematicModels/TelemetryWithRecursiveObject.json 29 codegen/test/ProtocolCompiler.UnitTests/ThingGeneratorTests/schemas/td-json-schema-validation.json 1318 codegen/test/samples/dotnet/bld.sh 12 codegen/test/samples/dotnet/gen.sh 33 codegen/test/samples/dtdl/CommandComplexSchemas.json 100 codegen/test/samples/dtdl/CommandRaw.json 26 codegen/test/samples/dtdl/CommandVariants.json 46 codegen/test/samples/dtdl/TelemetryAndCommand.json 41 codegen/test/samples/dtdl/TelemetryComplexSchemas.json 139 codegen/test/samples/dtdl/TelemetryNameCollisions.json 96 codegen/test/samples/dtdl/TelemetryPrimitiveSchemas.json 74 codegen/test/samples/dtdl/TelemetryRawSeparate.json 24 codegen/test/samples/dtdl/TelemetryRawSingle.json 19 codegen/test/samples/dtdl/TelemetryRawTogetherShouldFail.json 24 codegen/test/samples/go/bld.sh 1 codegen/test/samples/go/gen.sh 23 codegen/test/samples/go/go.mod 23 codegen/test/samples/json/complex-type-schema.schema.json 101 codegen/test/samples/rust/bld.sh 39 codegen/test/samples/rust/gen.sh 37 doc/README.md 39 doc/akri_connector/README.md 5 doc/components.md 52 doc/dev/README.md 6 doc/dev/adr/0001-generalized-topic-tokens.md 75 doc/dev/adr/0002-src-id-header.md 22 doc/dev/adr/0003-protocol-versioning-0_1.md 13 doc/dev/adr/0004-reserved-user-properties.md 16 doc/dev/adr/0005-logging.md 105 doc/dev/adr/0006-decoupled-caching.md 79 doc/dev/adr/0007-hybrid-logical-clock-timestamp.md 34 doc/dev/adr/0008-protocol-split.md 15 doc/dev/adr/0009-protocol-error-structure.md 10 doc/dev/adr/0010-cloud-event-content-type.md 56 doc/dev/adr/0011-cloud-events-api.md 121 doc/dev/adr/0012-content-type.md 17 doc/dev/adr/0013-codegen-generated-names.md 108 doc/dev/adr/0014-response-topic-prefix.md 29 doc/dev/adr/0015-remove-422-status-code.md 28 doc/dev/adr/0016-response-topic-pattern.md 26 doc/dev/adr/0017-error-refresh.md 40 doc/dev/adr/0018-mandatory-client-id.md 10 doc/dev/adr/0019-codegen-user-errs.md 754 doc/dev/adr/0020-lease-lock-leader.md 96 doc/dev/adr/0021-error-modeling-headers.md 68 doc/dev/adr/0022-codegen-err-headers.md 222 doc/dev/generated/MetlCases.md 133 doc/dev/generated/MetlSpec.md 1085 doc/dev/github.md 51 doc/dev/packaging.md 73 doc/dev/testing/rpc-protocol-testing.md 117 doc/dev/testing/session-client-testing.md 171 doc/dev/testing/telemetry-protocol-testing.md 79 doc/edge_application/README.md 29 doc/edge_application/deploy.md 147 doc/programming-resources.md 17 doc/reference/README.md 32 doc/reference/command-errors.md 146 doc/reference/command-timeouts.md 42 doc/reference/commands.md 72 doc/reference/connection-management.md 56 doc/reference/connection-settings.md 61 doc/reference/error-model.md 464 doc/reference/message-metadata.md 54 doc/reference/package-versioning.md 232 doc/reference/protocol-versioning.md 77 doc/reference/repository-structure.md 96 doc/reference/rpc-protocol.md 66 doc/reference/session-client.md 65 doc/reference/shared-subscriptions.md 27 doc/reference/telemetry.md 37 doc/reference/topic-structure.md 114 doc/retry.md 17 doc/setup.md 148 doc/terminology.md 23 doc/tools.md 27 doc/troubleshooting.md 26 dotnet/README.md 45 dotnet/samples/Connectors/EventDrivenTcpThermostatConnector/AssetEventReceivedEventArgs.cs 16 dotnet/samples/Connectors/EventDrivenTcpThermostatConnector/EventDrivenTcpThermostatConnector.csproj 16 dotnet/samples/Connectors/EventDrivenTcpThermostatConnector/EventDrivenTcpThermostatConnectorWorker.cs 87 dotnet/samples/Connectors/EventDrivenTcpThermostatConnector/KubernetesResources/connector-config.yaml 16 dotnet/samples/Connectors/EventDrivenTcpThermostatConnector/KubernetesResources/tcp-service-asset-definition.yaml 24 dotnet/samples/Connectors/EventDrivenTcpThermostatConnector/KubernetesResources/tcp-service-asset-endpoint-profile-definition.yaml 11 dotnet/samples/Connectors/EventDrivenTcpThermostatConnector/KubernetesResources/tcp-service.yaml 35 dotnet/samples/Connectors/EventDrivenTcpThermostatConnector/LeaderElectionConfigurationProvider.cs 16 dotnet/samples/Connectors/EventDrivenTcpThermostatConnector/Program.cs 15 dotnet/samples/Connectors/EventDrivenTcpThermostatConnector/README.md 22 dotnet/samples/Connectors/EventDrivenTcpThermostatConnector/ThermostatStatus.cs 12 dotnet/samples/Connectors/EventDrivenTcpThermostatConnector/appsettings.Development.json 9 dotnet/samples/Connectors/EventDrivenTcpThermostatConnector/appsettings.json 9 dotnet/samples/Connectors/EventDrivenTcpThermostatConnector/deploy-connector-and-asset.sh 8 dotnet/samples/Connectors/PollingRestThermostatConnector/KubernetesResources/connector-config.yaml 16 dotnet/samples/Connectors/PollingRestThermostatConnector/KubernetesResources/rest-server-asset-definition.yaml 31 dotnet/samples/Connectors/PollingRestThermostatConnector/KubernetesResources/rest-server-asset-endpoint-profile-definition.yaml 16 dotnet/samples/Connectors/PollingRestThermostatConnector/KubernetesResources/rest-server.yaml 55 dotnet/samples/Connectors/PollingRestThermostatConnector/LeaderElectionConfigurationProvider.cs 16 dotnet/samples/Connectors/PollingRestThermostatConnector/PollingRestThermostatConnector.csproj 16 dotnet/samples/Connectors/PollingRestThermostatConnector/Program.cs 16 dotnet/samples/Connectors/PollingRestThermostatConnector/README.md 22 dotnet/samples/Connectors/PollingRestThermostatConnector/RestThermostatDatasetSamplerFactory.cs 28 dotnet/samples/Connectors/PollingRestThermostatConnector/SampleRestServer/package.json 18 dotnet/samples/Connectors/PollingRestThermostatConnector/SampleRestServer/server.js 60 dotnet/samples/Connectors/PollingRestThermostatConnector/ThermostatStatus.cs 12 dotnet/samples/Connectors/PollingRestThermostatConnector/ThermostatStatusDatasetSampler.cs 57 dotnet/samples/Connectors/PollingRestThermostatConnector/appsettings.Development.json 9 dotnet/samples/Connectors/PollingRestThermostatConnector/appsettings.json 9 dotnet/samples/Connectors/PollingRestThermostatConnector/deploy-connector-and-asset.sh 9 dotnet/samples/Connectors/SampleTcpServiceApp/Program.cs 5 dotnet/samples/Connectors/SampleTcpServiceApp/README.md 2 dotnet/samples/Connectors/SampleTcpServiceApp/SampleTcpServiceApp.csproj 12 dotnet/samples/Connectors/SampleTcpServiceApp/ThermostatStatus.cs 12 dotnet/samples/Connectors/SampleTcpServiceApp/Worker.cs 64 dotnet/samples/Connectors/SampleTcpServiceApp/appsettings.Development.json 8 dotnet/samples/Connectors/SampleTcpServiceApp/appsettings.json 8 dotnet/samples/Connectors/SqlConnector/KubernetesResources/connector-config.yaml 16 dotnet/samples/Connectors/SqlConnector/KubernetesResources/sql-server-asset-definition.yaml 29 dotnet/samples/Connectors/SqlConnector/KubernetesResources/sql-server-asset-endpoint-profile-definition.yaml 15 dotnet/samples/Connectors/SqlConnector/KubernetesResources/sql-server-no-data.yaml 102 dotnet/samples/Connectors/SqlConnector/KubernetesResources/sql-server.yaml 162 dotnet/samples/Connectors/SqlConnector/LeaderElectionConfigurationProvider.cs 16 dotnet/samples/Connectors/SqlConnector/Program.cs 17 dotnet/samples/Connectors/SqlConnector/QualityAnalyzerData.cs 18 dotnet/samples/Connectors/SqlConnector/QualityAnalyzerDatasetSampler.cs 76 dotnet/samples/Connectors/SqlConnector/README.md 22 dotnet/samples/Connectors/SqlConnector/SqlQualityAnalyzerConnector.csproj 17 dotnet/samples/Connectors/SqlConnector/SqlQualityAnalyzerDatasetSamplerFactory.cs 25 dotnet/samples/Connectors/SqlConnector/appsettings.Development.json 9 dotnet/samples/Connectors/SqlConnector/appsettings.json 9 dotnet/samples/Connectors/SqlConnector/deploy-connector-and-asset.sh 6 dotnet/samples/Mqtt/SessionClient/LibraryManagedConnectionWorker.cs 40 dotnet/samples/Mqtt/SessionClient/MqttSessionClientFactoryProvider.cs 21 dotnet/samples/Mqtt/SessionClient/Program.cs 9 dotnet/samples/Mqtt/SessionClient/README.md 2 dotnet/samples/Mqtt/SessionClient/SessionClientSample.csproj 14 dotnet/samples/Mqtt/SessionClient/appsettings.Development.json 8 dotnet/samples/Mqtt/SessionClient/appsettings.json 15 dotnet/samples/Protocol/CloudEvents/BytesJsonConverter.cs 17 dotnet/samples/Protocol/CloudEvents/CloudEventsSample.csproj 16 dotnet/samples/Protocol/CloudEvents/DateJsonConverter.cs 18 dotnet/samples/Protocol/CloudEvents/DecimalJsonConverter.cs 18 dotnet/samples/Protocol/CloudEvents/DecimalString.cs 73 dotnet/samples/Protocol/CloudEvents/DurationJsonConverter.cs 18 dotnet/samples/Protocol/CloudEvents/EmptyJson.cs 6 dotnet/samples/Protocol/CloudEvents/MqttSessionClientFactoryProvider.cs 30 dotnet/samples/Protocol/CloudEvents/Oven/OperationSummarySchema.g.cs 21 dotnet/samples/Protocol/CloudEvents/Oven/Oven.g.cs 101 dotnet/samples/Protocol/CloudEvents/Oven/TelemetryCollection.g.cs 21 dotnet/samples/Protocol/CloudEvents/Oven/TelemetryReceiver.g.cs 21 dotnet/samples/Protocol/CloudEvents/Oven/TelemetrySender.g.cs 24 dotnet/samples/Protocol/CloudEvents/OvenSample.json 55 dotnet/samples/Protocol/CloudEvents/OvenService.cs 7 dotnet/samples/Protocol/CloudEvents/OvenTelemetry.schema.json 34 dotnet/samples/Protocol/CloudEvents/Program.cs 11 dotnet/samples/Protocol/CloudEvents/SchemaRegistryClientFactoryProvider.cs 9 dotnet/samples/Protocol/CloudEvents/TimeJsonConverter.cs 18 dotnet/samples/Protocol/CloudEvents/Utf8JsonSerializer.cs 75 dotnet/samples/Protocol/CloudEvents/UuidJsonConverter.cs 17 dotnet/samples/Protocol/CloudEvents/ValueExtractor.cs 13 dotnet/samples/Protocol/CloudEvents/Worker.cs 63 dotnet/samples/Protocol/CloudEvents/appsettings.Development.json 9 dotnet/samples/Protocol/CloudEvents/appsettings.json 16 dotnet/samples/Protocol/CloudEvents/gen.sh 1 dotnet/samples/Protocol/Codegen/SampleClient/CounterClient.cs 15 dotnet/samples/Protocol/Codegen/SampleClient/CustomTopicTokenClient.cs 18 dotnet/samples/Protocol/Codegen/SampleClient/GreeterEnvoyClient.cs 8 dotnet/samples/Protocol/Codegen/SampleClient/MathClient.cs 7 dotnet/samples/Protocol/Codegen/SampleClient/MemMonClient.cs 32 dotnet/samples/Protocol/Codegen/SampleClient/MqttSessionClientFactoryProvider.cs 21 dotnet/samples/Protocol/Codegen/SampleClient/Program.cs 17 dotnet/samples/Protocol/Codegen/SampleClient/RpcCommandRunner.cs 168 dotnet/samples/Protocol/Codegen/SampleClient/SampleClient.csproj 15 dotnet/samples/Protocol/Codegen/SampleClient/appsettings.Development.json 8 dotnet/samples/Protocol/Codegen/SampleClient/appsettings.json 15 dotnet/samples/Protocol/Codegen/SampleServer/CounterService.cs 52 dotnet/samples/Protocol/Codegen/SampleServer/CounterServiceApplicationError.cs 12 dotnet/samples/Protocol/Codegen/SampleServer/CustomTopicTokenService.cs 21 dotnet/samples/Protocol/Codegen/SampleServer/GreeterService.cs 38 dotnet/samples/Protocol/Codegen/SampleServer/MathService.cs 82 dotnet/samples/Protocol/Codegen/SampleServer/MemMonService.cs 86 dotnet/samples/Protocol/Codegen/SampleServer/MqttSessionClientFactoryProvider.cs 21 dotnet/samples/Protocol/Codegen/SampleServer/Program.cs 16 dotnet/samples/Protocol/Codegen/SampleServer/RpcHostBackgroundService.cs 72 dotnet/samples/Protocol/Codegen/SampleServer/SampleServer.csproj 14 dotnet/samples/Protocol/Codegen/SampleServer/appsettings.Development.json 8 dotnet/samples/Protocol/Codegen/SampleServer/appsettings.json 13 dotnet/samples/Protocol/Counter/CounterClient/CounterClient.cs 21 dotnet/samples/Protocol/Counter/CounterClient/CounterClient.csproj 14 dotnet/samples/Protocol/Counter/CounterClient/MqttSessionClientFactoryProvider.cs 21 dotnet/samples/Protocol/Counter/CounterClient/Program.cs 13 dotnet/samples/Protocol/Counter/CounterClient/RpcCommandRunner.cs 64 dotnet/samples/Protocol/Counter/CounterClient/appsettings.Development.json 8 dotnet/samples/Protocol/Counter/CounterClient/appsettings.json 16 dotnet/samples/Protocol/Counter/CounterServer/CounterServer.csproj 14 dotnet/samples/Protocol/Counter/CounterServer/CounterService.cs 44 dotnet/samples/Protocol/Counter/CounterServer/MqttSessionClientFactoryProvider.cs 26 dotnet/samples/Protocol/Counter/CounterServer/Program.cs 12 dotnet/samples/Protocol/Counter/CounterServer/RpcHostBackgroundService.cs 12 dotnet/samples/Protocol/Counter/CounterServer/appsettings.Development.json 8 dotnet/samples/Protocol/Counter/CounterServer/appsettings.json 16 dotnet/samples/Protocol/ReadCloudEvents/BytesJsonConverter.cs 17 dotnet/samples/Protocol/ReadCloudEvents/DateJsonConverter.cs 18 dotnet/samples/Protocol/ReadCloudEvents/DecimalJsonConverter.cs 18 dotnet/samples/Protocol/ReadCloudEvents/DecimalString.cs 73 dotnet/samples/Protocol/ReadCloudEvents/DurationJsonConverter.cs 18 dotnet/samples/Protocol/ReadCloudEvents/EmptyJson.cs 6 dotnet/samples/Protocol/ReadCloudEvents/MqttSessionClientFactoryProvider.cs 30 dotnet/samples/Protocol/ReadCloudEvents/Oven/OperationSummarySchema.g.cs 21 dotnet/samples/Protocol/ReadCloudEvents/Oven/Oven.g.cs 101 dotnet/samples/Protocol/ReadCloudEvents/Oven/TelemetryCollection.g.cs 21 dotnet/samples/Protocol/ReadCloudEvents/Oven/TelemetryReceiver.g.cs 21 dotnet/samples/Protocol/ReadCloudEvents/Oven/TelemetrySender.g.cs 24 dotnet/samples/Protocol/ReadCloudEvents/OvenClient.cs 51 dotnet/samples/Protocol/ReadCloudEvents/OvenSample.json 52 dotnet/samples/Protocol/ReadCloudEvents/Program.cs 12 dotnet/samples/Protocol/ReadCloudEvents/ReadCloudEventsSample.csproj 16 dotnet/samples/Protocol/ReadCloudEvents/SchemaRegistryClientFactoryProvider.cs 9 dotnet/samples/Protocol/ReadCloudEvents/TimeJsonConverter.cs 18 dotnet/samples/Protocol/ReadCloudEvents/Utf8JsonSerializer.cs 75 dotnet/samples/Protocol/ReadCloudEvents/UuidJsonConverter.cs 17 dotnet/samples/Protocol/ReadCloudEvents/ValueExtractor.cs 13 dotnet/samples/Protocol/ReadCloudEvents/Worker.cs 26 dotnet/samples/Protocol/ReadCloudEvents/appsettings.Development.json 9 dotnet/samples/Protocol/ReadCloudEvents/appsettings.json 16 dotnet/samples/Protocol/ReadCloudEvents/gen.sh 1 dotnet/samples/Protocol/TestEnvoys/AvroSerializer.cs 117 dotnet/samples/Protocol/TestEnvoys/BytesJsonConverter.cs 17 dotnet/samples/Protocol/TestEnvoys/Counter/Counter.g.cs 250 dotnet/samples/Protocol/TestEnvoys/Counter/IncrementCommandExecutor.g.cs 28 dotnet/samples/Protocol/TestEnvoys/Counter/IncrementCommandInvoker.g.cs 27 dotnet/samples/Protocol/TestEnvoys/Counter/IncrementRequestPayload.g.cs 16 dotnet/samples/Protocol/TestEnvoys/Counter/IncrementResponsePayload.g.cs 16 dotnet/samples/Protocol/TestEnvoys/Counter/ReadCounterCommandExecutor.g.cs 28 dotnet/samples/Protocol/TestEnvoys/Counter/ReadCounterCommandInvoker.g.cs 27 dotnet/samples/Protocol/TestEnvoys/Counter/ReadCounterResponsePayload.g.cs 16 dotnet/samples/Protocol/TestEnvoys/Counter/ResetCommandExecutor.g.cs 28 dotnet/samples/Protocol/TestEnvoys/Counter/ResetCommandInvoker.g.cs 27 dotnet/samples/Protocol/TestEnvoys/Counter/TelemetryCollection.g.cs 15 dotnet/samples/Protocol/TestEnvoys/Counter/TelemetryReceiver.g.cs 21 dotnet/samples/Protocol/TestEnvoys/Counter/TelemetrySender.g.cs 24 dotnet/samples/Protocol/TestEnvoys/CustomTopicTokens/CustomTopicTokens.g.cs 160 dotnet/samples/Protocol/TestEnvoys/CustomTopicTokens/ReadCustomTopicTokenCommandExecutor.g.cs 28 dotnet/samples/Protocol/TestEnvoys/CustomTopicTokens/ReadCustomTopicTokenCommandInvoker.g.cs 27 dotnet/samples/Protocol/TestEnvoys/CustomTopicTokens/ReadCustomTopicTokenResponsePayload.g.cs 30 dotnet/samples/Protocol/TestEnvoys/CustomTopicTokens/TelemetryCollection.g.cs 15 dotnet/samples/Protocol/TestEnvoys/CustomTopicTokens/TelemetryReceiver.g.cs 21 dotnet/samples/Protocol/TestEnvoys/CustomTopicTokens/TelemetrySender.g.cs 24 dotnet/samples/Protocol/TestEnvoys/DateJsonConverter.cs 18 dotnet/samples/Protocol/TestEnvoys/DecimalJsonConverter.cs 18 dotnet/samples/Protocol/TestEnvoys/DecimalString.cs 73 dotnet/samples/Protocol/TestEnvoys/DurationJsonConverter.cs 18 dotnet/samples/Protocol/TestEnvoys/EmptyAvro.cs 19 dotnet/samples/Protocol/TestEnvoys/EmptyJson.cs 6 dotnet/samples/Protocol/TestEnvoys/Greeter/GreeterEnvoy.g.cs 140 dotnet/samples/Protocol/TestEnvoys/Math/FibCommandExecutor.g.cs 29 dotnet/samples/Protocol/TestEnvoys/Math/FibCommandInvoker.g.cs 27 dotnet/samples/Protocol/TestEnvoys/Math/FibNumbers.cs 188 dotnet/samples/Protocol/TestEnvoys/Math/FibNumbersSchema.cs 189 dotnet/samples/Protocol/TestEnvoys/Math/FibRequest.cs 214 dotnet/samples/Protocol/TestEnvoys/Math/FibRequestPayload.cs 210 dotnet/samples/Protocol/TestEnvoys/Math/FibRequestSchema.cs 214 dotnet/samples/Protocol/TestEnvoys/Math/FibResponse.cs 260 dotnet/samples/Protocol/TestEnvoys/Math/FibResponsePayload.cs 210 dotnet/samples/Protocol/TestEnvoys/Math/FibResponseSchema.cs 260 dotnet/samples/Protocol/TestEnvoys/Math/GetRandomCommandExecutor.g.cs 28 dotnet/samples/Protocol/TestEnvoys/Math/GetRandomCommandInvoker.g.cs 27 dotnet/samples/Protocol/TestEnvoys/Math/GetRandomResponsePayload.cs 200 dotnet/samples/Protocol/TestEnvoys/Math/IsPrimeCommandExecutor.g.cs 29 dotnet/samples/Protocol/TestEnvoys/Math/IsPrimeCommandInvoker.g.cs 27 dotnet/samples/Protocol/TestEnvoys/Math/IsPrimeRequest.cs 309 dotnet/samples/Protocol/TestEnvoys/Math/IsPrimeRequestPayload.cs 210 dotnet/samples/Protocol/TestEnvoys/Math/IsPrimeRequestSchema.cs 309 dotnet/samples/Protocol/TestEnvoys/Math/IsPrimeResponse.cs 496 dotnet/samples/Protocol/TestEnvoys/Math/IsPrimeResponsePayload.cs 211 dotnet/samples/Protocol/TestEnvoys/Math/IsPrimeResponseSchema.cs 497 dotnet/samples/Protocol/TestEnvoys/Math/Math.g.cs 210 dotnet/samples/Protocol/TestEnvoys/Math/Ops.cs 188 dotnet/samples/Protocol/TestEnvoys/Math/OpsSchema.cs 188 dotnet/samples/Protocol/TestEnvoys/Math/RequestSchema.cs 214 dotnet/samples/Protocol/TestEnvoys/Memmon/GetRuntimeStatsCommandExecutor.g.cs 28 dotnet/samples/Protocol/TestEnvoys/Memmon/GetRuntimeStatsCommandInvoker.g.cs 27 dotnet/samples/Protocol/TestEnvoys/Memmon/GetRuntimeStatsRequestPayload.g.cs 31 dotnet/samples/Protocol/TestEnvoys/Memmon/GetRuntimeStatsRequestPayloadSerialization.g.cs 22 dotnet/samples/Protocol/TestEnvoys/Memmon/GetRuntimeStatsRequestSchema.g.cs 11 dotnet/samples/Protocol/TestEnvoys/Memmon/GetRuntimeStatsResponsePayload.g.cs 31 dotnet/samples/Protocol/TestEnvoys/Memmon/GetRuntimeStatsResponsePayloadSerialization.g.cs 24 dotnet/samples/Protocol/TestEnvoys/Memmon/ManagedMemoryTelemetry.g.cs 31 dotnet/samples/Protocol/TestEnvoys/Memmon/ManagedMemoryTelemetryReceiver.g.cs 22 dotnet/samples/Protocol/TestEnvoys/Memmon/ManagedMemoryTelemetrySender.g.cs 25 dotnet/samples/Protocol/TestEnvoys/Memmon/ManagedMemoryTelemetrySerialization.g.cs 18 dotnet/samples/Protocol/TestEnvoys/Memmon/Memmon.g.cs 312 dotnet/samples/Protocol/TestEnvoys/Memmon/MemoryStatsSchema.g.cs 34 dotnet/samples/Protocol/TestEnvoys/Memmon/MemoryStatsTelemetry.g.cs 31 dotnet/samples/Protocol/TestEnvoys/Memmon/MemoryStatsTelemetryReceiver.g.cs 22 dotnet/samples/Protocol/TestEnvoys/Memmon/MemoryStatsTelemetrySender.g.cs 25 dotnet/samples/Protocol/TestEnvoys/Memmon/MemoryStatsTelemetrySerialization.g.cs 41 dotnet/samples/Protocol/TestEnvoys/Memmon/StartTelemetryCommandExecutor.g.cs 28 dotnet/samples/Protocol/TestEnvoys/Memmon/StartTelemetryCommandInvoker.g.cs 27 dotnet/samples/Protocol/TestEnvoys/Memmon/StartTelemetryRequestPayload.g.cs 31 dotnet/samples/Protocol/TestEnvoys/Memmon/StartTelemetryRequestPayloadSerialization.g.cs 18 dotnet/samples/Protocol/TestEnvoys/Memmon/StopTelemetryCommandExecutor.g.cs 28 dotnet/samples/Protocol/TestEnvoys/Memmon/StopTelemetryCommandInvoker.g.cs 27 dotnet/samples/Protocol/TestEnvoys/Memmon/WorkingSetTelemetry.g.cs 31 dotnet/samples/Protocol/TestEnvoys/Memmon/WorkingSetTelemetryReceiver.g.cs 22 dotnet/samples/Protocol/TestEnvoys/Memmon/WorkingSetTelemetrySender.g.cs 25 dotnet/samples/Protocol/TestEnvoys/Memmon/WorkingSetTelemetrySerialization.g.cs 18 dotnet/samples/Protocol/TestEnvoys/Passthrough/PassCommandExecutor.g.cs 28 dotnet/samples/Protocol/TestEnvoys/Passthrough/PassCommandInvoker.g.cs 27 dotnet/samples/Protocol/TestEnvoys/Passthrough/Passthrough.g.cs 120 dotnet/samples/Protocol/TestEnvoys/PassthroughSerializer.cs 40 dotnet/samples/Protocol/TestEnvoys/ProtobufSerializer.cs 84 dotnet/samples/Protocol/TestEnvoys/TestEnvoys.csproj 19 dotnet/samples/Protocol/TestEnvoys/TimeJsonConverter.cs 18 dotnet/samples/Protocol/TestEnvoys/Utf8JsonSerializer.cs 75 dotnet/samples/Protocol/TestEnvoys/UuidJsonConverter.cs 17 dotnet/samples/Protocol/TestEnvoys/ValueExtractor.cs 13 dotnet/samples/Protocol/TestEnvoys/gen-envoys.cmd 7 dotnet/samples/Protocol/TestEnvoys/gen.sh 5 dotnet/samples/Protocol/TestEnvoys/math.json 146 dotnet/samples/Protocol/TestEnvoys/memmon.json 104 dotnet/samples/Protocol/TestEnvoys/passthrough.json 25 dotnet/samples/README.md 41 dotnet/samples/Services/LeasedLockClient/LeasedLockClientSample.csproj 13 dotnet/samples/Services/LeasedLockClient/Program.cs 71 dotnet/samples/Services/PassiveReplication/MqttClientFactoryProvider.cs 18 dotnet/samples/Services/PassiveReplication/PassiveReplicationNode.cs 129 dotnet/samples/Services/PassiveReplication/PassiveReplicationSample.csproj 16 dotnet/samples/Services/PassiveReplication/Program.cs 25 dotnet/samples/Services/PassiveReplication/README.md 57 dotnet/samples/Services/PassiveReplication/deploy.yaml 55 dotnet/samples/Services/PassiveReplication/run-sample.sh 1 dotnet/samples/Services/SchemaRegistryClient/Program.cs 45 dotnet/samples/Services/SchemaRegistryClient/SchemaRegistryClientSample.csproj 23 dotnet/samples/Services/SchemaRegistryClient/appsettings.json 3 dotnet/samples/Services/StateStoreClient/Program.cs 53 dotnet/samples/Services/StateStoreClient/README.md 2 dotnet/samples/Services/StateStoreClient/StateStoreClientSample.csproj 13 dotnet/samples/Services/StateStoreObserveKey/Program.cs 57 dotnet/samples/Services/StateStoreObserveKey/README.md 2 dotnet/samples/Services/StateStoreObserveKey/StateChangeSample.csproj 13 dotnet/samples/applications/EventDrivenApp/Constants.cs 6 dotnet/samples/applications/EventDrivenApp/EventDrivenApp.csproj 17 dotnet/samples/applications/EventDrivenApp/InputWorker.cs 81 dotnet/samples/applications/EventDrivenApp/Models/SensorData.cs 17 dotnet/samples/applications/EventDrivenApp/Models/WindowData.cs 28 dotnet/samples/applications/EventDrivenApp/MqttClientFactoryProvider.cs 21 dotnet/samples/applications/EventDrivenApp/OutputWorker.cs 79 dotnet/samples/applications/EventDrivenApp/Program.cs 10 dotnet/samples/applications/EventDrivenApp/README.md 2 dotnet/samples/applications/EventDrivenApp/Telemetry/SensorTelemetryReceiver.cs 11 dotnet/samples/applications/EventDrivenApp/Telemetry/Utf8JsonSerializer.cs 66 dotnet/samples/applications/EventDrivenApp/Telemetry/WindowTelemetrySender.cs 11 dotnet/samples/applications/EventDrivenApp/app.yaml 54 dotnet/samples/applications/EventDrivenApp/appsettings.Development.json 8 dotnet/samples/applications/EventDrivenApp/appsettings.json 8 dotnet/src/Azure.Iot.Operations.Protocol/api-surface.md 376 dotnet/src/Azure.Iot.Operations.Services/Akri/discovered_resources_commands_v1.json 348 dotnet/src/Azure.Iot.Operations.Services/LeaderElection/README.md 152 dotnet/src/Azure.Iot.Operations.Services/LeasedLock/README.md 148 dotnet/src/Azure.Iot.Operations.Services/StateStore/README.md 50 dotnet/src/Azure.Iot.Operations.Services/api-surface.md 459 dotnet/templates/EventDrivenTelemetryConnector/appsettings.Development.json 9 dotnet/templates/EventDrivenTelemetryConnector/appsettings.json 9 dotnet/templates/PollingTelemetryConnector/appsettings.Development.json 9 dotnet/templates/PollingTelemetryConnector/appsettings.json 9 dotnet/templates/README.md 22 dotnet/test/Azure.Iot.Operations.Protocol.UnitTests/Connection/TestSdkLiteCertKey.txt 5 dotnet/test/Azure.Iot.Operations.Protocol.UnitTests/Connection/TestSdkLiteCertPem.txt 11 dotnet/test/Azure.Iot.Operations.Protocol.UnitTests/Connection/TestSdkLiteCertPwdKey.txt 7 dotnet/test/Azure.Iot.Operations.Protocol.UnitTests/Connection/TestSdkLiteCertPwdPem.txt 11 dotnet/test/Azure.Iot.Operations.Protocol.UnitTests/Connection/TestSdkLiteKeyPwd.txt 1 dotnet/test/Azure.Iot.Operations.Protocol.UnitTests/Connection/TestSdkLitePwd.txt 1 dotnet/test/Azure.Iot.Operations.Protocol.UnitTests/Connection/ca.txt 15 dotnet/test/Azure.Iot.Operations.Protocol.UnitTests/Connection/mypassword.txt 1 dotnet/test/Azure.Iot.Operations.Protocol.UnitTests/Connection/testEnvFiles/defaults.txt 2 dotnet/test/Azure.Iot.Operations.Protocol.UnitTests/Connection/testEnvFiles/invalidInput.txt 7 dotnet/test/Azure.Iot.Operations.Protocol.UnitTests/Connection/testEnvFiles/missingClientId.txt 12 dotnet/test/Azure.Iot.Operations.Protocol.UnitTests/Connection/testEnvFiles/missingHostName.txt 6 dotnet/test/Azure.Iot.Operations.Protocol.UnitTests/Connection/testEnvFiles/validVars.txt 14 dotnet/test/Azure.Iot.Operations.Protocol.UnitTests/Connection/testEnvFiles/validVarsSat.txt 10 dotnet/test/Azure.Iot.Operations.Protocol.UnitTests/Connection/testEnvFiles/validVarsWithCertificateRevocationCheck.txt 14 dotnet/test/Azure.Iot.Operations.Protocol.UnitTests/Connection/testMountTrustedCerts/ca.txt 15 eng/dtdl/SchemaRegistry-1.json 208 eng/dtdl/aep-name-based-operations.json 953 eng/dtdl/aep-type-based-operations.json 116 eng/dtdl/statestore.json 28 eng/test/dummy_credentials/README.md 4 eng/test/dummy_credentials/TestCa.txt 15 eng/test/dummy_credentials/TestCert1Key.txt 5 eng/test/dummy_credentials/TestCert1Pem.txt 11 eng/test/dummy_credentials/TestCert2KeyEncrypted.txt 7 eng/test/dummy_credentials/TestCert2KeyPasswordFile.txt 1 eng/test/dummy_credentials/TestCert2Pem.txt 11 eng/test/dummy_credentials/TestMqttPasswordFile.txt 1 eng/test/faultablemqttbroker/src/Azure.Iot.Operations.FaultableMqttBroker/README.md 17 eng/test/faultablemqttbroker/src/Azure.Iot.Operations.FaultableMqttBroker/appsettings.Development.json 8 eng/test/faultablemqttbroker/src/Azure.Iot.Operations.FaultableMqttBroker/appsettings.json 8 eng/test/schema-registry/src/Azure.Iot.Operations.Services.SchemaRegistry.Host/appsettings.Development.json 9 eng/test/schema-registry/src/Azure.Iot.Operations.Services.SchemaRegistry.Host/appsettings.json 19 eng/test/schema-samples/counter.json 47 eng/test/schema-samples/dtdlWithCustomTopicToken.json 30 eng/test/schema-samples/math.json 146 eng/test/schema-samples/memmon.json 104 eng/test/test-cases/SanityCheck/README.md 16 eng/test/test-cases/schemas/AckKind.schema.json 18 eng/test/test-cases/schemas/ActionAwaitAck.schema.json 18 eng/test/test-cases/schemas/ActionAwaitInvocation.schema.json 36 eng/test/test-cases/schemas/ActionAwaitPublishRequest.schema.json 18 eng/test/test-cases/schemas/ActionAwaitPublishResponse.schema.json 18 eng/test/test-cases/schemas/ActionAwaitPublishTelemetry.schema.json 13 eng/test/test-cases/schemas/ActionAwaitSend.schema.json 18 eng/test/test-cases/schemas/ActionDisconnect.schema.json 13 eng/test/test-cases/schemas/ActionFreezeTime.schema.json 13 eng/test/test-cases/schemas/ActionInvokeCommand.schema.json 52 eng/test/test-cases/schemas/ActionReceiveRequest.schema.json 79 eng/test/test-cases/schemas/ActionReceiveResponse.schema.json 89 eng/test/test-cases/schemas/ActionReceiveTelemetry.schema.json 64 eng/test/test-cases/schemas/ActionSendTelemetry.schema.json 57 eng/test/test-cases/schemas/ActionSleep.schema.json 18 eng/test/test-cases/schemas/ActionSync.schema.json 23 eng/test/test-cases/schemas/ActionUnfreezeTime.schema.json 13 eng/test/test-cases/schemas/Catch.schema.json 50 eng/test/test-cases/schemas/Description.schema.json 16 eng/test/test-cases/schemas/Duration.schema.json 27 eng/test/test-cases/schemas/Executor.schema.json 103 eng/test/test-cases/schemas/ExecutorAction.schema.json 15 eng/test/test-cases/schemas/ExecutorEpilogue.schema.json 52 eng/test/test-cases/schemas/ExecutorPrologue.schema.json 38 eng/test/test-cases/schemas/ExecutorSerializer.schema.json 35 eng/test/test-cases/schemas/ExecutorTestCase.schema.json 34 eng/test/test-cases/schemas/FeatureKind.schema.json 38 eng/test/test-cases/schemas/Invoker.schema.json 50 eng/test/test-cases/schemas/InvokerAction.schema.json 16 eng/test/test-cases/schemas/InvokerEpilogue.schema.json 33 eng/test/test-cases/schemas/InvokerPrologue.schema.json 30 eng/test/test-cases/schemas/InvokerSerializer.schema.json 35 eng/test/test-cases/schemas/InvokerTestCase.schema.json 34 eng/test/test-cases/schemas/MqttConfig.schema.json 12 eng/test/test-cases/schemas/OriginatingCloudEvent.schema.json 43 eng/test/test-cases/schemas/PublishedRequest.schema.json 51 eng/test/test-cases/schemas/PublishedResponse.schema.json 56 eng/test/test-cases/schemas/PublishedTelemetry.schema.json 45 eng/test/test-cases/schemas/PushAcks.schema.json 25 eng/test/test-cases/schemas/ReceivedCloudEvent.schema.json 47 eng/test/test-cases/schemas/ReceivedTelemetry.schema.json 41 eng/test/test-cases/schemas/Receiver.schema.json 35 eng/test/test-cases/schemas/ReceiverAction.schema.json 13 eng/test/test-cases/schemas/ReceiverEpilogue.schema.json 47 eng/test/test-cases/schemas/ReceiverPrologue.schema.json 30 eng/test/test-cases/schemas/ReceiverSerializer.schema.json 25 eng/test/test-cases/schemas/ReceiverTestCase.schema.json 34 eng/test/test-cases/schemas/Sender.schema.json 35 eng/test/test-cases/schemas/SenderAction.schema.json 11 eng/test/test-cases/schemas/SenderEpilogue.schema.json 20 eng/test/test-cases/schemas/SenderPrologue.schema.json 30 eng/test/test-cases/schemas/SenderSerializer.schema.json 17 eng/test/test-cases/schemas/SenderTestCase.schema.json 34 eng/test/test-cases/schemas/Sync.schema.json 17 go/README.md 25 go/internal/README.md 6 go/internal/go.mod 13 go/internal/mqtt/API.md 227 go/mqtt/API.md 659 go/mqtt/README.md 55 go/mqtt/auth/API.md 99 go/mqtt/go.mod 25 go/mqtt/retry/API.md 53 go/protocol/API.md 847 go/protocol/README.md 86 go/protocol/errors/API.md 291 go/protocol/go.mod 23 go/protocol/hlc/API.md 125 go/protocol/iso/API.md 146 go/samples/README.md 43 go/samples/application/eventdrivenapp/README.md 2 go/samples/application/eventdrivenapp/app.yaml 54 go/samples/application/eventdrivenapp/go.mod 27 go/samples/application/eventdrivenapp/main.go 141 go/samples/application/eventdrivenapp/models.go 32 go/samples/application/eventdrivenapp/processing.go 114 go/samples/protocol/cloudevents/client/go.mod 28 go/samples/protocol/cloudevents/client/main.go 63 go/samples/protocol/cloudevents/envoy/gen.sh 2 go/samples/protocol/cloudevents/envoy/go.mod 18 go/samples/protocol/cloudevents/envoy/oven.json 52 go/samples/protocol/cloudevents/envoy/oven/operation_summary_schema.go 9 go/samples/protocol/cloudevents/envoy/oven/telemetry_collection.go 6 go/samples/protocol/cloudevents/envoy/oven/telemetry_receiver.go 30 go/samples/protocol/cloudevents/envoy/oven/telemetry_sender.go 41 go/samples/protocol/cloudevents/envoy/oven/wrapper.go 74 go/samples/protocol/cloudevents/server/go.mod 28 go/samples/protocol/cloudevents/server/main.go 69 go/samples/protocol/counter/client/go.mod 28 go/samples/protocol/counter/client/main.go 71 go/samples/protocol/counter/envoy/counter/increment_command_executor.go 35 go/samples/protocol/counter/envoy/counter/increment_command_invoker.go 54 go/samples/protocol/counter/envoy/counter/increment_request_payload.go 4 go/samples/protocol/counter/envoy/counter/increment_response_payload.go 4 go/samples/protocol/counter/envoy/counter/read_counter_command_executor.go 35 go/samples/protocol/counter/envoy/counter/read_counter_command_invoker.go 53 go/samples/protocol/counter/envoy/counter/read_counter_response_payload.go 4 go/samples/protocol/counter/envoy/counter/reset_command_executor.go 35 go/samples/protocol/counter/envoy/counter/reset_command_invoker.go 53 go/samples/protocol/counter/envoy/counter/telemetry_collection.go 4 go/samples/protocol/counter/envoy/counter/telemetry_receiver.go 30 go/samples/protocol/counter/envoy/counter/telemetry_sender.go 41 go/samples/protocol/counter/envoy/counter/wrapper.go 169 go/samples/protocol/counter/envoy/gen.sh 2 go/samples/protocol/counter/envoy/go.mod 18 go/samples/protocol/counter/server/go.mod 28 go/samples/protocol/counter/server/main.go 118 go/samples/protocol/greeter/client/go.mod 28 go/samples/protocol/greeter/client/main.go 81 go/samples/protocol/greeter/envoy/go.mod 18 go/samples/protocol/greeter/envoy/greeter.go 157 go/samples/protocol/greeter/server/go.mod 28 go/samples/protocol/greeter/server/main.go 74 go/samples/services/leasedlock/go.mod 27 go/samples/services/leasedlock/main.go 82 go/samples/services/schemaregistry/go.mod 27 go/samples/services/schemaregistry/main.go 57 go/samples/services/statestore/go.mod 27 go/samples/services/statestore/main.go 45 go/services/README.md 21 go/services/go.mod 24 go/services/leasedlock/API.md 195 go/services/schemaregistry/API.md 218 go/services/schemaregistry/schemaregistry/API.md 230 go/services/statestore/API.md 393 go/services/statestore/errors/API.md 93 go/test/integration/go.mod 36 go/test/protocol/go.mod 30 rust/README.md 66 rust/azure_iot_operations_mqtt/README.md 73 rust/azure_iot_operations_mqtt/examples/connection_monitor.rs 63 rust/azure_iot_operations_mqtt/examples/custom_reconnect_policy.rs 68 rust/azure_iot_operations_mqtt/examples/manual_ack.rs 115 rust/azure_iot_operations_mqtt/examples/sat_auth.rs 50 rust/azure_iot_operations_mqtt/examples/send_receive.rs 91 rust/azure_iot_operations_mqtt/examples/simple_sample.rs 49 rust/azure_iot_operations_protocol/README.md 10 rust/azure_iot_operations_protocol/examples/rpc_executors_with_shared_subscription.rs 186 rust/azure_iot_operations_protocol/examples/simple_rpc_executor.rs 121 rust/azure_iot_operations_protocol/examples/simple_rpc_invoker.rs 148 rust/azure_iot_operations_protocol/examples/simple_telemetry_receiver.rs 144 rust/azure_iot_operations_protocol/examples/simple_telemetry_sender.rs 105 rust/azure_iot_operations_services/README.md 17 rust/azure_iot_operations_services/examples/leased_lock_client.rs 288 rust/azure_iot_operations_services/examples/schema_registry_client.rs 126 rust/azure_iot_operations_services/examples/state_store_client.rs 100 rust/azure_iot_operations_services/src/schema_registry/schemaregistry_gen/dependencies.md 18 rust/sample_applications/README.md 3 rust/sample_applications/counter/README.md 20 rust/sample_applications/event_driven_app/README.md 2 samples/README.md 50 samples/event_driven_app/README.md 184 samples/event_driven_app/simulator.yaml 71 tools/README.md 2 tools/deployment/README.md 52 tools/statestore-cli/readme-dev.md 25 tools/statestore-cli/readme.md 149