ddtDataBroker.hpp

Go to the documentation of this file.

 
#ifndef DDTDATABROKER_HPP_
#define DDTDATABROKER_HPP_
 
#include <condition_variable>
#include <csignal>
#include <fstream>
 
#include "ddt/commandLineParser.hpp"
#include "ddt/ddtConnectionManager.hpp"
#include "ddt/ddtLogger.hpp"
#include "ddt/ddtInitCodes.hpp"
 
class DdtDataBroker {
 public:
  DdtDataBroker();
 
  virtual ~DdtDataBroker();
 
  ddt::InitCodes Init(int argc, char* argv[]);
 
  bool Run();
 
 private:
  ddt::CommandLineParserResult ParseCommandLine(int argc, char* argv[]);
 
  const std::string ExtractPort(const std::string uri, int& string_index) const;
 
  bool CheckPath(std::string& uri, const int string_index);
 
  std::unique_ptr<ddt::DdtLogger> logger;
 
  std::string uri_string;
 
  std::string config_file;
 
  bool datastreams_list = false;
 
  bool debug_log_enabled = false;
 
  const std::string URI_PATH{"/broker"};
};
 
#endif /* DDTDATABROKER_HPP_ */