Path Lines of Code dotnet/Directory.Build.props 9 dotnet/src/Azure.Iot.Operations.Connector/AssetAvailabileEventArgs.cs 17 dotnet/src/Azure.Iot.Operations.Connector/AssetMonitorFactoryProvider.cs 12 dotnet/src/Azure.Iot.Operations.Connector/AssetUnavailableEventArgs.cs 12 dotnet/src/Azure.Iot.Operations.Connector/ConnectorBackgroundService.cs 9 dotnet/src/Azure.Iot.Operations.Connector/ConnectorLeaderElectionConfiguration.cs 22 dotnet/src/Azure.Iot.Operations.Connector/ConnectorMessageSchema.cs 27 dotnet/src/Azure.Iot.Operations.Connector/Exceptions/AssetConfigurationException.cs 22 dotnet/src/Azure.Iot.Operations.Connector/IConnectorLeaderElectionConfigurationProvider.cs 8 dotnet/src/Azure.Iot.Operations.Connector/IDatasetSampler.cs 9 dotnet/src/Azure.Iot.Operations.Connector/IDatasetSamplerFactory.cs 9 dotnet/src/Azure.Iot.Operations.Connector/IMessageSchemaProvider.cs 10 dotnet/src/Azure.Iot.Operations.Connector/MqttSessionClientFactoryProvider.cs 27 dotnet/src/Azure.Iot.Operations.Connector/NoMessageSchemaProvider.cs 24 dotnet/src/Azure.Iot.Operations.Connector/PollingTelemetryConnectorWorker.cs 85 dotnet/src/Azure.Iot.Operations.Connector/TelemetryConnectorWorker.cs 303 dotnet/src/Azure.Iot.Operations.Mqtt/BlockingConcurrentDelayableQueue.cs 64 dotnet/src/Azure.Iot.Operations.Mqtt/BuildConfiguration.cs 4 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/GenericMqttClientCertificatesProvider.cs 15 dotnet/src/Azure.Iot.Operations.Mqtt/Converters/GenericMqttClientCredentialsProvider.cs 23 dotnet/src/Azure.Iot.Operations.Mqtt/Converters/GenericMqttEnhancedAuthenticationHandler.cs 33 dotnet/src/Azure.Iot.Operations.Mqtt/Converters/MqttNetCertificateSelectionHandler.cs 18 dotnet/src/Azure.Iot.Operations.Mqtt/Converters/MqttNetCertificateValidationHandler.cs 17 dotnet/src/Azure.Iot.Operations.Mqtt/Converters/MqttNetConverter.cs 521 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/MqttNetMqttClientCredentialsProvider.cs 23 dotnet/src/Azure.Iot.Operations.Mqtt/Converters/MqttNetMqttEnhancedAuthenticationHandler.cs 23 dotnet/src/Azure.Iot.Operations.Mqtt/IDelayableQueueItem.cs 9 dotnet/src/Azure.Iot.Operations.Mqtt/MqttConnectingFailedException.cs 15 dotnet/src/Azure.Iot.Operations.Mqtt/MqttNetTraceLogger.cs 22 dotnet/src/Azure.Iot.Operations.Mqtt/OrderedAckMqttClient.cs 269 dotnet/src/Azure.Iot.Operations.Mqtt/OrderedAckMqttClientOptions.cs 12 dotnet/src/Azure.Iot.Operations.Mqtt/QueuedMqttApplicationMessageReceivedEventArgs.cs 23 dotnet/src/Azure.Iot.Operations.Mqtt/SatEnhancedAuthenticationHandler.cs 21 dotnet/src/Azure.Iot.Operations.Mqtt/Session/BlockingConcurrentList.cs 158 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/MqttSessionClientOptions.cs 32 dotnet/src/Azure.Iot.Operations.Mqtt/Session/MqttSessionExpiredException.cs 16 dotnet/src/Azure.Iot.Operations.Mqtt/Session/QueuedPublishRequest.cs 23 dotnet/src/Azure.Iot.Operations.Mqtt/Session/QueuedRequest.cs 14 dotnet/src/Azure.Iot.Operations.Mqtt/Session/QueuedSubscribeRequest.cs 23 dotnet/src/Azure.Iot.Operations.Mqtt/Session/QueuedUnsubscribeRequest.cs 23 dotnet/src/Azure.Iot.Operations.Mqtt/TokenRefreshTimer.cs 63 dotnet/src/Azure.Iot.Operations.Protocol/AkriMqttErrorKind.cs 20 dotnet/src/Azure.Iot.Operations.Protocol/AkriMqttException.cs 78 dotnet/src/Azure.Iot.Operations.Protocol/AkriSystemProperties.cs 34 dotnet/src/Azure.Iot.Operations.Protocol/ApplicationContext.cs 24 dotnet/src/Azure.Iot.Operations.Protocol/AttributeRetriever.cs 26 dotnet/src/Azure.Iot.Operations.Protocol/BuildConfiguration.cs 5 dotnet/src/Azure.Iot.Operations.Protocol/CommandBehaviorAttribute.cs 11 dotnet/src/Azure.Iot.Operations.Protocol/CommandTopicAttribute.cs 10 dotnet/src/Azure.Iot.Operations.Protocol/Connection/MqttConnectionSettings.cs 352 dotnet/src/Azure.Iot.Operations.Protocol/Connection/StringToDictionaryExtension.cs 32 dotnet/src/Azure.Iot.Operations.Protocol/Connection/X509ClientCertificateLocator.cs 21 dotnet/src/Azure.Iot.Operations.Protocol/Dispatcher.cs 7 dotnet/src/Azure.Iot.Operations.Protocol/Events/MqttApplicationMessageReceivedEventArgs.cs 32 dotnet/src/Azure.Iot.Operations.Protocol/Events/MqttClientConnectedEventArgs.cs 10 dotnet/src/Azure.Iot.Operations.Protocol/Events/MqttClientDisconnectedEventArgs.cs 22 dotnet/src/Azure.Iot.Operations.Protocol/ExecutionDispatcher.cs 48 dotnet/src/Azure.Iot.Operations.Protocol/ExecutionDispatcherCollection.cs 52 dotnet/src/Azure.Iot.Operations.Protocol/GuidExtensions.cs 26 dotnet/src/Azure.Iot.Operations.Protocol/HybridLogicalClock.cs 244 dotnet/src/Azure.Iot.Operations.Protocol/HybridLogicalClockException.cs 10 dotnet/src/Azure.Iot.Operations.Protocol/IMqttClient.cs 21 dotnet/src/Azure.Iot.Operations.Protocol/IMqttPubSubClient.cs 19 dotnet/src/Azure.Iot.Operations.Protocol/IPayloadSerializer.cs 11 dotnet/src/Azure.Iot.Operations.Protocol/IWallClock.cs 13 dotnet/src/Azure.Iot.Operations.Protocol/Models/DefaultMqttCertificatesProvider.cs 29 dotnet/src/Azure.Iot.Operations.Protocol/Models/IMqttClientCertificatesProvider.cs 9 dotnet/src/Azure.Iot.Operations.Protocol/Models/IMqttClientChannelOptions.cs 8 dotnet/src/Azure.Iot.Operations.Protocol/Models/IMqttClientCredentialsProvider.cs 9 dotnet/src/Azure.Iot.Operations.Protocol/Models/IMqttEnhancedAuthenticationHandler.cs 9 dotnet/src/Azure.Iot.Operations.Protocol/Models/MqttApplicationMessage.cs 82 dotnet/src/Azure.Iot.Operations.Protocol/Models/MqttApplicationMessageReceivedReasonCode.cs 16 dotnet/src/Azure.Iot.Operations.Protocol/Models/MqttAuthPacket.cs 13 dotnet/src/Azure.Iot.Operations.Protocol/Models/MqttAuthenticateReasonCode.cs 10 dotnet/src/Azure.Iot.Operations.Protocol/Models/MqttClientCertificateSelectionEventArgs.cs 19 dotnet/src/Azure.Iot.Operations.Protocol/Models/MqttClientCertificateValidationEventArgs.cs 14 dotnet/src/Azure.Iot.Operations.Protocol/Models/MqttClientConnectResult.cs 27 dotnet/src/Azure.Iot.Operations.Protocol/Models/MqttClientConnectResultCode.cs 29 dotnet/src/Azure.Iot.Operations.Protocol/Models/MqttClientCredentials.cs 17 dotnet/src/Azure.Iot.Operations.Protocol/Models/MqttClientDisconnectOptions.cs 17 dotnet/src/Azure.Iot.Operations.Protocol/Models/MqttClientDisconnectOptionsReason.cs 21 dotnet/src/Azure.Iot.Operations.Protocol/Models/MqttClientDisconnectReason.cs 36 dotnet/src/Azure.Iot.Operations.Protocol/Models/MqttClientOptions.cs 145 dotnet/src/Azure.Iot.Operations.Protocol/Models/MqttClientPublishReasonCode.cs 15 dotnet/src/Azure.Iot.Operations.Protocol/Models/MqttClientPublishResult.cs 12 dotnet/src/Azure.Iot.Operations.Protocol/Models/MqttClientSubscribeOptions.cs 26 dotnet/src/Azure.Iot.Operations.Protocol/Models/MqttClientSubscribeReasonCode.cs 18 dotnet/src/Azure.Iot.Operations.Protocol/Models/MqttClientSubscribeResult.cs 65 dotnet/src/Azure.Iot.Operations.Protocol/Models/MqttClientSubscribeResultItem.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/MqttClientUnsubscribeOptions.cs 25 dotnet/src/Azure.Iot.Operations.Protocol/Models/MqttClientUnsubscribeReasonCode.cs 13 dotnet/src/Azure.Iot.Operations.Protocol/Models/MqttClientUnsubscribeResult.cs 60 dotnet/src/Azure.Iot.Operations.Protocol/Models/MqttClientUnsubscribeResultItem.cs 9 dotnet/src/Azure.Iot.Operations.Protocol/Models/MqttClientWebSocketOptions.cs 24 dotnet/src/Azure.Iot.Operations.Protocol/Models/MqttClientWebSocketProxyOptions.cs 14 dotnet/src/Azure.Iot.Operations.Protocol/Models/MqttEnhancedAuthenticationEventArgs.cs 22 dotnet/src/Azure.Iot.Operations.Protocol/Models/MqttEnhancedAuthenticationExchangeData.cs 12 dotnet/src/Azure.Iot.Operations.Protocol/Models/MqttExtendedAuthenticationExchangeContext.cs 13 dotnet/src/Azure.Iot.Operations.Protocol/Models/MqttPayloadFormatIndicator.cs 8 dotnet/src/Azure.Iot.Operations.Protocol/Models/MqttPendingMessagesOverflowStrategy.cs 9 dotnet/src/Azure.Iot.Operations.Protocol/Models/MqttProtocolVersion.cs 11 dotnet/src/Azure.Iot.Operations.Protocol/Models/MqttQualityOfServiceLevel.cs 9 dotnet/src/Azure.Iot.Operations.Protocol/Models/MqttRetainHandling.cs 9 dotnet/src/Azure.Iot.Operations.Protocol/Models/MqttTopicFilter.cs 11 dotnet/src/Azure.Iot.Operations.Protocol/Models/MqttTopicFilterCompareResult.cs 11 dotnet/src/Azure.Iot.Operations.Protocol/Models/MqttTopicFilterComparer.cs 123 dotnet/src/Azure.Iot.Operations.Protocol/Models/MqttUserProperty.cs 9 dotnet/src/Azure.Iot.Operations.Protocol/Models/ProtocolVersion.cs 60 dotnet/src/Azure.Iot.Operations.Protocol/MqttTopicProcessor.cs 142 dotnet/src/Azure.Iot.Operations.Protocol/MqttUserPropertyListExtension.cs 23 dotnet/src/Azure.Iot.Operations.Protocol/PatternValidity.cs 12 dotnet/src/Azure.Iot.Operations.Protocol/RPC/CommandExecutor.cs 568 dotnet/src/Azure.Iot.Operations.Protocol/RPC/CommandInvoker.cs 624 dotnet/src/Azure.Iot.Operations.Protocol/RPC/CommandRequestMetadata.cs 75 dotnet/src/Azure.Iot.Operations.Protocol/RPC/CommandResponseCache.cs 270 dotnet/src/Azure.Iot.Operations.Protocol/RPC/CommandResponseMetadata.cs 58 dotnet/src/Azure.Iot.Operations.Protocol/RPC/CommandStatusCode.cs 14 dotnet/src/Azure.Iot.Operations.Protocol/RPC/CommandVersion.cs 9 dotnet/src/Azure.Iot.Operations.Protocol/RPC/ExtendedRequest.cs 10 dotnet/src/Azure.Iot.Operations.Protocol/RPC/ExtendedResponse.cs 68 dotnet/src/Azure.Iot.Operations.Protocol/RPC/ICommandResponseCache.cs 15 dotnet/src/Azure.Iot.Operations.Protocol/RPC/RpcCallAsync.cs 33 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/Retry/NoRetryPolicy.cs 15 dotnet/src/Azure.Iot.Operations.Protocol/Retry/RetryExpiredException.cs 17 dotnet/src/Azure.Iot.Operations.Protocol/SerializedPayloadContext.cs 12 dotnet/src/Azure.Iot.Operations.Protocol/ServiceGroupIdAttribute.cs 10 dotnet/src/Azure.Iot.Operations.Protocol/Telemetry/CloudEvent.cs 16 dotnet/src/Azure.Iot.Operations.Protocol/Telemetry/IncomingTelemetryMetadata.cs 93 dotnet/src/Azure.Iot.Operations.Protocol/Telemetry/OutgoingTelemetryMetadata.cs 16 dotnet/src/Azure.Iot.Operations.Protocol/Telemetry/TelemetryReceiver.cs 209 dotnet/src/Azure.Iot.Operations.Protocol/Telemetry/TelemetrySender.cs 184 dotnet/src/Azure.Iot.Operations.Protocol/Telemetry/TelemetryVersion.cs 9 dotnet/src/Azure.Iot.Operations.Protocol/TelemetryTopicAttribute.cs 10 dotnet/src/Azure.Iot.Operations.Protocol/WallClock.cs 19 dotnet/src/Azure.Iot.Operations.Services/Akri/Common/BytesJsonConverter.cs 17 dotnet/src/Azure.Iot.Operations.Services/Akri/Common/DateJsonConverter.cs 18 dotnet/src/Azure.Iot.Operations.Services/Akri/Common/DecimalJsonConverter.cs 18 dotnet/src/Azure.Iot.Operations.Services/Akri/Common/DecimalString.cs 73 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/TimeJsonConverter.cs 18 dotnet/src/Azure.Iot.Operations.Services/Akri/Common/Utf8JsonSerializer.cs 75 dotnet/src/Azure.Iot.Operations.Services/Akri/Common/UuidJsonConverter.cs 17 dotnet/src/Azure.Iot.Operations.Services/Akri/Common/ValueExtractor.cs 13 dotnet/src/Azure.Iot.Operations.Services/Akri/DiscoveredAssetResources/CreateDiscoveredAssetCommandExecutor.g.cs 28 dotnet/src/Azure.Iot.Operations.Services/Akri/DiscoveredAssetResources/CreateDiscoveredAssetCommandInvoker.g.cs 27 dotnet/src/Azure.Iot.Operations.Services/Akri/DiscoveredAssetResources/CreateDiscoveredAssetEndpointProfileCommandExecutor.g.cs 28 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/CreateDiscoveredAssetEndpointProfileRequestSchema.g.cs 27 dotnet/src/Azure.Iot.Operations.Services/Akri/DiscoveredAssetResources/CreateDiscoveredAssetEndpointProfileResponsePayload.g.cs 30 dotnet/src/Azure.Iot.Operations.Services/Akri/DiscoveredAssetResources/CreateDiscoveredAssetEndpointProfileResponseSchema.g.cs 15 dotnet/src/Azure.Iot.Operations.Services/Akri/DiscoveredAssetResources/CreateDiscoveredAssetRequestPayload.g.cs 30 dotnet/src/Azure.Iot.Operations.Services/Akri/DiscoveredAssetResources/CreateDiscoveredAssetRequestSchema.g.cs 57 dotnet/src/Azure.Iot.Operations.Services/Akri/DiscoveredAssetResources/CreateDiscoveredAssetResponsePayload.g.cs 30 dotnet/src/Azure.Iot.Operations.Services/Akri/DiscoveredAssetResources/CreateDiscoveredAssetResponseSchema.g.cs 15 dotnet/src/Azure.Iot.Operations.Services/Akri/DiscoveredAssetResources/DataPointsSchemaElementSchema.g.cs 24 dotnet/src/Azure.Iot.Operations.Services/Akri/DiscoveredAssetResources/DatasetsSchemaElementSchema.g.cs 24 dotnet/src/Azure.Iot.Operations.Services/Akri/DiscoveredAssetResources/DefaultTopicSchema.g.cs 18 dotnet/src/Azure.Iot.Operations.Services/Akri/DiscoveredAssetResources/DiscoveredAssetResources.g.cs 164 dotnet/src/Azure.Iot.Operations.Services/Akri/DiscoveredAssetResources/DiscoveredTopicRetain.g.cs 12 dotnet/src/Azure.Iot.Operations.Services/Akri/DiscoveredAssetResources/EventsSchemaElementSchema.g.cs 27 dotnet/src/Azure.Iot.Operations.Services/Akri/DiscoveredAssetResources/StatusSchema.g.cs 14 dotnet/src/Azure.Iot.Operations.Services/Akri/DiscoveredAssetResources/SupportedAuthenticationMethodsSchemaElementSchema.g.cs 14 dotnet/src/Azure.Iot.Operations.Services/Akri/DiscoveredAssetResources/TopicSchema.g.cs 18 dotnet/src/Azure.Iot.Operations.Services/Akri/DiscoveredAssetResourcesClient.cs 49 dotnet/src/Azure.Iot.Operations.Services/Akri/DiscoveredAssetResourcesClientStub.cs 6 dotnet/src/Azure.Iot.Operations.Services/Akri/IDiscoveredAssetResourcesClient.cs 18 dotnet/src/Azure.Iot.Operations.Services/Akri/gen.cmd 4 dotnet/src/Azure.Iot.Operations.Services/Assets/Asset.cs 223 dotnet/src/Azure.Iot.Operations.Services/Assets/AssetChangedEventArgs.cs 16 dotnet/src/Azure.Iot.Operations.Services/Assets/AssetEndpointProfile.cs 20 dotnet/src/Azure.Iot.Operations.Services/Assets/AssetEndpointProfileChangedEventArgs.cs 14 dotnet/src/Azure.Iot.Operations.Services/Assets/AssetEndpointProfileCredentials.cs 16 dotnet/src/Azure.Iot.Operations.Services/Assets/AssetMonitor.cs 224 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/FilesMonitor/FileChangedEventArgs.cs 21 dotnet/src/Azure.Iot.Operations.Services/Assets/FilesMonitor/FilesMonitor.cs 108 dotnet/src/Azure.Iot.Operations.Services/Assets/IAssetMonitor.cs 16 dotnet/src/Azure.Iot.Operations.Services/Assets/JsonDocumentConverter.cs 20 dotnet/src/Azure.Iot.Operations.Services/BuildConfiguration.cs 3 dotnet/src/Azure.Iot.Operations.Services/LeaderElection/CampaignRequestOptions.cs 8 dotnet/src/Azure.Iot.Operations.Services/LeaderElection/CampaignResponse.cs 15 dotnet/src/Azure.Iot.Operations.Services/LeaderElection/GetCurrentLeaderResponse.cs 12 dotnet/src/Azure.Iot.Operations.Services/LeaderElection/ILeaderElectionClient.cs 19 dotnet/src/Azure.Iot.Operations.Services/LeaderElection/LeaderElectionAutomaticRenewalOptions.cs 10 dotnet/src/Azure.Iot.Operations.Services/LeaderElection/LeaderElectionCandidate.cs 66 dotnet/src/Azure.Iot.Operations.Services/LeaderElection/LeaderElectionClient.cs 196 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/ResignationRequestOptions.cs 9 dotnet/src/Azure.Iot.Operations.Services/LeaderElection/ResignationResponse.cs 12 dotnet/src/Azure.Iot.Operations.Services/LeasedLock/AcquireLockRequestOptions.cs 8 dotnet/src/Azure.Iot.Operations.Services/LeasedLock/AcquireLockResponse.cs 18 dotnet/src/Azure.Iot.Operations.Services/LeasedLock/GetLockHolderResponse.cs 12 dotnet/src/Azure.Iot.Operations.Services/LeasedLock/LeasedLockAutomaticRenewalOptions.cs 10 dotnet/src/Azure.Iot.Operations.Services/LeasedLock/LeasedLockClient.cs 357 dotnet/src/Azure.Iot.Operations.Services/LeasedLock/LeasedLockHolder.cs 66 dotnet/src/Azure.Iot.Operations.Services/LeasedLock/LockChangeEventArgs.cs 16 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/ReleaseLockResponse.cs 12 dotnet/src/Azure.Iot.Operations.Services/LeasedLock/RetryPolicyWithAutoReset.cs 34 dotnet/src/Azure.Iot.Operations.Services/SchemaRegistry/Common/BytesJsonConverter.cs 17 dotnet/src/Azure.Iot.Operations.Services/SchemaRegistry/Common/DateJsonConverter.cs 18 dotnet/src/Azure.Iot.Operations.Services/SchemaRegistry/Common/DecimalJsonConverter.cs 18 dotnet/src/Azure.Iot.Operations.Services/SchemaRegistry/Common/DecimalString.cs 73 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/TimeJsonConverter.cs 18 dotnet/src/Azure.Iot.Operations.Services/SchemaRegistry/Common/Utf8JsonSerializer.cs 75 dotnet/src/Azure.Iot.Operations.Services/SchemaRegistry/Common/UuidJsonConverter.cs 17 dotnet/src/Azure.Iot.Operations.Services/SchemaRegistry/Common/ValueExtractor.cs 13 dotnet/src/Azure.Iot.Operations.Services/SchemaRegistry/ISchemaRegistryClient.cs 10 dotnet/src/Azure.Iot.Operations.Services/SchemaRegistry/SchemaRegistry/Format.g.cs 12 dotnet/src/Azure.Iot.Operations.Services/SchemaRegistry/SchemaRegistry/GetCommandExecutor.g.cs 29 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/GetRequestSchema.g.cs 18 dotnet/src/Azure.Iot.Operations.Services/SchemaRegistry/SchemaRegistry/GetResponsePayload.g.cs 15 dotnet/src/Azure.Iot.Operations.Services/SchemaRegistry/SchemaRegistry/PutCommandExecutor.g.cs 28 dotnet/src/Azure.Iot.Operations.Services/SchemaRegistry/SchemaRegistry/PutCommandInvoker.g.cs 27 dotnet/src/Azure.Iot.Operations.Services/SchemaRegistry/SchemaRegistry/PutRequestPayload.g.cs 30 dotnet/src/Azure.Iot.Operations.Services/SchemaRegistry/SchemaRegistry/PutRequestSchema.g.cs 33 dotnet/src/Azure.Iot.Operations.Services/SchemaRegistry/SchemaRegistry/PutResponsePayload.g.cs 30 dotnet/src/Azure.Iot.Operations.Services/SchemaRegistry/SchemaRegistry/Schema.g.cs 42 dotnet/src/Azure.Iot.Operations.Services/SchemaRegistry/SchemaRegistry/SchemaRegistry.g.cs 163 dotnet/src/Azure.Iot.Operations.Services/SchemaRegistry/SchemaRegistry/SchemaType.g.cs 10 dotnet/src/Azure.Iot.Operations.Services/SchemaRegistry/SchemaRegistryClient.cs 83 dotnet/src/Azure.Iot.Operations.Services/SchemaRegistry/SchemaRegistryClientStub.cs 6 dotnet/src/Azure.Iot.Operations.Services/SchemaRegistry/SchemaRegistryServiceException.cs 29 dotnet/src/Azure.Iot.Operations.Services/SchemaRegistry/gen.cmd 4 dotnet/src/Azure.Iot.Operations.Services/StateStore/IStateStoreClient.cs 14 dotnet/src/Azure.Iot.Operations.Services/StateStore/IStateStoreClientStub.cs 9 dotnet/src/Azure.Iot.Operations.Services/StateStore/KeyChangeMessageReceivedEventArgs.cs 18 dotnet/src/Azure.Iot.Operations.Services/StateStore/KeyState.cs 9 dotnet/src/Azure.Iot.Operations.Services/StateStore/RESP3/Resp3ArrayBuilder.cs 21 dotnet/src/Azure.Iot.Operations.Services/StateStore/RESP3/Resp3Protocol.cs 261 dotnet/src/Azure.Iot.Operations.Services/StateStore/RESP3/Resp3ProtocolException.cs 12 dotnet/src/Azure.Iot.Operations.Services/StateStore/RESP3/Resp3SimpleErrorException.cs 13 dotnet/src/Azure.Iot.Operations.Services/StateStore/SetCondition.cs 10 dotnet/src/Azure.Iot.Operations.Services/StateStore/StateStoreClient.cs 293 dotnet/src/Azure.Iot.Operations.Services/StateStore/StateStoreClientStub.cs 11 dotnet/src/Azure.Iot.Operations.Services/StateStore/StateStoreDeleteRequestOptions.cs 10 dotnet/src/Azure.Iot.Operations.Services/StateStore/StateStoreDeleteResponse.cs 12 dotnet/src/Azure.Iot.Operations.Services/StateStore/StateStoreGen/InvokeCommandExecutor.g.cs 28 dotnet/src/Azure.Iot.Operations.Services/StateStore/StateStoreGen/InvokeCommandInvoker.g.cs 27 dotnet/src/Azure.Iot.Operations.Services/StateStore/StateStoreGen/PassthroughSerializer.cs 40 dotnet/src/Azure.Iot.Operations.Services/StateStore/StateStoreGen/StateStore.g.cs 119 dotnet/src/Azure.Iot.Operations.Services/StateStore/StateStoreGeneratedClient.cs 11 dotnet/src/Azure.Iot.Operations.Services/StateStore/StateStoreGetResponse.cs 14 dotnet/src/Azure.Iot.Operations.Services/StateStore/StateStoreKey.cs 35 dotnet/src/Azure.Iot.Operations.Services/StateStore/StateStoreKeyNotification.cs 19 dotnet/src/Azure.Iot.Operations.Services/StateStore/StateStoreObject.cs 104 dotnet/src/Azure.Iot.Operations.Services/StateStore/StateStoreOperationException.cs 78 dotnet/src/Azure.Iot.Operations.Services/StateStore/StateStorePayloadParser.cs 195 dotnet/src/Azure.Iot.Operations.Services/StateStore/StateStoreResponse.cs 13 dotnet/src/Azure.Iot.Operations.Services/StateStore/StateStoreSetRequestOptions.cs 11 dotnet/src/Azure.Iot.Operations.Services/StateStore/StateStoreSetResponse.cs 14 dotnet/src/Azure.Iot.Operations.Services/StateStore/StateStoreValue.cs 33 dotnet/src/Azure.Iot.Operations.Services/StateStore/gen.cmd 7 dotnet/templates/EventDrivenTelemetryConnector/ConnectorWorker.cs 43 dotnet/templates/EventDrivenTelemetryConnector/LeaderElectionConfigurationProvider.cs 16 dotnet/templates/EventDrivenTelemetryConnector/MessageSchemaProvider.cs 21 dotnet/templates/EventDrivenTelemetryConnector/Program.cs 15 dotnet/templates/PollingTelemetryConnector/DatasetSampler.cs 13 dotnet/templates/PollingTelemetryConnector/DatasetSamplerFactory.cs 17 dotnet/templates/PollingTelemetryConnector/LeaderElectionConfigurationProvider.cs 16 dotnet/templates/PollingTelemetryConnector/MessageSchemaProvider.cs 21 dotnet/templates/PollingTelemetryConnector/Program.cs 16