telegrafAdapter.hpp

Go to the documentation of this file.

 
#ifndef RTCTK_COMPONENTFRAMEWORK_TELEGRAFADAPTER_HPP
#define RTCTK_COMPONENTFRAMEWORK_TELEGRAFADAPTER_HPP
 
#include <string>
#include <map>
#include <boost/asio.hpp>
#include <mal/utility/Uri.hpp>
 
#include <rtctk/componentFramework/logger.hpp>
 
namespace rtctk::componentFramework {
 
using FieldValue = std::variant<int64_t, uint64_t, float, double, bool, std::string>;

struct InfluxPoint {
    std::string table_name;

    std::map<std::string, std::string> tags;

    std::map<std::string, FieldValue> fields;

    std::optional<std::chrono::nanoseconds> timestamp = std::nullopt;

    std::string ToLineProtocol() const;
};
 
std::vector<InfluxPoint>
ParseStateToInfluxPoints(const std::string& component_name,
                         const std::string& states_str,
                         const std::map<std::string, std::string>& base_tags);

class TelegrafAdapter {
public:
    TelegrafAdapter() = delete;

    TelegrafAdapter(const TelegrafAdapter&) = delete;

    TelegrafAdapter& operator=(const TelegrafAdapter&) = delete;

    explicit TelegrafAdapter(const elt::mal::Uri& uri, std::string component);
 
    ~TelegrafAdapter() = default;

    std::map<std::string, std::string> BaseTags();

    void SendPoints(const std::vector<InfluxPoint>& points);
 
private:
    static const std::size_t MTU = 1500;
 
    boost::asio::io_service m_io_service;
    boost::asio::ip::udp::socket m_socket;
    boost::asio::ip::udp::endpoint m_endpoint;
    std::string m_host;
    std::string m_pid;
    std::string m_component;
    std::mutex m_mutex;
    log4cplus::Logger m_logger;
    bool m_enabled = true;
};
 
}  // namespace rtctk::componentFramework
 
#endif  // RTCTK_COMPONENTFRAMEWORK_TELEGRAFADAPTER_HPP