collector_adapters.h

Go to the documentation of this file.

// BSD 3-Clause License
// Copyright (c) 2021-2025, 🍀☀🌕🌥 🌊
// See the LICENSE file in the project root for full license information.
 
#pragma once
 
#include <memory>
#include <string>
#include <vector>
 
#include "metric_factory.h"
 
namespace kcenon::monitoring {
 
template <typename T>
class plugin_collector_adapter : public collector_interface {
   public:
    plugin_collector_adapter() : collector_(std::make_unique<T>()) {}
 
    bool initialize(const config_map& config) override {
        return collector_->initialize(config);
    }
 
    [[nodiscard]] std::string get_name() const override { return std::string(collector_->name()); }
 
    [[nodiscard]] bool is_healthy() const override { return collector_->is_available(); }
 
    [[nodiscard]] std::vector<std::string> get_metric_types() const override {
        return collector_->get_metric_types();
    }
 
    [[nodiscard]] T* get_collector() { return collector_.get(); }
    [[nodiscard]] const T* get_collector() const { return collector_.get(); }
 
   private:
    std::unique_ptr<T> collector_;
};
 
template <typename T>
class crtp_collector_adapter : public collector_interface {
   public:
    crtp_collector_adapter() : collector_(std::make_unique<T>()) {}
 
    bool initialize(const config_map& config) override {
        return collector_->initialize(config);
    }
 
    [[nodiscard]] std::string get_name() const override { return collector_->get_name(); }
 
    [[nodiscard]] bool is_healthy() const override { return collector_->is_available(); }
 
    [[nodiscard]] std::vector<std::string> get_metric_types() const override {
        return collector_->get_metric_types();
    }
 
    [[nodiscard]] T* get_collector() { return collector_.get(); }
    [[nodiscard]] const T* get_collector() const { return collector_.get(); }
 
   private:
    std::unique_ptr<T> collector_;
};
 
template <typename T>
class standalone_collector_adapter : public collector_interface {
   public:
    standalone_collector_adapter() : collector_(std::make_unique<T>()) {}
 
    bool initialize(const config_map& config) override {
        return collector_->initialize(config);
    }
 
    [[nodiscard]] std::string get_name() const override { return collector_->get_name(); }
 
    [[nodiscard]] bool is_healthy() const override { return collector_->is_healthy(); }
 
    [[nodiscard]] std::vector<std::string> get_metric_types() const override {
        return collector_->get_metric_types();
    }
 
    [[nodiscard]] T* get_collector() { return collector_.get(); }
    [[nodiscard]] const T* get_collector() const { return collector_.get(); }
 
   private:
    std::unique_ptr<T> collector_;
};
 
template <typename T>
bool register_plugin_collector(const std::string& name) {
    return metric_factory::instance().register_collector(name, []() {
        return std::make_unique<plugin_collector_adapter<T>>();
    });
}
 
template <typename T>
bool register_crtp_collector(const std::string& name) {
    return metric_factory::instance().register_collector(name, []() {
        return std::make_unique<crtp_collector_adapter<T>>();
    });
}
 
template <typename T>
bool register_standalone_collector(const std::string& name) {
    return metric_factory::instance().register_collector(name, []() {
        return std::make_unique<standalone_collector_adapter<T>>();
    });
}
 
}  // namespace kcenon::monitoring