Class AzureCosmosDBChangeFeedService

Namespace

FoundationaLLM.Core.Services

Assembly

FoundationaLLM.Core.dll

Supports all classes in the .NET class hierarchy and provides low-level services to derived classes. This is the ultimate base class of all .NET classes; it is the root of the type hierarchy.

public class AzureCosmosDBChangeFeedService : ICosmosDbChangeFeedService

Inheritance

object

AzureCosmosDBChangeFeedService

Implements

ICosmosDbChangeFeedService

Inherited Members

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

AzureCosmosDBChangeFeedService(ILogger<AzureCosmosDBChangeFeedService>, IAzureCosmosDBService, IOptions<AzureCosmosDBSettings>)

Initializes a new instance of the AzureCosmosDBChangeFeedService class.

public AzureCosmosDBChangeFeedService(ILogger<AzureCosmosDBChangeFeedService> logger, IAzureCosmosDBService cosmosDBService, IOptions<AzureCosmosDBSettings> settings)

Parameters

logger ILogger<AzureCosmosDBChangeFeedService>

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

cosmosDBService IAzureCosmosDBService

Contains standard methods for managing data stored within the Azure Cosmos DB workspace.

settings IOptions<AzureCosmosDBSettings>

The AzureCosmosDBSettings settings retrieved by the injected IOptions<TOptions>.

Exceptions

ArgumentException

Thrown if any of the required settings are null or empty.

Properties

IsInitialized

Gets a value indicating whether the change feeds have been initialized.

public bool IsInitialized { get; }

Property Value

bool

Methods

StartChangeFeedProcessorsAsync()

Initializes the change feed processors and starts listening for changes.

public Task StartChangeFeedProcessorsAsync()

Returns

Task

StopChangeFeedProcessorAsync()

Stops the change feed processors.

public Task StopChangeFeedProcessorAsync()

Returns

Task