ProtoBufStream.hpp

Go to the documentation of this file.

 
#ifndef ERSKAFKA_PROTOBUFSTREAM_HPP
#define ERSKAFKA_PROTOBUFSTREAM_HPP
 
#include "erskafka/ERSPublisher.hpp"
#include <ers/OutputStream.hpp>
 
#include <memory>
#include <string>
#include <vector>
 
namespace erskafka {
 
class ProtoBufStream : public ers::OutputStream
{
public:
  explicit ProtoBufStream(const std::string& param);
  void write(const ers::Issue& issue) override;
 
private:
  std::unique_ptr<dunedaq::erskafka::ERSPublisher> m_publisher;
  std::string m_session;
  std::string m_application;
};
} // namespace erskafka
 
#endif // ERSKAFKA_ERSSTREAM_HPP