Share via

Microsoft.Azure.Documents.ChangeFeedProcessor.FeedProcessing Namespace

  • Reference

Interfaces

IChangeFeedObserver

This interface is used to deliver change events to document feed observers.
IChangeFeedObserverContext

Represents the context passed to IChangeFeedObserver events.
IChangeFeedObserverFactory

Factory class used to create instance(s) of IChangeFeedObserver.
ICheckpointPartitionProcessorFactory

Factory class used to create instance(s) of IPartitionProcessor and allows to re-use default checkpoint mechanism.
IPartitionProcessor

Provides an API to run continuous processing on a single partition of some resource. Created by Create(ILease, IChangeFeedObserver) or Create(ILease, ILeaseCheckpointer, IChangeFeedObserver) after some lease is acquired by the current host. Processing can perform the following tasks in a loop:

  1. Read some data from the resource partition.
  2. Handle possible problems with the read.
  3. Pass the obtained data to an observer by calling ProcessChangesAsync(IChangeFeedObserverContext, IReadOnlyList<Document>, CancellationToken) with the context IChangeFeedObserverContext.
IPartitionProcessorFactory

Factory class used to create instance(s) of IPartitionProcessor. Use ICheckpointPartitionProcessorFactory for using default checkpoint mechanism.

Enums

ChangeFeedObserverCloseReason

The reason for the IChangeFeedObserver to close.