BufferedWriteDecoder.h

#pragma once

#include <memory>
#include <vector>

#include "logdevice/include/Record.h"

namespace facebook { namespace logdevice {

class BufferedWriteDecoderImpl;

class BufferedWriteDecoder {
 public:
  static std::unique_ptr<BufferedWriteDecoder> create();

  static int getBatchSize(const DataRecord& record, size_t* size_out);

  int decode(std::vector<std::unique_ptr<DataRecord>>&& records,
             std::vector<Payload>& payloads_out);
  int decode(std::vector<std::unique_ptr<DataRecord>>&& records,
             std::vector<PayloadGroup>& payload_groups_out);

  int decodeOne(std::unique_ptr<DataRecord>&& record,
                std::vector<Payload>& payloads_out);
  int decodeOne(std::unique_ptr<DataRecord>&& record,
                std::vector<PayloadGroup>& payload_groups_out);

  int decodeOneCompressed(
      std::unique_ptr<DataRecord>&& record,
      CompressedPayloadGroups& compressed_payload_groups_out);

  virtual ~BufferedWriteDecoder() {}

 private:
  BufferedWriteDecoder() {} // can be constructed by the factory only
  BufferedWriteDecoder(const BufferedWriteDecoder&) = delete;
  BufferedWriteDecoder& operator=(const BufferedWriteDecoder&) = delete;

  friend class BufferedWriteDecoderImpl;
  BufferedWriteDecoderImpl* impl(); // downcasts (this)
};
}} // namespace facebook::logdevice