local_wal_writer.h

Go to the documentation of this file.

 
#ifndef ENGINES_GRAPH_DB_DATABASE_WAL_LOCAL_WAL_WRITER_H_
#define ENGINES_GRAPH_DB_DATABASE_WAL_LOCAL_WAL_WRITER_H_
 
#include <memory>
#include <unordered_map>
#include "flex/engines/graph_db/database/wal/wal.h"
 
namespace gs {
 
class LocalWalWriter : public IWalWriter {
 public:
  static std::unique_ptr<IWalWriter> Make();
 
  static constexpr size_t TRUNC_SIZE = 1ul << 30;
  LocalWalWriter() = default;
  ~LocalWalWriter() { close(); }
 
  void open(const std::string& wal_uri, int thread_id) override;
  void close() override;
  bool append(const char* data, size_t length) override;
  std::string type() const override { return "file"; }
 
 private:
  int fd_;
  size_t file_size_;
  size_t file_used_;
 
  static const bool registered_;
};
 
}  // namespace gs
 
#endif  // ENGINES_GRAPH_DB_DATABASE_WAL_LOCAL_WAL_WRITER_H_