#include <local_wal_writer.h>
◆ LocalWalWriter()
gs::LocalWalWriter::LocalWalWriter |
( |
| ) |
|
|
default |
◆ ~LocalWalWriter()
gs::LocalWalWriter::~LocalWalWriter |
( |
| ) |
|
|
inline |
◆ append()
bool gs::LocalWalWriter::append |
( |
const char * |
data, |
|
|
size_t |
length |
|
) |
| |
|
overridevirtual |
◆ close()
void gs::LocalWalWriter::close |
( |
| ) |
|
|
overridevirtual |
Close the wal writer. If a remote connection is hold by the wal writer, it should be closed.
Implements gs::IWalWriter.
◆ Make()
std::unique_ptr< IWalWriter > gs::LocalWalWriter::Make |
( |
| ) |
|
|
static |
◆ open()
void gs::LocalWalWriter::open |
( |
const std::string & |
uri, |
|
|
int |
thread_id |
|
) |
| |
|
overridevirtual |
Open a wal file. In our design, each thread has its own wal file. The uri could be a file_path or a remote connection string.
Implements gs::IWalWriter.
◆ type()
std::string gs::LocalWalWriter::type |
( |
| ) |
const |
|
inlineoverridevirtual |
◆ fd_
int gs::LocalWalWriter::fd_ |
|
private |
◆ file_size_
size_t gs::LocalWalWriter::file_size_ |
|
private |
◆ file_used_
size_t gs::LocalWalWriter::file_used_ |
|
private |
◆ registered_
const bool gs::LocalWalWriter::registered_ |
|
staticprivate |
◆ TRUNC_SIZE
constexpr size_t gs::LocalWalWriter::TRUNC_SIZE = 1ul << 30 |
|
staticconstexpr |
The documentation for this class was generated from the following files:
- /home/runner/work/GraphScope/GraphScope/flex/engines/graph_db/database/wal/local_wal_writer.h
- /home/runner/work/GraphScope/GraphScope/flex/engines/graph_db/database/wal/local_wal_writer.cc