dunedaq::erskafka::ERSPublisher Class Reference

#include <ERSPublisher.hpp>

Public Member Functions
	ERSPublisher (const nlohmann::json &conf)
	ERSPublisher ()=delete
	ERSPublisher (const ERSPublisher &)=delete
ERSPublisher &	operator= (const ERSPublisher &)=delete
	ERSPublisher (ERSPublisher &&)=delete
ERSPublisher &	operator= (ERSPublisher &&)=delete
	~ERSPublisher ()
bool	publish (dunedaq::ersschema::IssueChain &&) const

Protected Member Functions
std::string	topic (const dunedaq::ersschema::IssueChain &) const
std::string	key (const dunedaq::ersschema::IssueChain &i) const

Private Attributes
std::unique_ptr< RdKafka::Producer >	m_producer
std::string	m_default_topic = "monitoring.ers_stream"

Detailed Description

Definition at line 28 of file ERSPublisher.hpp.

Constructor & Destructor Documentation

ERSPublisher() [1/4]

dunedaq::erskafka::ERSPublisher::ERSPublisher

(

const nlohmann::json &

conf

)

ERSPublisher() [2/4]

dunedaq::erskafka::ERSPublisher::ERSPublisher ( )

delete

ERSPublisher() [3/4]

dunedaq::erskafka::ERSPublisher::ERSPublisher ( const ERSPublisher & )

delete

ERSPublisher() [4/4]

dunedaq::erskafka::ERSPublisher::ERSPublisher ( ERSPublisher && )

delete

~ERSPublisher()

dunedaq::erskafka::ERSPublisher::~ERSPublisher ( )

inline

Definition at line 40 of file ERSPublisher.hpp.

{;}

Member Function Documentation

key()

std::string dunedaq::erskafka::ERSPublisher::key ( const dunedaq::ersschema::IssueChain & i ) const

inlineprotected

Definition at line 51 of file ERSPublisher.hpp.

                                                                  {
    return i.session() ;
      }

operator=() [1/2]

ERSPublisher & dunedaq::erskafka::ERSPublisher::operator= ( const ERSPublisher & )

delete

operator=() [2/2]

ERSPublisher & dunedaq::erskafka::ERSPublisher::operator= ( ERSPublisher && )

delete

publish()

bool dunedaq::erskafka::ERSPublisher::publish

(

dunedaq::ersschema::IssueChain &&

)

const

topic()

std::string dunedaq::erskafka::ERSPublisher::topic ( const dunedaq::ersschema::IssueChain & ) const

inlineprotected

Definition at line 47 of file ERSPublisher.hpp.

                                                                  {
        return m_default_topic;
      }

Member Data Documentation

m_default_topic

std::string dunedaq::erskafka::ERSPublisher::m_default_topic = "monitoring.ers_stream"

private

Definition at line 58 of file ERSPublisher.hpp.

m_producer

std::unique_ptr<RdKafka::Producer> dunedaq::erskafka::ERSPublisher::m_producer

private

Definition at line 57 of file ERSPublisher.hpp.

---

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

• /github/workspace/dunedaq/sourcecode/erskafka/include/erskafka/ERSPublisher.hpp