#include <joedb/journal/Writable_Journal.h>

Inheritance diagram for joedb::Writable_Journal:

[legend]

Collaboration diagram for joedb::Writable_Journal:

[legend]

Public Member Functions
	Writable_Journal (Journal_Construction_Lock &lock)

	Writable_Journal (Journal_Construction_Lock &&lock)

	Writable_Journal (Buffered_File &file)

int64_t	pull_from (const Readonly_Journal &journal, int64_t until)

int64_t	pull_from (const Readonly_Journal &journal)

int64_t	ahead_of_checkpoint () const noexcept

void	flush () override

int64_t	get_position () const override

void	start_writing (int64_t position) override

void	end_writing (int64_t position) override

void	soft_checkpoint_at (int64_t position)

void	hard_checkpoint_at (int64_t position)

void	soft_checkpoint () override

void	hard_checkpoint () override

void	create_table (const std::string &name) override

void	drop_table (Table_Id table_id) override

void	rename_table (Table_Id table_id, const std::string &name) override

void	add_field (Table_Id table_id, const std::string &name, Type type) override

void	drop_field (Table_Id table_id, Field_Id field_id) override

void	rename_field (Table_Id table_id, Field_Id field_id, const std::string &name) override

void	custom (const std::string &name) override

void	comment (const std::string &comment) override

void	timestamp (int64_t timestamp) override

void	valid_data () override

void	insert_into (Table_Id table_id, Record_Id record_id) override

void	delete_from (Table_Id table_id, Record_Id record_id) override

void	insert_vector (Table_Id table_id, Record_Id record_id, size_t size) override

void	delete_vector (Table_Id table_id, Record_Id record_id, size_t size) override

bool	wants_blob_data () const override

Blob	write_blob (const std::string &data) override

Async_Writer	get_async_tail_writer ()

void	lock_pull ()

bool	is_locked () const

void	unlock () noexcept

	~Writable_Journal () override

Public Member Functions inherited from joedb::Readonly_Journal
	Readonly_Journal (Journal_Construction_Lock &lock)

	Readonly_Journal (Journal_Construction_Lock &&lock)

	Readonly_Journal (Buffered_File &file)

int64_t	get_position () const

int64_t	get_checkpoint () const

int64_t	get_hard_checkpoint () const

bool	is_empty () const

bool	is_shared () const

int64_t	pull ()

const Buffered_File &	get_file () const

void	replay_log (Writable &writable)

void	replay_with_checkpoint_comments (Writable &writable)

void	rewind ()

void	one_step (Writable &writable)

void	play_until (Writable &writable, int64_t end)

void	raw_play_until (Writable &writable, int64_t end)

void	play_until_checkpoint (Writable &writable)

void	raw_play_until_checkpoint (Writable &writable)

void	skip_directly_to (int64_t position)

bool	equal_to (Readonly_Journal &journal, int64_t from, int64_t until) const

Async_Reader	get_async_tail_reader (int64_t start_position) const

Async_Reader	get_async_reader (int64_t start_position, int64_t until_position) const

Public Member Functions inherited from joedb::Writable
virtual void	on_blob (Blob blob)

virtual	~Writable ()=default

Additional Inherited Members
Static Public Attributes inherited from joedb::Readonly_Journal
static constexpr uint32_t	format_version = 5

Protected Types inherited from joedb::Readonly_Journal
enum class	operation_t : uint8_t { create_table = 0x01 , drop_table = 0x02 , add_field = 0x03 , drop_field = 0x04 , insert_into = 0x05 , delete_from = 0x06 , update = 0x07 , append = 0x08 , update_last = 0x09 , comment = 0x0a , timestamp = 0x0b , rename_table = 0x0c , rename_field = 0x0d , valid_data = 0x0e , insert_vector = 0x0f , custom = 0x10 , update_vector = 0x11 , update_next = 0x12 , blob = 0x13 , delete_vector = 0x14 , updates = 0x80 , TYPE_MACRO }

Protected Member Functions inherited from joedb::Readonly_Journal
void	reset_context ()

Type	read_type ()

std::string	safe_read_string ()

Protected Attributes inherited from joedb::Readonly_Journal
Buffered_File &	file

int	hard_index

int	soft_index

int64_t	checkpoint_position

int64_t	hard_checkpoint_position

Table_Id	table_of_last_operation

