dunedaq::ipm::Subscriber Class Reference

#include <Subscriber.hpp>

Inheritance diagram for dunedaq::ipm::Subscriber:

Collaboration diagram for dunedaq::ipm::Subscriber:

Public Member Functions
	Subscriber ()=default
virtual void	subscribe (std::string const &topic)=0
virtual void	unsubscribe (std::string const &topic)=0
	Subscriber (const Subscriber &)=delete
Subscriber &	operator= (const Subscriber &)=delete
	Subscriber (Subscriber &&)=delete
Subscriber &	operator= (Subscriber &&)=delete
Public Member Functions inherited from dunedaq::ipm::Receiver
	Receiver ()=default
virtual	~Receiver ()=default
virtual std::string	connect_for_receives (const nlohmann::json &connection_info)=0
virtual bool	can_receive () const noexcept=0
Response	receive (const duration_t &timeout, message_size_t num_bytes=s_any_size, bool no_tmoexcept_mode=false)
virtual void	register_callback (std::function< void(Response &)>)=0
virtual void	unregister_callback ()=0
	Receiver (const Receiver &)=delete
Receiver &	operator= (const Receiver &)=delete
	Receiver (Receiver &&)=delete
Receiver &	operator= (Receiver &&)=delete
Public Member Functions inherited from dunedaq::opmonlib::MonitorableObject
	MonitorableObject (const MonitorableObject &)=delete
MonitorableObject &	operator= (const MonitorableObject &)=delete
	MonitorableObject (MonitorableObject &&)=delete
MonitorableObject &	operator= (MonitorableObject &&)=delete
virtual	~MonitorableObject ()=default
auto	get_opmon_id () const noexcept
auto	get_opmon_level () const noexcept

Additional Inherited Members
Public Types inherited from dunedaq::ipm::Receiver
using	duration_t = std::chrono::milliseconds
using	message_size_t = int
Public Types inherited from dunedaq::opmonlib::MonitorableObject
using	NodePtr = std::weak_ptr<MonitorableObject>
using	NewNodePtr = std::shared_ptr<MonitorableObject>
using	ElementId = std::string
Static Public Member Functions inherited from dunedaq::opmonlib::MonitorableObject
static bool	publishable_metric (OpMonLevel entry, OpMonLevel system) noexcept
Static Public Attributes inherited from dunedaq::ipm::Receiver
static constexpr duration_t	s_block = duration_t::max()
static constexpr duration_t	s_no_block = duration_t::zero()
static constexpr message_size_t	s_any_size
Protected Member Functions inherited from dunedaq::ipm::Receiver
void	generate_opmon_data () override
virtual Response	receive_ (const duration_t &timeout, bool no_tmoexcept_mode)=0
Protected Member Functions inherited from dunedaq::opmonlib::MonitorableObject
	MonitorableObject ()=default
void	register_node (ElementId name, NewNodePtr)
void	publish (google::protobuf::Message &&, CustomOrigin &&co={}, OpMonLevel l=to_level(EntryOpMonLevel::kDefault)) const noexcept

Detailed Description

Definition at line 42 of file Subscriber.hpp.

Constructor & Destructor Documentation

Subscriber() [1/3]

dunedaq::ipm::Subscriber::Subscriber ( )

default

Subscriber() [2/3]

dunedaq::ipm::Subscriber::Subscriber ( const Subscriber & )

delete

Subscriber() [3/3]

dunedaq::ipm::Subscriber::Subscriber ( Subscriber && )

delete

Member Function Documentation

operator=() [1/2]

Subscriber & dunedaq::ipm::Subscriber::operator= ( const Subscriber & )

delete

operator=() [2/2]

Subscriber & dunedaq::ipm::Subscriber::operator= ( Subscriber && )

delete

subscribe()

virtual void dunedaq::ipm::Subscriber::subscribe ( std::string const & topic )

pure virtual

unsubscribe()

virtual void dunedaq::ipm::Subscriber::unsubscribe ( std::string const & topic )

pure virtual

---

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

• /github/workspace/dunedaq/sourcecode/ipm/include/ipm/Subscriber.hpp