MessageIdBuilder.h

 
#pragma once
 
#include <pulsar/MessageId.h>
 
#include <memory>
 
namespace pulsar {
 
namespace proto {
class MessageIdData;
}
 
class PULSAR_PUBLIC MessageIdBuilder {
   public:
    explicit MessageIdBuilder();
 
    static MessageIdBuilder from(const MessageId& messageId);
 
    static MessageIdBuilder from(const proto::MessageIdData& messageIdData);
 
    MessageId build() const;
 
    MessageIdBuilder& ledgerId(int64_t ledgerId);
 
    MessageIdBuilder& entryId(int64_t entryId);
 
    MessageIdBuilder& partition(int32_t partition);
 
    MessageIdBuilder& batchIndex(int32_t batchIndex);
 
    MessageIdBuilder& batchSize(int32_t batchSize);
 
   private:
    std::shared_ptr<MessageIdImpl> impl_;
};
 
}  // namespace pulsar