Class ChangeFeedWorker

Namespace

FoundationaLLM.Core.Worker

Assembly

FoundationaLLM.Core.Worker.dll

Background service that runs the Change Feed Processor.

public class ChangeFeedWorker : BackgroundService, IHostedService, IDisposable

Inheritance

object

BackgroundService

ChangeFeedWorker

Implements

IHostedService

IDisposable

Inherited Members

BackgroundService.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()

Extension Methods

ObjectExtensions.GetPropertyValues(object, List<string>)

Constructors

ChangeFeedWorker(ILogger<ChangeFeedWorker>, TelemetryClient, ICosmosDbChangeFeedService)

Instantiates a new instance of the ChangeFeedWorker.

public ChangeFeedWorker(ILogger<ChangeFeedWorker> logger, TelemetryClient telemetryClient, ICosmosDbChangeFeedService cosmosDbChangeFeedService)

Parameters

logger ILogger<ChangeFeedWorker>

The logging interface used to log under the ChangeFeedWorker type name.

telemetryClient TelemetryClient

The telemetry client sends events, metrics, and other telemetry to the App Insights service.

cosmosDbChangeFeedService ICosmosDbChangeFeedService

The Cosmos DB change feed processor that performs the event processing tasks for the worker.

Methods

ExecuteAsync(CancellationToken)

Executes the Change Feed Processor.

protected override Task ExecuteAsync(CancellationToken stoppingToken)

Parameters

stoppingToken CancellationToken

Returns

Task