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_ */