dcn::feed::SqliteFeedStore Class Reference

#include <sqlite_feed_store.hpp>

Inheritance diagram for dcn::feed::SqliteFeedStore:

Public Member Functions
	SqliteFeedStore (const std::filesystem::path &feed_db_path, const std::filesystem::path &archive_root, std::int64_t outbox_retention_ms, int default_chain_id, std::string default_chain_namespace="local")
	~SqliteFeedStore () override
void	applyChange (const events::ChangeRecord &row, std::int64_t now_ms) override
void	maintainOutbox (std::int64_t now_ms) override
FeedPage	getFeedPage (const FeedQuery &query) const override
StreamPage	getStreamPage (const StreamQuery &query) const override
std::int64_t	minAvailableStreamSeq () const override
std::int64_t	getFeedCursor () const override
void	setFeedCursor (std::int64_t last_change_seq) override
bool	runArchiveCycle (int chain_id, std::size_t hot_window_days, std::int64_t now_ms) override
storage::sqlite::WalCheckpointStats	checkpointWal (storage::sqlite::WalCheckpointMode mode) override
Public Member Functions inherited from dcn::feed::IFeedStore
virtual	~IFeedStore ()=default

Constructor & Destructor Documentation

SqliteFeedStore()

dcn::feed::SqliteFeedStore::SqliteFeedStore	(	const std::filesystem::path &	feed_db_path,
		const std::filesystem::path &	archive_root,
		std::int64_t	outbox_retention_ms,
		int	default_chain_id,
		std::string	default_chain_namespace = "local" )

~SqliteFeedStore()

dcn::feed::SqliteFeedStore::~SqliteFeedStore ( )

override

Member Function Documentation

applyChange()

void dcn::feed::SqliteFeedStore::applyChange ( const events::ChangeRecord & row, std::int64_t now_ms )

overridevirtual

Implements dcn::feed::IFeedStore.

checkpointWal()

storage::sqlite::WalCheckpointStats dcn::feed::SqliteFeedStore::checkpointWal ( storage::sqlite::WalCheckpointMode mode )

overridevirtual

Implements dcn::feed::IFeedStore.

getFeedCursor()

std::int64_t dcn::feed::SqliteFeedStore::getFeedCursor ( ) const

overridevirtual

Implements dcn::feed::IFeedStore.

getFeedPage()

FeedPage dcn::feed::SqliteFeedStore::getFeedPage ( const FeedQuery & query ) const

overridevirtual

Implements dcn::feed::IFeedStore.

getStreamPage()

StreamPage dcn::feed::SqliteFeedStore::getStreamPage ( const StreamQuery & query ) const

overridevirtual

Implements dcn::feed::IFeedStore.

maintainOutbox()

void dcn::feed::SqliteFeedStore::maintainOutbox ( std::int64_t now_ms )

overridevirtual

Implements dcn::feed::IFeedStore.

minAvailableStreamSeq()

std::int64_t dcn::feed::SqliteFeedStore::minAvailableStreamSeq ( ) const

overridevirtual

Implements dcn::feed::IFeedStore.

runArchiveCycle()

bool dcn::feed::SqliteFeedStore::runArchiveCycle ( int chain_id, std::size_t hot_window_days, std::int64_t now_ms )

overridevirtual

Implements dcn::feed::IFeedStore.

setFeedCursor()

void dcn::feed::SqliteFeedStore::setFeedCursor ( std::int64_t last_change_seq )

overridevirtual

Implements dcn::feed::IFeedStore.

---

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

• src/feed/include/sqlite_feed_store.hpp
• src/feed/src/sqlite_feed_store.cpp