checkpoint_store.hpp

// Copyright (c) Microsoft Corporation.
// Licensed under the MIT License.
#pragma once
#include "models/checkpoint_store_models.hpp"
 
#include <azure/core/context.hpp>
#include <azure/core/datetime.hpp>
#include <azure/core/nullable.hpp>
 
#include <sstream>
#include <stdexcept>
#include <vector>
 
namespace Azure { namespace Messaging { namespace EventHubs {
 
  class CheckpointStore {
  public:
    CheckpointStore() = default;
 
    CheckpointStore(CheckpointStore const& other) = default;
 
    CheckpointStore& operator=(CheckpointStore const& other) = default;
 
    virtual std::vector<Models::Ownership> ClaimOwnership(
        std::vector<Models::Ownership> const& partitionOwnership,
        Core::Context const& context = {})
        = 0;
 
    virtual std::vector<Models::Checkpoint> ListCheckpoints(
        std::string const& fullyQualifiedNamespace,
        std::string const& eventHubName,
        std::string const& consumerGroup,
        Core::Context const& context = {})
        = 0;
 
    virtual std::vector<Models::Ownership> ListOwnership(
        std::string const& fullyQualifiedNamespace,
        std::string const& eventHubName,
        std::string const& consumerGroup,
        Core::Context const& context = {})
        = 0;
 
    virtual void UpdateCheckpoint(
        Models::Checkpoint const& checkpoint,
        Core::Context const& context = {})
        = 0;
 
    virtual ~CheckpointStore() = default;
  };
 
}}} // namespace Azure::Messaging::EventHubs