Some information relates to prerelease product that may be substantially modified before it’s released. Microsoft makes no warranties, express or implied, with respect to the information provided here.
NoOpCheckpointer is used in EventDataGeneratorStreamProvider eco system to replace the default Checkpointer which requires a back end storage. In EventHubDataGeneratorStreamProvider,
it is generating EventData on the fly when receiver pull messages from the queue, which means it doesn't support recoverable stream, hence check pointing won't bring much value there.
So a checkpointer with no ops should be enough.
public class NoOpCheckpointer : Orleans.Streams.IStreamQueueCheckpointer<string>
type NoOpCheckpointer = class
interface IStreamQueueCheckpointer<string>
Public Class NoOpCheckpointer
Implements IStreamQueueCheckpointer(Of String)