PluggableCheckpointStoreEventProcessor<TPartition>
PluggableCheckpointStoreEventProcessor()
PluggableCheckpointStoreEventProcessor(CheckpointStore, Int32, String, String, EventProcessorOptions)
PluggableCheckpointStoreEventProcessor(CheckpointStore, Int32, String, String, String, EventProcessorOptions)
PluggableCheckpointStoreEventProcessor(CheckpointStore, Int32, String, String, String, AzureNamedKeyCredential, EventProcessorOptions)
PluggableCheckpointStoreEventProcessor(CheckpointStore, Int32, String, String, String, AzureSasCredential, EventProcessorOptions)
PluggableCheckpointStoreEventProcessor(CheckpointStore, Int32, String, String, String, TokenCredential, EventProcessorOptions)
ClaimOwnershipAsync(IEnumerable<EventProcessorPartitionOwnership>, CancellationToken)
GetCheckpointAsync(String, CancellationToken)
ListOwnershipAsync(CancellationToken)
UpdateCheckpointAsync(String, CheckpointPosition, CancellationToken)
UpdateCheckpointAsync(String, Int64, Int64?, CancellationToken)
net10.0
namespace Azure.Messaging.EventHubs.Primitives
{
public abstract class PluggableCheckpointStoreEventProcessor<TPartition> : EventProcessor<TPartition>
where TPartition, new(), EventProcessorPartition
{
protected PluggableCheckpointStoreEventProcessor(CheckpointStore checkpointStore, int eventBatchMaximumCount, string consumerGroup, string fullyQualifiedNamespace, string eventHubName, TokenCredential credential, EventProcessorOptions options = null);
}
}
| nuget.org | 0.0 % Reference this API |
|---|---|
| .NET | 8.09.010.0 |
Information specific to net10.0 | |
| Assembly | Azure.Messaging.EventHubs , Version=5.12.2.0, PublicKeyToken=92742159e12e44c8 |
| Referencing | Your project needs a package reference to |
| Package | Azure.Messaging.EventHubs (5.12.2) net8.0 |
| Platform Restrictions | This API is supported on all platforms. |
- Built-in API
- Package-provided API