Monitoring.h

Go to the documentation of this file.

// 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.


#ifndef ALICEO2_MONITORING_MONITORING_H
#define ALICEO2_MONITORING_MONITORING_H

#include <atomic>
#include <chrono>
#include <map>
#include <memory>
#include <string>
#include <thread>
#include <tuple>
#include <unordered_map>
#include <vector>
#include <deque>

#include "Monitoring/Backend.h"
#include "Monitoring/DerivedMetrics.h"
#include "Monitoring/ProcessMonitor.h"

namespace o2
{
namespace monitoring
{

class Monitoring
{
 public:
  Monitoring& operator=(const Monitoring&) = delete;

  Monitoring(const Monitoring&) = delete;

  Monitoring();

  void addBackend(std::unique_ptr<Backend> backend);

  ~Monitoring();

  void send(Metric&& metric, DerivedMetricMode mode = DerivedMetricMode::NONE);

  void enableProcessMonitoring(const unsigned int interval = 5);

  void flushBuffer();

  void enableBuffering(const std::size_t size = 128);

  void addGlobalTag(std::string_view name, std::string_view value);

  void addGlobalTag(tags::Key key, tags::Value value);

  //ComplexMetric& getAutoPushMetric(std::string name, unsigned int interval = 1);

 private:
  void transmit(std::vector<Metric>&& metrics);

  void flushBuffer(short index);

  bool matchVerbosity(Verbosity backend, Verbosity metric);

  std::unique_ptr<DerivedMetrics> mDerivedHandler;

  std::vector<std::unique_ptr<Backend>> mBackends;

  void transmit(Metric&& metric);

  std::atomic<bool> mMonitorRunning;

  std::thread mMonitorThread;

  std::unique_ptr<ProcessMonitor> mProcessMonitor;

  void pushLoop();

  std::unordered_map<std::underlying_type<Verbosity>::type, std::vector<Metric>> mStorage;

  bool mBuffering;

  std::size_t mBufferSize;

  //std::deque<ComplexMetric> mPushStore;

  std::atomic<unsigned int> mProcessMonitoringInterval;

  //std::atomic<unsigned int> mAutoPushInterval;
};

} // namespace monitoring
} // namespace o2

#endif // ALICEO2_MONITORING_MONITORING_H