#include <swcdb/ranger/queries/update/MetricsReporting.h>
Public Types | |
typedef std::shared_ptr< Reporting > | Ptr |
Public Types inherited from SWC::Common::Query::Update::Metric::Reporting | |
typedef std::shared_ptr< Reporting > | Ptr |
Public Types inherited from SWC::client::Query::Update::Handlers::Metric::Reporting | |
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 Comm::IoContextPtr &a_io) | |
Reporting (const Reporting &)=delete | |
Reporting (Reporting &&)=delete | |
Reporting & | operator= (const Reporting &)=delete |
Reporting & | operator= (Reporting &&)=delete |
void | configure_rgr (const char *, const Comm::EndPoints &endpoints) |
virtual | ~Reporting () noexcept |
Public Member Functions inherited from SWC::Common::Query::Update::Metric::Reporting | |
Reporting (const SWC::client::Clients::Ptr &a_clients, const Comm::IoContextPtr &a_io, Config::Property::Value_int32_g::Ptr a_cfg_intval, client::Clients::Flag a_executor=client::Clients::DEFAULT) | |
virtual Level * | configure (const char *group_name, const char *inst_name, const char *host, const Comm::EndPoints &endpoints) |
Reporting (const Reporting &)=delete | |
Reporting (Reporting &&)=delete | |
Reporting & | operator= (const Reporting &)=delete |
Reporting & | operator= (Reporting &&)=delete |
Public Member Functions inherited from 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) | |
Reporting (const Reporting &)=delete | |
Reporting & | operator= (const Reporting &)=delete |
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 | |
Item_Net< Comm::Protocol::Rgr::Commands > * | net |
Public Attributes inherited from SWC::Common::Query::Update::Metric::Reporting | |
SWC::Common::Query::Update::Metric::Reporting::System | system |
Item_CPU * | cpu |
Item_Mem * | mem |
Public Attributes inherited from SWC::client::Query::Update::Handlers::Metric::Reporting | |
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 |
Additional Inherited Members | |
Protected Member Functions inherited from SWC::client::Query::Update::Handlers::Metric::Reporting | |
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 inherited from SWC::client::Query::Update::Handlers::Metric::Reporting | |
Core::MutexSptd | m_mutex |
Definition at line 23 of file MetricsReporting.h.
typedef std::shared_ptr<Reporting> SWC::Ranger::Metric::Reporting::Ptr |
Definition at line 26 of file MetricsReporting.h.
SWC::Ranger::Metric::Reporting::Reporting | ( | const Comm::IoContextPtr & | a_io | ) |
Definition at line 13 of file MetricsReporting.cc.
|
delete |
|
delete |
|
inlinevirtualnoexcept |
Reimplemented from SWC::Common::Query::Update::Metric::Reporting.
Definition at line 37 of file MetricsReporting.h.
void SWC::Ranger::Metric::Reporting::configure_rgr | ( | const char * | , |
const Comm::EndPoints & | endpoints | ||
) |
Definition at line 25 of file MetricsReporting.cc.
References SWC::Common::Query::Update::Metric::Reporting::configure(), SWC::Env::FsInterface::fs(), SWC::Env::Config::settings(), and SWC_THROW.
Item_Net<Comm::Protocol::Rgr::Commands>* SWC::Ranger::Metric::Reporting::net |
Definition at line 39 of file MetricsReporting.h.