Line data    Source code

       1              : #ifndef KAFKAOPMON_PLUGIN_STREAMOPMONFACILITY_HPP_
       2              : #define KAFKAOPMON_PLUGIN_STREAMOPMONFACILITY_HPP_
       3              : 
       4              : #include "kafkaopmon/OpMonPublisher.hpp"
       5              : #include "opmonlib/OpMonFacility.hpp"
       6              : 
       7              : #include <memory>
       8              : #include <nlohmann/json.hpp>
       9              : #include <regex>
      10              : #include <string>
      11              : 
      12              : using json = nlohmann::json;
      13              : 
      14              : namespace dunedaq { // namespace dunedaq
      15              : 
      16            3 : ERS_DECLARE_ISSUE(kafkaopmon, WrongURI, "Incorrect URI: " << uri, ((std::string)uri))
      17              : 
      18              : } // namespace dunedaq
      19              : 
      20              : namespace dunedaq::kafkaopmon { // namespace dunedaq
      21              : 
      22              : class streamOpMonFacility : public dunedaq::opmonlib::OpMonFacility
      23              : {
      24              :   std::unique_ptr<OpMonPublisher> m_publisher;
      25              : 
      26              : public:
      27              :   explicit streamOpMonFacility(std::string uri, dunedaq::opmonlib::OptionalOrigin);
      28            0 :   void publish(opmon::OpMonEntry&& e) const override { m_publisher->publish(std::move(e)); }
      29              : };
      30              : 
      31              : } // namespace dunedaq::kafkaopmon
      32              : 
      33              : #endif // KAFKAOPMON_PLUGIN_STREAMOPMONFACILITY_HPP_