MetricsReporting.cc

Go to the documentation of this file.

/*
 * SWC-DB© Copyright since 2019 Alex Kashirin <kashirin.alex@gmail.com>
 * License details at <https://github.com/kashirin-alex/swc-db/#license>
 */
 
 
#include "swcdb/ranger/queries/update/MetricsReporting.h"
 
 
namespace SWC { namespace Ranger { namespace Metric {
 
 
Reporting::Reporting(const Comm::IoContextPtr& a_io)
        : Common::Query::Update::Metric::Reporting(
            Env::Clients::get(),
            a_io,
            Env::Config::settings()->get<Config::Property::Value_int32_g>(
              "swc.rgr.metrics.report.interval"),
            Env::Config::settings()->get_bool("swc.rgr.metrics.report.broker")
              ? client::Clients::BROKER : client::Clients::DEFAULT
          ),
          net(nullptr) {
}
 
void Reporting::configure_rgr(const char*, const Comm::EndPoints& endpoints) {
  char hostname[256];
  if(gethostname(hostname, sizeof(hostname)) == -1)
    SWC_THROW(errno, "gethostname");
 
  auto level = Common::Query::Update::Metric::Reporting::configure(
    "swcdb", "rgr", hostname, endpoints
  );
 
  level->metrics.emplace_back(
    net = new Item_Net<Comm::Protocol::Rgr::Commands>(
      endpoints, Env::Config::settings()->get_bool("swc.comm.ssl")));
 
  const auto& fs = Env::FsInterface::fs();
  if(fs->statistics.enabled)
    level->metrics.emplace_back(new Item_FS(fs));
  // ++ Ranger Metrics
}
 
 
 
}}} // namespace SWC::Ranger::Metric