Monitoring  3.3.4
O2 Monitoring library
Public Member Functions | List of all members
o2::monitoring::transports::Kafka Class Reference

Transport that sends string formatted metrics via Kafka. More...

#include <Kafka.h>

Inheritance diagram for o2::monitoring::transports::Kafka:
Collaboration diagram for o2::monitoring::transports::Kafka:

Public Member Functions

 Kafka (const std::string &host, unsigned int port, const std::string &topic="test")
 
 ~Kafka ()
 Deletes producer.
 
void send (std::string &&message) override
 

Detailed Description

Transport that sends string formatted metrics via Kafka.

Constructor & Destructor Documentation

o2::monitoring::transports::Kafka::Kafka ( const std::string &  host,
unsigned int  port,
const std::string &  topic = "test" 
)

Creates producer

Parameters
hostnameHostname
portPort number
topicKafka topic

Member Function Documentation

void o2::monitoring::transports::Kafka::send ( std::string &&  message)
overridevirtual

Sends metric via Kafka

Parameters
messager-value string formated

Implements o2::monitoring::transports::TransportInterface.

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