Packages

erlkaf

1.1.8
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 erlkaf_logger.h
Raw

c_src/erlkaf_logger.h 

#ifndef ERLKAF_C_SRC_ERLKAF_LOGGER_H_

#define ERLKAF_C_SRC_ERLKAF_LOGGER_H_



#include "erlkaf_nif.h"



#include <string>



typedef struct rd_kafka_s rd_kafka_t;



enum kRdLogLevel {

    kRdLogLevelEmergency = 0,

    kRdLogLevelAlert,

    kRdLogLevelCritical,

    kRdLogLevelError,

    kRdLogLevelWarning,

    kRdLogLevelNotice,

    kRdLogLevelInfo,

    kRdLogLevelDebug

};



void logger_callback(const rd_kafka_t *rk, int level, const char *fac, const char *buf);

ERL_NIF_TERM nif_set_logger_pid(ErlNifEnv* env, int argc, const ERL_NIF_TERM argv[]);



void log_message(const rd_kafka_t *rk, kRdLogLevel level, const std::string& msg);



#endif