SWC-DB  v0.5.12 C++ documentations
SWC-DB© (Super Wide Column Database) - High Performance Scalable Database (https://github.com/kashirin-alex/swc-db)
Public Types | Public Member Functions | Public Attributes | Protected Member Functions | Protected Attributes | Private Member Functions | Private Attributes | List of all members
SWC::client::Query::Update::Handlers::Metric::Reporting Class Reference

#include <swcdb/db/client/Query/Update/Handlers/Metrics.h>

+ Inheritance diagram for SWC::client::Query::Update::Handlers::Metric::Reporting:
+ Collaboration diagram for SWC::client::Query::Update::Handlers::Metric::Reporting:

Public Types

typedef std::shared_ptr< Reporting > Ptr
 
- Public Types inherited from SWC::client::Query::Update::Handlers::BaseSingleColumn
typedef std::shared_ptr< BaseSingleColumn > Ptr
 
- Public Types inherited from SWC::client::Query::Update::Handlers::Base
typedef std::shared_ptr< Base > Ptr
 
typedef Core::Vector< Column * > Colms
 

Public Member Functions

 Reporting (const Clients::Ptr &a_clients, const Comm::IoContextPtr &a_io, Config::Property::Value_int32_g::Ptr a_cfg_intval, Clients::Flag a_executor=client::Clients::DEFAULT)
 
 Reporting (const Reporting &)=delete
 
Reporting & operator= (const Reporting &)=delete
 
virtual ~Reporting () noexcept
 
virtual void start ()
 
virtual void stop ()
 
virtual void wait ()
 
Level * get_level (const char *name)
 
virtual uint64_t apply_time (uint32_t intval, DB::Cell::KeyVec &key)
 
- Public Member Functions inherited from SWC::client::Query::Update::Handlers::BaseSingleColumn
SWC_CAN_INLINE BaseSingleColumn (const Clients::Ptr &a_clients, const cid_t cid, DB::Types::KeySeq seq, uint32_t versions, uint32_t ttl_secs, DB::Types::Column type, Clients::Flag a_executor=Clients::DEFAULT)
 
SWC_CAN_INLINE BaseSingleColumn (const Clients::Ptr &a_clients, const cid_t cid, DB::Types::KeySeq seq, uint32_t versions, uint32_t ttl_secs, DB::Types::Column type, const StaticBuffer &buffer)
 
virtual ~BaseSingleColumn () noexcept
 
virtual bool requires_commit () noexcept override
 
virtual bool empty () noexcept override
 
virtual size_t size_bytes () noexcept override
 
virtual void next (Base::Colms &cols) noexcept override
 
virtual Base::Column * next (cid_t cid) noexcept override
 
virtual void error (cid_t cid, int err) noexcept override
 
SWC_CAN_INLINE size_t size () noexcept
 
- Public Member Functions inherited from SWC::client::Query::Update::Handlers::Base
SWC_CAN_INLINE Base (const Clients::Ptr &a_clients, Clients::Flag a_executor=Clients::Flag::DEFAULT) noexcept
 
 Base (Base &&)=delete
 
 Base (const Base &)=delete
 
Base & operator= (const Base &)=delete
 
Base & operator= (Base &&)=delete
 
virtual int error () noexcept
 
virtual void error (int err) noexcept
 
SWC_CAN_INLINE void add_resend_count (size_t count) noexcept
 
SWC_CAN_INLINE size_t get_resend_count (bool reset=true) noexcept
 
void commit ()
 
SWC_CAN_INLINE void commit (const cid_t cid)
 
void commit (Column *colp)
 

Public Attributes

const Comm::IoContextPtr io
 
Config::Property::Value_int32_g::Ptr cfg_intval
 
Core::Vector< Metric::Base::Ptr > metrics
 
Core::AtomicBool running
 
- Public Attributes inherited from SWC::client::Query::Update::Handlers::BaseSingleColumn
ColumnMutable column
 
- Public Attributes inherited from SWC::client::Query::Update::Handlers::Base
Clients::Ptr clients
 
Profiling profile
 
Core::Atomic< int > state_error
 
Core::CompletionCounter< uint64_t > completion
 
Core::Atomic< uint32_t > timeout
 
Core::Atomic< uint32_t > timeout_ratio
 
Core::Atomic< uint32_t > buff_sz
 
Core::Atomic< uint8_t > buff_ahead
 
const Clients::Flag executor
 

Protected Member Functions

virtual bool valid () noexcept override
 
virtual void response (int err=Error::OK) override
 
- Protected Member Functions inherited from SWC::client::Query::Update::Handlers::Base
virtual void _execute (Column *colp)
 
virtual ~Base () noexcept
 

Protected Attributes

Core::MutexSptd m_mutex
 

Private Member Functions

void report ()
 
void schedule ()
 

Private Attributes

asio::high_resolution_timer m_timer
 

Detailed Description

Definition at line 233 of file Metrics.h.

Member Typedef Documentation

◆ Ptr

typedef std::shared_ptr<Reporting> SWC::client::Query::Update::Handlers::Metric::Reporting::Ptr

Definition at line 236 of file Metrics.h.

Constructor & Destructor Documentation

◆ Reporting() [1/2]

SWC::client::Query::Update::Handlers::Metric::Reporting::Reporting ( const Clients::Ptr &  a_clients,
const Comm::IoContextPtr &  a_io,
Config::Property::Value_int32_g::Ptr  a_cfg_intval,
Clients::Flag  a_executor = client::Clients::DEFAULT 
)

Definition at line 197 of file Metrics.cc.

◆ Reporting() [2/2]

SWC::client::Query::Update::Handlers::Metric::Reporting::Reporting ( const Reporting &  )
delete

◆ ~Reporting()

virtual SWC::client::Query::Update::Handlers::Metric::Reporting::~Reporting ( )
inlinevirtualnoexcept

Reimplemented in SWC::ThriftBroker::Metric::Reporting, SWC::Ranger::Metric::Reporting, SWC::Manager::Metric::Reporting, SWC::FsBroker::Metric::Reporting, SWC::Common::Query::Update::Metric::Reporting, and SWC::Broker::Metric::Reporting.

Definition at line 252 of file Metrics.h.

Member Function Documentation

◆ apply_time()

uint64_t SWC::client::Query::Update::Handlers::Metric::Reporting::apply_time ( uint32_t  intval,
DB::Cell::KeyVec &  key 
)
virtual

Definition at line 242 of file Metrics.cc.

References SWC::DB::Cell::KeyVec::add(), and SWC::Core::to_string().

Referenced by report().

+ Here is the call graph for this function:
+ Here is the caller graph for this function:

◆ get_level()

Level * SWC::client::Query::Update::Handlers::Metric::Reporting::get_level ( const char *  name)

Definition at line 232 of file Metrics.cc.

References SWC::Core::Vector< T, SizeT, GROW_SZ >::emplace_back(), SWC::client::Query::Update::Handlers::Metric::Level::get_level(), and metrics.

+ Here is the call graph for this function:

◆ operator=()

Reporting& SWC::client::Query::Update::Handlers::Metric::Reporting::operator= ( const Reporting &  )
delete

◆ report()

void SWC::client::Query::Update::Handlers::Metric::Reporting::report ( )
private

Definition at line 282 of file Metrics.cc.

References SWC::DB::Cell::KeyVec::add(), apply_time(), cfg_intval, SWC::client::Query::Update::Handlers::ColumnMutable::cid, SWC::client::Query::Update::Handlers::BaseSingleColumn::column, SWC::client::Query::Update::Handlers::Base::commit(), SWC::client::Query::Update::Handlers::ColumnMutable::empty(), SWC::Config::Property::Value_int32_g::get(), metrics, SWC::client::Query::Update::Handlers::Base::profile, SWC::client::Query::Profiling::reset(), running, schedule(), SWC::DB::Types::SystemColumn::SYS_CID_DEFINE_LEXIC, SWC::DB::Types::SystemColumn::SYS_CID_STATS, and SWC::Core::to_string().

Referenced by response(), and schedule().

+ Here is the call graph for this function:
+ Here is the caller graph for this function:

◆ response()

void SWC::client::Query::Update::Handlers::Metric::Reporting::response ( int  err = Error::OK)
overrideprotectedvirtual

Implements SWC::client::Query::Update::Handlers::Base.

Definition at line 248 of file Metrics.cc.

References SWC::client::Query::Update::Handlers::ColumnMutable::cid, SWC::Error::CLIENT_DATA_REMAINED, SWC::client::Query::Update::Handlers::BaseSingleColumn::column, SWC::client::Query::Update::Handlers::Base::commit(), SWC::client::Query::Update::Handlers::Base::completion, SWC::client::Query::Update::Handlers::BaseSingleColumn::empty(), SWC::client::Query::Update::Handlers::Base::error(), SWC::client::Query::Update::Handlers::ColumnMutable::error(), SWC::client::Query::Profiling::finished(), SWC::Core::CompletionCounter< CountT >::is_last(), SWC::LOG_WARN, SWC::Error::OK, SWC::Error::print(), SWC::client::Query::Update::Handlers::Base::profile, report(), SWC::client::Query::Update::Handlers::BaseSingleColumn::requires_commit(), running, schedule(), SWC::client::Query::Update::Handlers::Base::state_error, SWC::client::Query::Update::Handlers::ColumnMutable::state_error, SWC::Core::AtomicBase< T, OrderT >::store(), SWC_LOG_OSTREAM, SWC_LOG_OUT, SWC::DB::Types::SystemColumn::SYS_CID_DEFINE_LEXIC, and SWC::DB::Types::SystemColumn::SYS_CID_STATS.

+ Here is the call graph for this function:

◆ schedule()

void SWC::client::Query::Update::Handlers::Metric::Reporting::schedule ( )
private

Definition at line 307 of file Metrics.cc.

References cfg_intval, SWC::Config::Property::Value_int32_g::get(), m_mutex, m_timer, report(), running, and SWC_CAN_INLINE.

Referenced by report(), response(), and start().

+ Here is the call graph for this function:
+ Here is the caller graph for this function:

◆ start()

virtual void SWC::client::Query::Update::Handlers::Metric::Reporting::start ( )
inlinevirtual

Definition at line 254 of file Metrics.h.

References SWC::Core::AtomicBase< T, OrderT >::compare_exchange_weak(), running, and schedule().

+ Here is the call graph for this function:

◆ stop()

void SWC::client::Query::Update::Handlers::Metric::Reporting::stop ( )
virtual

Definition at line 215 of file Metrics.cc.

References SWC::Core::AtomicBase< T, OrderT >::compare_exchange_weak(), m_mutex, m_timer, and running.

+ Here is the call graph for this function:

◆ valid()

virtual bool SWC::client::Query::Update::Handlers::Metric::Reporting::valid ( )
inlineoverrideprotectedvirtualnoexcept

Implements SWC::client::Query::Update::Handlers::Base.

Definition at line 272 of file Metrics.h.

References running.

◆ wait()

void SWC::client::Query::Update::Handlers::Metric::Reporting::wait ( )
virtual

Definition at line 223 of file Metrics.cc.

References SWC::client::Query::Update::Handlers::Base::completion, SWC::Core::CompletionCounter< CountT >::count(), SWC::LOG_WARN, SWC_FMT_LU, and SWC_LOGF.

+ Here is the call graph for this function:

Member Data Documentation

◆ cfg_intval

Config::Property::Value_int32_g::Ptr SWC::client::Query::Update::Handlers::Metric::Reporting::cfg_intval

Definition at line 239 of file Metrics.h.

Referenced by SWC::Common::Query::Update::Metric::Reporting::System::get_cpu_ms_interval(), report(), and schedule().

◆ io

const Comm::IoContextPtr SWC::client::Query::Update::Handlers::Metric::Reporting::io

Definition at line 238 of file Metrics.h.

◆ m_mutex

Core::MutexSptd SWC::client::Query::Update::Handlers::Metric::Reporting::m_mutex
protected

Definition at line 270 of file Metrics.h.

Referenced by schedule(), and stop().

◆ m_timer

asio::high_resolution_timer SWC::client::Query::Update::Handlers::Metric::Reporting::m_timer
private

Definition at line 285 of file Metrics.h.

Referenced by schedule(), and stop().

◆ metrics

Core::Vector<Metric::Base::Ptr> SWC::client::Query::Update::Handlers::Metric::Reporting::metrics

Definition at line 240 of file Metrics.h.

Referenced by get_level(), and report().

◆ running

Core::AtomicBool SWC::client::Query::Update::Handlers::Metric::Reporting::running

Definition at line 241 of file Metrics.h.

Referenced by report(), response(), schedule(), start(), stop(), and valid().

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