ceph/src/test/rgw/kafka_stub.cc

   1 // -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
   2 // vim: ts=8 sw=2 smarttab
   3
   4 #include <librdkafka/rdkafka.h>
   5
   6 const char *rd_kafka_topic_name(const rd_kafka_topic_t *rkt) {
   7     return "";
   8 }
   9
  10 rd_kafka_resp_err_t rd_kafka_last_error() {
  11     return rd_kafka_resp_err_t();
  12 }
  13
  14 const char *rd_kafka_err2str(rd_kafka_resp_err_t err) {
  15     return "";
  16 }
  17
  18 rd_kafka_conf_t *rd_kafka_conf_new() {
  19     return nullptr;
  20 }
  21
  22 rd_kafka_conf_res_t rd_kafka_conf_set(rd_kafka_conf_t *conf,
  23                                        const char *name,
  24                                        const char *value,
  25                                        char *errstr, size_t errstr_size) {
  26     return rd_kafka_conf_res_t();
  27 }
  28
  29 void rd_kafka_conf_set_dr_msg_cb(rd_kafka_conf_t *conf,
  30                                   void (*dr_msg_cb) (rd_kafka_t *rk,
  31                                                      const rd_kafka_message_t *
  32                                                      rkmessage,
  33                                                      void *opaque)) {}
  34
  35 void rd_kafka_conf_set_opaque(rd_kafka_conf_t *conf, void *opaque) {}
  36
  37 rd_kafka_t *rd_kafka_new(rd_kafka_type_t type, rd_kafka_conf_t *conf,
  38                       char *errstr, size_t errstr_size) {
  39     return nullptr;
  40 }
  41
  42 void rd_kafka_conf_destroy(rd_kafka_conf_t *conf) {}
  43
  44 rd_kafka_resp_err_t rd_kafka_flush (rd_kafka_t *rk, int timeout_ms) {
  45     return rd_kafka_resp_err_t();
  46 }
  47
  48 void rd_kafka_destroy(rd_kafka_t *rk) {}
  49
  50 rd_kafka_topic_t *rd_kafka_topic_new(rd_kafka_t *rk, const char *topic,
  51                               rd_kafka_topic_conf_t *conf) {
  52     return nullptr;
  53 }
  54
  55 int rd_kafka_produce(rd_kafka_topic_t *rkt, int32_t partition,
  56                       int msgflags,
  57                       void *payload, size_t len,
  58                       const void *key, size_t keylen,
  59                       void *msg_opaque) {
  60     return 0;
  61 }
  62
  63 int rd_kafka_poll(rd_kafka_t *rk, int timeout_ms) {
  64     return 0;
  65 }
  66
  67 void rd_kafka_topic_destroy(rd_kafka_topic_t *rkt) {}
  68