public interface CheckpointStore
Modifier and Type | Method and Description |
---|---|
Flux<PartitionOwnership> |
claimOwnership(List<PartitionOwnership> requestedPartitionOwnerships)
Called to claim ownership of a list of partitions.
|
Flux<Checkpoint> |
listCheckpoints(String fullyQualifiedNamespace,
String eventHubName,
String consumerGroup)
Called to get the list of checkpoints from the underlying data store.
|
Flux<PartitionOwnership> |
listOwnership(String fullyQualifiedNamespace,
String eventHubName,
String consumerGroup)
Called to get the list of all existing partition ownership from the underlying data store.
|
Mono<Void> |
updateCheckpoint(Checkpoint checkpoint)
Updates the checkpoint in the data store for a partition.
|
Flux<PartitionOwnership> listOwnership(String fullyQualifiedNamespace, String eventHubName, String consumerGroup)
fullyQualifiedNamespace
- The fully qualified namespace of the Event Hub. This is likely to be similar to
"{your-namespace}.servicebus.windows.net".eventHubName
- The Event Hub name to get ownership information.consumerGroup
- The consumer group name.Flux<PartitionOwnership> claimOwnership(List<PartitionOwnership> requestedPartitionOwnerships)
requestedPartitionOwnerships
- List of partition ownerships this instance is requesting to own.Flux<Checkpoint> listCheckpoints(String fullyQualifiedNamespace, String eventHubName, String consumerGroup)
fullyQualifiedNamespace
- The fully qualified namespace of the Event Hub.eventHubName
- The Event Hub name to get checkpoint information.consumerGroup
- The consumer group name associated with the checkpoint.Mono<Void> updateCheckpoint(Checkpoint checkpoint)
checkpoint
- Checkpoint information containing sequence number and offset to be stored for this partition.Mono
that completes when the checkpoint is updated.Copyright © 2019 Microsoft Corporation. All rights reserved.