Dela via


ICheckpointManager Interface

Definition

Provides methods for running checkpoint asynchronously. Extensibility is provided to specify host-specific storage for storing the offset. This is provided when RegisterProcessorAsync<T>(Lease, ICheckpointManager) is called, to checkpoint the offset position using CheckpointAsync(EventData).

public interface ICheckpointManager
type ICheckpointManager = interface
Public Interface ICheckpointManager

Methods

CheckpointAsync(Lease, String, Int64)

Stores the offset of a particular partition in the host-specific store.

Applies to