ddtStatisticsClient.hpp

Go to the documentation of this file.

 
#ifndef DDTSTATISTICSCLIENT_HPP_
#define DDTSTATISTICSCLIENT_HPP_
 
#include "ddt/ddtConstants.hpp"
#include "ddt/ddtDataTransferLib.hpp"
#include "ddt/ddtLogger.hpp"
#include "ddt/ddtStatistics.hpp"
 
namespace mal = ::elt::mal;
namespace datatransfer = ::elt::ddt::datatransfer;
 
namespace ddt {

class DdtStatisticsClient : public DdtDataTransferLib {
 public:
  DdtStatisticsClient(DdtLogger* ddt_logger, const std::string broker_uri);

  ~DdtStatisticsClient() override;

  DdtStatistics GetStatistics(const std::string data_stream_identifier);

  std::vector<std::string> GetRegisteredStreams();

  std::vector<std::string> GetConnectedBrokers();
 
 private:
  void Reregister() override {}

  void Init(std::string broker_uri);
};
 
}  // namespace ddt
 
#endif /* DDTSTATISTICSCLIENT_HPP_ */