Record_Id	record_of_last_operation

Field_Id	field_of_last_update

Detailed Description

Definition at line 11 of file Writable_Journal.h.

Constructor & Destructor Documentation

◆ Writable_Journal() [1/3]

joedb::Writable_Journal::Writable_Journal ( Journal_Construction_Lock & lock )

explicit

Definition at line 7 of file Writable_Journal.cpp.

◆ Writable_Journal() [2/3]

joedb::Writable_Journal::Writable_Journal ( Journal_Construction_Lock && lock )

inlineexplicit

Definition at line 25 of file Writable_Journal.h.

◆ Writable_Journal() [3/3]

joedb::Writable_Journal::Writable_Journal ( Buffered_File & file )

inlineexplicit

Definition at line 30 of file Writable_Journal.h.

◆ ~Writable_Journal()

joedb::Writable_Journal::~Writable_Journal ( )

override

Definition at line 457 of file Writable_Journal.cpp.

Member Function Documentation

◆ add_field()

void joedb::Writable_Journal::add_field	(	Table_Id	table_id,
		const std::string &	name,
		Type	type
	)

overridevirtual

Reimplemented from joedb::Writable.

Definition at line 182 of file Writable_Journal.cpp.

◆ ahead_of_checkpoint()

int64_t joedb::Writable_Journal::ahead_of_checkpoint ( ) const

noexcept

Definition at line 57 of file Writable_Journal.cpp.

◆ comment()

void joedb::Writable_Journal::comment ( const std::string & comment )

overridevirtual

Reimplemented from joedb::Writable.

Definition at line 235 of file Writable_Journal.cpp.

◆ create_table()

void joedb::Writable_Journal::create_table ( const std::string & name )

overridevirtual

Reimplemented from joedb::Writable.

Definition at line 153 of file Writable_Journal.cpp.

◆ custom()

void joedb::Writable_Journal::custom ( const std::string & name )

overridevirtual

Reimplemented from joedb::Writable.

Definition at line 227 of file Writable_Journal.cpp.

◆ delete_from()

void joedb::Writable_Journal::delete_from	(	Table_Id	table_id,
		Record_Id	record_id
	)

overridevirtual

Reimplemented from joedb::Writable.

Definition at line 282 of file Writable_Journal.cpp.

◆ delete_vector()

void joedb::Writable_Journal::delete_vector	(	Table_Id	table_id,
		Record_Id	record_id,
		size_t	size
	)

overridevirtual

Implements joedb::Writable.

Definition at line 313 of file Writable_Journal.cpp.

◆ drop_field()

void joedb::Writable_Journal::drop_field	(	Table_Id	table_id,
		Field_Id	field_id
	)

overridevirtual

Reimplemented from joedb::Writable.

Definition at line 199 of file Writable_Journal.cpp.

◆ drop_table()

void joedb::Writable_Journal::drop_table ( Table_Id table_id )

overridevirtual

Reimplemented from joedb::Writable.

Definition at line 161 of file Writable_Journal.cpp.

◆ end_writing()

void joedb::Writable_Journal::end_writing ( int64_t position )

overridevirtual

Reimplemented from joedb::Writable.

Definition at line 72 of file Writable_Journal.cpp.

◆ flush()

void joedb::Writable_Journal::flush ( )

inlineoverridevirtual

Reimplemented from joedb::Writable.

Definition at line 43 of file Writable_Journal.h.

◆ get_async_tail_writer()

Async_Writer joedb::Writable_Journal::get_async_tail_writer ( )

inline

Definition at line 127 of file Writable_Journal.h.

◆ get_position()

int64_t joedb::Writable_Journal::get_position ( ) const

inlineoverridevirtual

Reimplemented from joedb::Writable.

Definition at line 45 of file Writable_Journal.h.

◆ hard_checkpoint()

void joedb::Writable_Journal::hard_checkpoint ( )

overridevirtual

Reimplemented from joedb::Writable.

Definition at line 146 of file Writable_Journal.cpp.

◆ hard_checkpoint_at()

void joedb::Writable_Journal::hard_checkpoint_at ( int64_t position )

Definition at line 106 of file Writable_Journal.cpp.

◆ insert_into()

void joedb::Writable_Journal::insert_into	(	Table_Id	table_id,
		Record_Id	record_id
	)

overridevirtual

