dcn::feed::Feed Class Reference

#include <feed.hpp>

Inheritance diagram for dcn::feed::Feed:

Public Member Functions
	Feed (asio::io_context &io_context, std::filesystem::path feed_db_path, std::filesystem::path archive_root, std::int64_t outbox_retention_ms, int default_chain_id, std::string default_chain_namespace="local")
	Feed (const Feed &)=delete
Feed &	operator= (const Feed &)=delete
asio::awaitable< void >	applyChange (events::ChangeRecord row, std::int64_t now_ms)
asio::awaitable< void >	maintainOutbox (std::int64_t now_ms)
asio::awaitable< bool >	runArchiveCycle (int chain_id, std::size_t hot_window_days, std::int64_t now_ms)
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
asio::awaitable< void >	setFeedCursor (std::int64_t seq)
asio::awaitable< storage::sqlite::WalCheckpointStats >	checkpointWal (storage::sqlite::WalCheckpointMode mode) const override
Public Member Functions inherited from dcn::feed::IFeedRepository
virtual	~IFeedRepository ()=default
Public Member Functions inherited from dcn::storage::sqlite::IWalStore
virtual	~IWalStore ()=default

Constructor & Destructor Documentation

Feed() [1/2]

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

Feed() [2/2]

dcn::feed::Feed::Feed ( const Feed & )

delete

Member Function Documentation

applyChange()

asio::awaitable< void > dcn::feed::Feed::applyChange	(	events::ChangeRecord	row,
		std::int64_t	now_ms )

checkpointWal()

asio::awaitable< storage::sqlite::WalCheckpointStats > dcn::feed::Feed::checkpointWal ( storage::sqlite::WalCheckpointMode mode ) const

overridevirtual

Implements dcn::storage::sqlite::IWalStore.

getFeedCursor()

std::int64_t dcn::feed::Feed::getFeedCursor

(

)

const

getFeedPage()

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

overridevirtual

Implements dcn::feed::IFeedRepository.

getStreamPage()

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

overridevirtual

Implements dcn::feed::IFeedRepository.

maintainOutbox()

asio::awaitable< void > dcn::feed::Feed::maintainOutbox

(

std::int64_t

now_ms

)

minAvailableStreamSeq()

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

overridevirtual

Implements dcn::feed::IFeedRepository.

operator=()

Feed & dcn::feed::Feed::operator= ( const Feed & )

delete

runArchiveCycle()

asio::awaitable< bool > dcn::feed::Feed::runArchiveCycle	(	int	chain_id,
		std::size_t	hot_window_days,
		std::int64_t	now_ms )

setFeedCursor()

asio::awaitable< void > dcn::feed::Feed::setFeedCursor

(

std::int64_t

seq

)

---

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

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