KeySharedPolicy.h

#pragma once
 
#include <pulsar/defines.h>
 
#include <cstdint>
#include <memory>
#include <utility>
#include <vector>
 
namespace pulsar {

enum KeySharedMode : uint8_t
{

    AUTO_SPLIT = 0,

    STICKY = 1
};
 
struct KeySharedPolicyImpl;
 
typedef std::pair<int, int> StickyRange;
typedef std::vector<StickyRange> StickyRanges;
 
class PULSAR_PUBLIC KeySharedPolicy {
   public:
    KeySharedPolicy();
    ~KeySharedPolicy();
 
    KeySharedPolicy(const KeySharedPolicy&);
    KeySharedPolicy& operator=(const KeySharedPolicy&);

    KeySharedPolicy clone() const;

    KeySharedPolicy& setKeySharedMode(KeySharedMode keySharedMode);

    KeySharedMode getKeySharedMode() const;

    KeySharedPolicy& setAllowOutOfOrderDelivery(bool allowOutOfOrderDelivery);

    bool isAllowOutOfOrderDelivery() const;

    KeySharedPolicy& setStickyRanges(std::initializer_list<StickyRange> ranges);

    KeySharedPolicy& setStickyRanges(const StickyRanges& ranges);

    StickyRanges getStickyRanges() const;
 
   private:
    std::shared_ptr<KeySharedPolicyImpl> impl_;
};
}  // namespace pulsar