Reimplemented from joedb::Writable.

Definition at line 258 of file Writable_Journal.cpp.

◆ insert_vector()

void joedb::Writable_Journal::insert_vector	(	Table_Id	table_id,
		Record_Id	record_id,
		size_t	size
	)

overridevirtual

Implements joedb::Writable.

Definition at line 295 of file Writable_Journal.cpp.

◆ is_locked()

bool joedb::Writable_Journal::is_locked ( ) const

inline

Definition at line 133 of file Writable_Journal.h.

◆ lock_pull()

void joedb::Writable_Journal::lock_pull ( )

Definition at line 438 of file Writable_Journal.cpp.

◆ pull_from() [1/2]

int64_t joedb::Writable_Journal::pull_from ( const Readonly_Journal & journal )

inline

Definition at line 36 of file Writable_Journal.h.

◆ pull_from() [2/2]

int64_t joedb::Writable_Journal::pull_from	(	const Readonly_Journal &	journal,
		int64_t	until
	)

Definition at line 39 of file Writable_Journal.cpp.

◆ rename_field()

void joedb::Writable_Journal::rename_field	(	Table_Id	table_id,
		Field_Id	field_id,
		const std::string &	name
	)

overridevirtual

Reimplemented from joedb::Writable.

Definition at line 212 of file Writable_Journal.cpp.

◆ rename_table()

void joedb::Writable_Journal::rename_table	(	Table_Id	table_id,
		const std::string &	name
	)

overridevirtual

Reimplemented from joedb::Writable.

Definition at line 169 of file Writable_Journal.cpp.

◆ soft_checkpoint()

void joedb::Writable_Journal::soft_checkpoint ( )

overridevirtual

Reimplemented from joedb::Writable.

Definition at line 139 of file Writable_Journal.cpp.

◆ soft_checkpoint_at()

void joedb::Writable_Journal::soft_checkpoint_at ( int64_t position )

Definition at line 80 of file Writable_Journal.cpp.

◆ start_writing()

void joedb::Writable_Journal::start_writing ( int64_t position )

overridevirtual

Reimplemented from joedb::Writable.

Definition at line 64 of file Writable_Journal.cpp.

◆ timestamp()

void joedb::Writable_Journal::timestamp ( int64_t timestamp )

overridevirtual

Reimplemented from joedb::Writable.

Definition at line 243 of file Writable_Journal.cpp.

◆ unlock()

void joedb::Writable_Journal::unlock ( )

noexcept

Definition at line 449 of file Writable_Journal.cpp.

◆ valid_data()

void joedb::Writable_Journal::valid_data ( )

overridevirtual

Reimplemented from joedb::Writable.

Definition at line 251 of file Writable_Journal.cpp.

◆ wants_blob_data()

bool joedb::Writable_Journal::wants_blob_data ( ) const

inlineoverridevirtual

Reimplemented from joedb::Writable.

Definition at line 124 of file Writable_Journal.h.

◆ write_blob()

joedb::Blob joedb::Writable_Journal::write_blob ( const std::string & data )

overridevirtual

Reimplemented from joedb::Writable.

Definition at line 423 of file Writable_Journal.cpp.

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

/home/rcoulom/repos/joedb/src/joedb/journal/Writable_Journal.h
/home/rcoulom/repos/joedb/src/joedb/journal/Writable_Journal.cpp

Public Member Functions

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

◆ Writable_Journal() [1/3]

◆ Writable_Journal() [2/3]

◆ Writable_Journal() [3/3]

◆ ~Writable_Journal()

Member Function Documentation

◆ add_field()

◆ ahead_of_checkpoint()

◆ comment()

◆ create_table()

◆ custom()

◆ delete_from()

◆ delete_vector()

◆ drop_field()

◆ drop_table()

◆ end_writing()

◆ flush()

◆ get_async_tail_writer()

◆ get_position()

◆ hard_checkpoint()

◆ hard_checkpoint_at()

◆ insert_into()

◆ insert_vector()

◆ is_locked()

◆ lock_pull()

◆ pull_from() [1/2]

◆ pull_from() [2/2]

◆ rename_field()

◆ rename_table()

◆ soft_checkpoint()

◆ soft_checkpoint_at()

◆ start_writing()

◆ timestamp()

◆ unlock()

◆ valid_data()

◆ wants_blob_data()

◆ write_blob()