erskafka::ProtoBufStream Class Reference

ERS stream implementation. More...

#include <ProtoBufStream.hpp>

Inheritance diagram for erskafka::ProtoBufStream:

Collaboration diagram for erskafka::ProtoBufStream:

Public Member Functions
	ProtoBufStream (const std::string &param)
void	write (const ers::Issue &issue) override
Public Member Functions inherited from ers::OutputStream
virtual	~OutputStream ()
	Sends the issue into this stream.

Private Attributes
std::unique_ptr< dunedaq::erskafka::ERSPublisher >	m_publisher
std::string	m_session
std::string	m_application

Additional Inherited Members
Protected Member Functions inherited from ers::OutputStream
	OutputStream ()
OutputStream &	chained ()
virtual bool	isNull () const

Detailed Description

ERS stream implementation.

This stream offers capability of publishing Issues to a data stream, So that other services can subscribe to the stream. A stream configuration is composed of the stream name, that is "protobufstream". Messages are transported using the ERS schema defined in ers

Definition at line 31 of file ProtoBufStream.hpp.

Constructor & Destructor Documentation

ProtoBufStream()

erskafka::ProtoBufStream::ProtoBufStream ( const std::string & param )

explicit

Definition at line 24 of file ProtoBufStream.cpp.

    : m_session("Uknown")
    , m_application("Uknown") {
 
    nlohmann::json conf;
    conf["bootstrap"] = param;
 
    m_publisher = std::make_unique<dunedaq::erskafka::ERSPublisher>(conf);
 
    if(auto env_p = std::getenv("DUNEDAQ_SESSION")) 
      m_session = env_p;
 
    if (auto app_p = std::getenv("DUNEDAQ_APPLICATION_NAME"))
      m_application = app_p;
  }

Member Function Documentation

write()

void erskafka::ProtoBufStream::write ( const ers::Issue & issue )

overridevirtual

Implements ers::OutputStream.

Member Data Documentation

m_application

std::string erskafka::ProtoBufStream::m_application

private

Definition at line 39 of file ProtoBufStream.hpp.

m_publisher

std::unique_ptr<dunedaq::erskafka::ERSPublisher> erskafka::ProtoBufStream::m_publisher

private

Definition at line 37 of file ProtoBufStream.hpp.

m_session

std::string erskafka::ProtoBufStream::m_session

private

Definition at line 38 of file ProtoBufStream.hpp.

---

The documentation for this class was generated from the following files:

• /github/workspace/dunedaq/sourcecode/erskafka/src/ProtoBufStream.hpp
• /github/workspace/dunedaq/sourcecode/erskafka/src/ProtoBufStream.cpp