Record.h

/*
 * Copyright (c) Meta Platforms, Inc. and affiliates.
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *     http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */
 
#pragma once
 
#include <memory>
#include <vector>
 
#include <vrs/ForwardDefinitions.h>
#include <vrs/StreamId.h>
#include <vrs/helpers/EnumTemplates.hpp>
 
namespace vrs {
 
class DataSource;
class DirectWriteRecordData;
class Compressor;
class RecordManager;
 
enum class CompressionType : uint8_t {
  None = 0, 
  Lz4, 
  Zstd, 
 
  COUNT
};
 
class Record final {
 public:
  static const double kMaxTimestamp;
 
  enum class Type : uint8_t {
    UNDEFINED = 0, 
    STATE = 1, 
    CONFIGURATION = 2, 
    DATA = 3, 
    TAGS = 4, 
    COUNT 
  };
 
  void recycle();
 
  void set(
      double timestamp,
      Type type,
      uint32_t formatVersion,
      const DataSource& data,
      uint64_t creationOrder);
 
  void addDirectWriteRecordData(std::unique_ptr<DirectWriteRecordData>&& directWriteRecordData);
 
  bool shouldTryToCompress() const;
 
  uint32_t compressRecord(Compressor& compressor);
 
  int writeRecord(
      WriteFileHandler& file,
      StreamId streamId,
      uint32_t& inOutRecordSize,
      Compressor& compressor,
      uint32_t compressedSize);
 
  double getTimestamp() const {
    return timestamp_;
  }
 
  uint64_t getCreationOrder() const {
    return creationOrder_;
  }
 
  size_t getSize() const {
    return usedBufferSize_;
  }
 
  Type getRecordType() const {
    return recordType_;
  }
 
  static const char* typeName(Type type);
 
  struct uninitialized_byte final {
    // NOLINTNEXTLINE(cppcoreguidelines-pro-type-member-init, modernize-use-equals-default)
    uninitialized_byte() {} // do not use '= default' as it will initialize byte!
    uint8_t byte;
  };
 
 private:
  friend class RecordManager;
 
  explicit Record(RecordManager& recordManager);
  ~Record();
 
  double timestamp_{};
  Type recordType_{};
  uint32_t formatVersion_{};
  std::vector<uninitialized_byte> buffer_;
  size_t usedBufferSize_{};
  uint64_t creationOrder_{};
  std::unique_ptr<DirectWriteRecordData> directWriteRecordData_;
 
  RecordManager& recordManager_;
};
 
string toString(Record::Type recordType);
 
template <>
Record::Type toEnum(const string& name);
 
} // namespace vrs