|
CheckpointStore is used by multiple consumers to coordinate progress and ownership for partitions.
#include <checkpoint_store.hpp>
Public Member Functions | |
CheckpointStore (CheckpointStore const &other)=default | |
Construct a CheckpointStore from another CheckpointStore. | |
CheckpointStore & | operator= (CheckpointStore const &other)=default |
Construct a CheckpointStore from another CheckpointStore. | |
virtual std::vector< Models::Ownership > | ClaimOwnership (std::vector< Models::Ownership > const &partitionOwnership, Core::Context const &context={})=0 |
ClaimOwnership attempts to claim ownership of the partitions in partitionOwnership and returns the actual partitions that were claimed. | |
virtual std::vector< Models::Checkpoint > | ListCheckpoints (std::string const &fullyQualifiedNamespace, std::string const &eventHubName, std::string const &consumerGroup, Core::Context const &context={})=0 |
ListCheckpoints lists all the available checkpoints. | |
virtual std::vector< Models::Ownership > | ListOwnership (std::string const &fullyQualifiedNamespace, std::string const &eventHubName, std::string const &consumerGroup, Core::Context const &context={})=0 |
ListOwnership lists all ownerships. | |
virtual void | UpdateCheckpoint (Models::Checkpoint const &checkpoint, Core::Context const &context={})=0 |
UpdateCheckpoint updates a specific checkpoint with a sequence and offset. | |