Class PollingTelemetryConnectorWorker

Namespace

Azure.Iot.Operations.Connector

Assembly

Azure.Iot.Operations.Connector.dll

public class PollingTelemetryConnectorWorker : ConnectorWorker, IHostedService, IDisposable

Inheritance

object

BackgroundService

ConnectorBackgroundService

ConnectorWorker

PollingTelemetryConnectorWorker

Implements

IHostedService

IDisposable

Inherited Members

ConnectorWorker._logger

ConnectorWorker._adrClient

ConnectorWorker.WhileDeviceIsAvailable

ConnectorWorker.WhileAssetIsAvailable

ConnectorWorker.RunConnectorAsync(CancellationToken)

ConnectorWorker.ExecuteAsync(CancellationToken)

ConnectorWorker.ForwardSampledDatasetAsync(string, string, Asset, string, AssetDataset, byte[], Dictionary<string, string>, CancellationToken)

ConnectorWorker.ForwardReceivedEventAsync(string, string, Asset, string, AssetEvent, byte[], Dictionary<string, string>, CancellationToken)

ConnectorWorker.Dispose()

BackgroundService.StartAsync(CancellationToken)

BackgroundService.StopAsync(CancellationToken)

BackgroundService.ExecuteTask

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Constructors

PollingTelemetryConnectorWorker(ApplicationContext, ILogger<ConnectorWorker>, IMqttClient, IDatasetSamplerFactory, IMessageSchemaProvider, IAdrClientWrapperProvider, IConnectorLeaderElectionConfigurationProvider?)

public PollingTelemetryConnectorWorker(ApplicationContext applicationContext, ILogger<ConnectorWorker> logger, IMqttClient mqttClient, IDatasetSamplerFactory datasetSamplerFactory, IMessageSchemaProvider messageSchemaFactory, IAdrClientWrapperProvider adrClientFactory, IConnectorLeaderElectionConfigurationProvider? leaderElectionConfigurationProvider = null)

Parameters

applicationContext ApplicationContext

logger ILogger<ConnectorWorker>

mqttClient IMqttClient

datasetSamplerFactory IDatasetSamplerFactory

messageSchemaFactory IMessageSchemaProvider

adrClientFactory IAdrClientWrapperProvider

leaderElectionConfigurationProvider IConnectorLeaderElectionConfigurationProvider

Methods

WhileAssetAvailableAsync(AssetAvailableEventArgs, CancellationToken)

public Task WhileAssetAvailableAsync(AssetAvailableEventArgs args, CancellationToken cancellationToken)

Parameters

args AssetAvailableEventArgs

cancellationToken CancellationToken

Returns

Task