Add InfluxDb backend with StdOut transport (#186)

Author: awegrzyn

CMakeLists.txt

@@ -102,6 +102,7 @@ add_library(Monitoring SHARED
   src/Transports/UDP.cxx
   src/Transports/TCP.cxx
   src/Transports/Unix.cxx
+  src/Transports/StdOut.cxx
   src/Exceptions/MonitoringException.cxx
   $<$<BOOL:${ApMon_FOUND}>:src/Backends/ApMonBackend.cxx>
   $<$<BOOL:${RdKafka_FOUND}>:src/Backends/Kafka.cxx>

src/MonitoringFactory.cxx

@@ -26,6 +26,7 @@
 
 #include "Transports/UDP.h"
 #include "Transports/Unix.h"
+#include "Transports/StdOut.h"
 
 #ifdef O2_MONITORING_WITH_APPMON
 #include "Backends/ApMonBackend.h"
@@ -90,7 +91,10 @@ std::unique_ptr<Backend> getInfluxDb(http::url uri)
     auto transport = std::make_unique<transports::Unix>(path);
     return std::make_unique<backends::InfluxDB>(std::move(transport));
   }
-
+  if (uri.protocol == "stdout") {
+    auto transport = std::make_unique<transports::StdOut>();
+    return std::make_unique<backends::InfluxDB>(std::move(transport));
+  }
   throw std::runtime_error("InfluxDB transport protocol not supported");
 }
 
@@ -130,6 +134,7 @@ std::unique_ptr<Backend> MonitoringFactory::GetBackend(std::string& url)
     {"stdout", getStdOut},
     {"influxdb-udp", getInfluxDb},
     {"influxdb-unix", getInfluxDb},
+    {"influxdb-stdout", getInfluxDb},
     {"apmon", getApMon},
     {"no-op", getNoop},
     {"kafka", getKafka}};

src/Transports/StdOut.cxx

@@ -0,0 +1,43 @@
+// Copyright CERN and copyright holders of ALICE O2. This software is
+// distributed under the terms of the GNU General Public License v3 (GPL
+// Version 3), copied verbatim in the file "COPYING".
+//
+// See http://alice-o2.web.cern.ch/license for full licensing information.
+//
+// In applying this license CERN does not waive the privileges and immunities
+// granted to it by virtue of its status as an Intergovernmental Organization
+// or submit itself to any jurisdiction.
+
+///
+/// \file StdOut.cxx
+/// \author Adam Wegrzynek <[email protected]>
+///
+
+#include "StdOut.h"
+#include <iostream>
+#include <string>
+
+namespace o2
+{
+/// ALICE O2 Monitoring system
+namespace monitoring
+{
+/// Monitoring transports
+namespace transports
+{
+
+void StdOut::send(std::string&& message)
+{
+  std::cout << message << std::endl;
+}
+
+template <typename T>
+StdOut& StdOut::operator<<(const T& msg)
+{
+  std::cout << msg;
+  return *this;
+}
+
+} // namespace transports
+} // namespace monitoring
+} // namespace o2

src/Transports/StdOut.h

@@ -0,0 +1,56 @@
+// Copyright CERN and copyright holders of ALICE O2. This software is
+// distributed under the terms of the GNU General Public License v3 (GPL
+// Version 3), copied verbatim in the file "COPYING".
+//
+// See http://alice-o2.web.cern.ch/license for full licensing information.
+//
+// In applying this license CERN does not waive the privileges and immunities
+// granted to it by virtue of its status as an Intergovernmental Organization
+// or submit itself to any jurisdiction.
+
+///
+/// \file StdOut.h
+/// \author Adam Wegrzynek <[email protected]>
+///
+
+#ifndef ALICEO2_MONITORING_TRANSPORTS_STDOUT_H
+#define ALICEO2_MONITORING_TRANSPORTS_STDOUT_H
+
+#include "TransportInterface.h"
+
+#include <chrono>
+#include <string>
+
+namespace o2
+{
+/// ALICE O2 Monitoring system
+namespace monitoring
+{
+/// Monitoring transports
+namespace transports
+{
+
+/// \brief Transport that sends string formatted metrics via StdOut
+class StdOut : public TransportInterface
+{
+ public:
+  /// Constructor
+  StdOut() = default;
+
+  /// Default destructor
+  ~StdOut() = default;
+
+  /// Sends metric via StdOut
+  /// \param message   r-value string formated
+  void send(std::string&& message) override;
+
+  /// Overload stream operator
+  template <typename T>
+  StdOut& operator<<(const T& msg);
+};
+
+} // namespace transports
+} // namespace monitoring
+} // namespace o2
+
+#endif // ALICEO2_MONITORING_TRANSPORTS_STDOUT_H

test/testInfluxDb.cxx

@@ -8,12 +8,12 @@
 // granted to it by virtue of its status as an Intergovernmental Organization
 // or submit itself to any jurisdiction.
 
-#include "../src/UriParser/UriParser.h"
-
 #define BOOST_TEST_MODULE Test Monitoring InfluxDB
 #define BOOST_TEST_DYN_LINK
 #include <boost/test/unit_test.hpp>
+#include "../src/UriParser/UriParser.h"
 #include "../src/Transports/UDP.h"
+#include "../src/Transports/StdOut.h"
 #include "../src/Backends/InfluxDB.h"
 
 namespace o2
@@ -33,6 +33,14 @@ BOOST_AUTO_TEST_CASE(simplySendMetric)
   influxBackend.send(metric);
 }
 
+BOOST_AUTO_TEST_CASE(simplySendMetric2)
+{
+  auto transport = std::make_unique<transports::StdOut>();
+  o2::monitoring::backends::InfluxDB influxBackend(std::move(transport));
+  o2::monitoring::Metric metric{10, "myCrazyMetric"};
+  influxBackend.send(metric);
+}
+
 } // namespace Test
 } // namespace monitoring
 } // namespace o2