ddtDataBroker.hpp

Go to the documentation of this file.

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