Share via

IPartitionProcessor Interface

  • Reference

Definition

Namespace:
Microsoft.Azure.Documents.ChangeFeedProcessor.FeedProcessing
Assembly:
Microsoft.Azure.Documents.ChangeFeedProcessor.dll
Package:
Microsoft.Azure.DocumentDB.ChangeFeedProcessor v2.4.0

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.
public interface IPartitionProcessor
type IPartitionProcessor = interface
Public Interface IPartitionProcessor

Methods

RunAsync(CancellationToken)

Perform partition processing.

Applies to