dunedaq::kafkaopmon::OpMonPublisher Class Reference

#include <OpMonPublisher.hpp>

Public Member Functions
	OpMonPublisher (const nlohmann::json &conf)
	OpMonPublisher ()=delete
	OpMonPublisher (const OpMonPublisher &)=delete
OpMonPublisher &	operator= (const OpMonPublisher &)=delete
	OpMonPublisher (OpMonPublisher &&)=delete
OpMonPublisher &	operator= (OpMonPublisher &&)=delete
	~OpMonPublisher ()
void	publish (dunedaq::opmon::OpMonEntry &&) const

Protected Member Functions
std::string	extract_topic (const dunedaq::opmon::OpMonEntry &) const noexcept
std::string	extract_key (const dunedaq::opmon::OpMonEntry &e) const noexcept

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

Detailed Description

Definition at line 65 of file OpMonPublisher.hpp.

Constructor & Destructor Documentation

OpMonPublisher() [1/4]

dunedaq::kafkaopmon::OpMonPublisher::OpMonPublisher

(

const nlohmann::json &

conf

)

OpMonPublisher() [2/4]

dunedaq::kafkaopmon::OpMonPublisher::OpMonPublisher ( )

delete

OpMonPublisher() [3/4]

dunedaq::kafkaopmon::OpMonPublisher::OpMonPublisher ( const OpMonPublisher & )

delete

OpMonPublisher() [4/4]

dunedaq::kafkaopmon::OpMonPublisher::OpMonPublisher ( OpMonPublisher && )

delete

~OpMonPublisher()

dunedaq::kafkaopmon::OpMonPublisher::~OpMonPublisher

(

)

Member Function Documentation

extract_key()

std::string dunedaq::kafkaopmon::OpMonPublisher::extract_key ( const dunedaq::opmon::OpMonEntry & e ) const

inlineprotectednoexcept

Definition at line 84 of file OpMonPublisher.hpp.

                                                                            {
      return dunedaq::opmonlib::to_string(e.origin()) + '/' + e.measurement() ;
    }

extract_topic()

std::string dunedaq::kafkaopmon::OpMonPublisher::extract_topic ( const dunedaq::opmon::OpMonEntry & ) const

inlineprotectednoexcept

Definition at line 81 of file OpMonPublisher.hpp.

                                                                             {
      return m_default_topic; 
    }

operator=() [1/2]

OpMonPublisher & dunedaq::kafkaopmon::OpMonPublisher::operator= ( const OpMonPublisher & )

delete

operator=() [2/2]

OpMonPublisher & dunedaq::kafkaopmon::OpMonPublisher::operator= ( OpMonPublisher && )

delete

publish()

void dunedaq::kafkaopmon::OpMonPublisher::publish

(

dunedaq::opmon::OpMonEntry &&

)

const

Member Data Documentation

m_default_topic

std::string dunedaq::kafkaopmon::OpMonPublisher::m_default_topic = "monitoring.opmon_stream"

private

Definition at line 90 of file OpMonPublisher.hpp.

m_producer

std::unique_ptr<RdKafka::Producer> dunedaq::kafkaopmon::OpMonPublisher::m_producer

private

Definition at line 89 of file OpMonPublisher.hpp.

---

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

• /github/workspace/dunedaq/sourcecode/kafkaopmon/include/kafkaopmon/OpMonPublisher.hpp