Packages

erlkaf

1.1.3
2.2.1 2.2.0 2.1.9 2.1.8 2.1.7 2.1.6 2.1.5 2.1.4 2.1.3 2.1.2 2.1.1 2.1.0 2.0.9 2.0.8 2.0.7 2.0.6 2.0.5 2.0.4 2.0.3 2.0.2 2.0.1 2.0.0 1.2.0 1.1.9 1.1.8 1.1.7 1.1.6 1.1.5 1.1.4 1.1.3

erlkaf - Erlang Kafka library based on librdkafka

HexDocs

Current section

Files

Jump to
Readme
30 Versions
3 Dependencies
Dependants
Files
Activity
erlkaf c_src topicmanager.h
Raw

c_src/topicmanager.h 

#ifndef ERLKAF_C_SRC_TOPICMANAGER_H_

#define ERLKAF_C_SRC_TOPICMANAGER_H_



#include "rdkafka.h"

#include "macros.h"

#include "critical_section.h"



#include <map>

#include <string>



class TopicManager

{

public:



    explicit TopicManager(rd_kafka_t *rk);

    ~TopicManager();



    rd_kafka_topic_t* AddTopic(const std::string& name, rd_kafka_topic_conf_t* conf, bool* already_exist);

    rd_kafka_topic_t* GetOrCreateTopic(const std::string& name);



private:



    DISALLOW_COPY_AND_ASSIGN(TopicManager);



    void Cleanup();



    CriticalSection crt_;

    std::map<std::string, rd_kafka_topic_t*> topics_;

    rd_kafka_t* rk_;

};



#endif