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