ICheckpointManager Interface


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


CheckpointAsync(Lease, String, Int64)

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