gs::LocalWalParser Class Reference

#include <local_wal_parser.h>

Inheritance diagram for gs::LocalWalParser:

Collaboration diagram for gs::LocalWalParser:

Public Member Functions
	LocalWalParser (const std::string &wal_uri)
	~LocalWalParser ()
void	open (const std::string &wal_uri) override
void	close () override
uint32_t	last_ts () const override
const WalContentUnit &	get_insert_wal (uint32_t ts) const override
const std::vector< UpdateWalUnit > &	get_update_wals () const override
Public Member Functions inherited from gs::IWalParser
virtual	~IWalParser ()

Static Public Member Functions
static std::unique_ptr< IWalParser >	Make (const std::string &wal_dir)

Private Attributes
std::vector< int >	fds_
std::vector< void * >	mmapped_ptrs_
std::vector< size_t >	mmapped_size_
std::vector< WalContentUnit >	insert_wal_list_
uint32_t	last_ts_ {0}
std::vector< UpdateWalUnit >	update_wal_list_

Static Private Attributes
static const bool	registered_

Constructor & Destructor Documentation

LocalWalParser()

gs::LocalWalParser::LocalWalParser

(

const std::string &

wal_uri

)

~LocalWalParser()

gs::LocalWalParser::~LocalWalParser ( )

inline

Member Function Documentation

close()

void gs::LocalWalParser::close ( )

overridevirtual

Implements gs::IWalParser.

get_insert_wal()

const WalContentUnit & gs::LocalWalParser::get_insert_wal ( uint32_t  ts ) const

overridevirtual

Implements gs::IWalParser.

get_update_wals()

const std::vector< UpdateWalUnit > & gs::LocalWalParser::get_update_wals ( ) const

overridevirtual

Get all the update wal units.

Implements gs::IWalParser.

last_ts()

uint32_t gs::LocalWalParser::last_ts ( ) const

overridevirtual

Implements gs::IWalParser.

Make()

static std::unique_ptr<IWalParser> gs::LocalWalParser::Make ( const std::string &  wal_dir )

inlinestatic

open()

void gs::LocalWalParser::open ( const std::string &  wal_uri )

overridevirtual

Open wals from a uri and parse the wal files.

Implements gs::IWalParser.

Member Data Documentation

fds_

std::vector<int> gs::LocalWalParser::fds_

private

insert_wal_list_

std::vector<WalContentUnit> gs::LocalWalParser::insert_wal_list_

private

last_ts_

uint32_t gs::LocalWalParser::last_ts_ {0}

private

mmapped_ptrs_

std::vector<void*> gs::LocalWalParser::mmapped_ptrs_

private

mmapped_size_

std::vector<size_t> gs::LocalWalParser::mmapped_size_

private

registered_

const bool gs::LocalWalParser::registered_

staticprivate

Initial value:

= WalParserFactory::RegisterWalParser(
    "file", static_cast<WalParserFactory::wal_parser_initializer_t>(
                &LocalWalParser::Make))

update_wal_list_

std::vector<UpdateWalUnit> gs::LocalWalParser::update_wal_list_

private

---

The documentation for this class was generated from the following files:

• /home/runner/work/GraphScope/GraphScope/flex/engines/graph_db/database/wal/local_wal_parser.h
• /home/runner/work/GraphScope/GraphScope/flex/engines/graph_db/database/wal/local_wal_parser.cc