dcn::events::EventRuntime Class Reference

#include <events_runtime.hpp>

Inheritance diagram for dcn::events::EventRuntime:

Public Member Functions
	EventRuntime (asio::io_context &io_context, EventRuntimeConfig config)
	~EventRuntime ()
	EventRuntime (const EventRuntime &)=delete
EventRuntime &	operator= (const EventRuntime &)=delete
	EventRuntime (EventRuntime &&)=delete
EventRuntime &	operator= (EventRuntime &&)=delete
void	start ()
void	requestStop ()
asio::awaitable< void >	stop ()
bool	running () const
bool	ingestionEnabled () const
bool	blockingTransportObservedOnHotWriteStrand () const
std::uint64_t	rpcTransportCallCount () const
FeedPage	getFeedPage (const FeedQuery &query) const override
StreamPage	getStreamPage (const StreamQuery &query) const override
std::int64_t	minAvailableStreamSeq () const override
asio::awaitable< storage::sqlite::WalCheckpointStats >	checkpointWal (storage::sqlite::WalCheckpointMode mode) const override
Public Member Functions inherited from dcn::events::IFeedRepository
virtual	~IFeedRepository ()=default
Public Member Functions inherited from dcn::storage::sqlite::IWalStore
virtual	~IWalStore ()=default

Constructor & Destructor Documentation

EventRuntime() [1/3]

dcn::events::EventRuntime::EventRuntime	(	asio::io_context &	io_context,
		EventRuntimeConfig	config
	)

~EventRuntime()

dcn::events::EventRuntime::~EventRuntime

(

)

EventRuntime() [2/3]

dcn::events::EventRuntime::EventRuntime ( const EventRuntime &  )

delete

EventRuntime() [3/3]

dcn::events::EventRuntime::EventRuntime ( EventRuntime &&  )

delete

Member Function Documentation

blockingTransportObservedOnHotWriteStrand()

bool dcn::events::EventRuntime::blockingTransportObservedOnHotWriteStrand

(

)

const

checkpointWal()

asio::awaitable< storage::sqlite::WalCheckpointStats > dcn::events::EventRuntime::checkpointWal ( storage::sqlite::WalCheckpointMode  mode ) const

overridevirtual

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

getFeedPage()

FeedPage dcn::events::EventRuntime::getFeedPage ( const FeedQuery &  query ) const

overridevirtual

Implements dcn::events::IFeedRepository.

getStreamPage()

StreamPage dcn::events::EventRuntime::getStreamPage ( const StreamQuery &  query ) const

overridevirtual

Implements dcn::events::IFeedRepository.

ingestionEnabled()

bool dcn::events::EventRuntime::ingestionEnabled

(

)

const

minAvailableStreamSeq()

std::int64_t dcn::events::EventRuntime::minAvailableStreamSeq ( ) const

overridevirtual

Implements dcn::events::IFeedRepository.

operator=() [1/2]

EventRuntime & dcn::events::EventRuntime::operator= ( const EventRuntime &  )

delete

operator=() [2/2]

EventRuntime & dcn::events::EventRuntime::operator= ( EventRuntime &&  )

delete

requestStop()

void dcn::events::EventRuntime::requestStop

(

)

rpcTransportCallCount()

std::uint64_t dcn::events::EventRuntime::rpcTransportCallCount

(

)

const

running()

bool dcn::events::EventRuntime::running

(

)

const

start()

void dcn::events::EventRuntime::start

(

)

stop()

asio::awaitable< void > dcn::events::EventRuntime::stop

(

)

---

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

• src/events/include/events_runtime.hpp
• src/events/src/events_runtime.cpp