src/kafka_client_test.c File Reference

#include <string.h>
#include <stdlib.h>
#include <limits.h>

Go to the source code of this file.

Data Structures
struct	rd_kafka_t
struct	rd_kafka_topic_t
struct	rd_kafka_conf_t
struct	rd_kafka_topic_conf_t
struct	test_config
struct	_zhandle_t
struct	String_vector
Defines
#define	RD_KAFKA_CONF_OK   1
#define	RD_KAFKA_PRODUCER   42
#define	RD_KAFKA_PARTITION_UA   42
#define	RD_KAFKA_MSG_F_COPY   42
#define	asprintf(x,...)   (test_with()->asprintf_sets_NULL? (*x = NULL) == NULL : asprintf(x, __VA_ARGS__))
#define	ZOK   1
#define	ZOO_CHILD_EVENT   4
#define	ZOO_LOG_LEVEL_ERROR   1
Typedefs
typedef int	rd_kafka_conf_res_t
typedef int	rd_kafka_type_t
typedef struct _zhandle_t	zhandle_t
typedef void(*	watcher_fn )(zhandle_t *zh, int type, int state, const char *path, void *watcherCtx)
Functions
static struct fuse_context *	test_fuse_get_context ()
rd_kafka_conf_t *	rd_kafka_conf_new ()
rd_kafka_topic_conf_t *	rd_kafka_topic_conf_new ()
void	rd_kafka_conf_set_dr_cb (rd_kafka_conf_t *conf, void *f)
static test_config *	test_with ()
rd_kafka_conf_res_t	rd_kafka_conf_set (rd_kafka_conf_t *conf, const char *name, const char *value, char *errstr, size_t errstr_size)
rd_kafka_t *	rd_kafka_new (rd_kafka_type_t type, rd_kafka_conf_t *conf, char *errstr, size_t errstr_size)
void	rd_kafka_destroy (rd_kafka_t *to_destroy)
void	rd_kafka_wait_destroyed (int timeout_ms)
void	rd_kafka_topic_destroy (rd_kafka_topic_t *rkt)
void	rd_kafka_set_logger (rd_kafka_t *rk, void *f)
void	rd_kafka_set_log_level (rd_kafka_t *rk, int level)
int	rd_kafka_brokers_add (rd_kafka_t *rk, const char *brokerlist)
rd_kafka_topic_t *	rd_kafka_topic_new (rd_kafka_t *rk, const char *topic, rd_kafka_topic_conf_t *conf)
int	rd_kafka_produce (rd_kafka_topic_t *rkt, int32_t partitition, int msgflags, void *payload, size_t len, const void *key, size_t keylen, void *msg_opaque)
int	rd_kafka_poll (rd_kafka_t *rk, int timeout_ms)
void	zoo_set_debug_level (int level)
zhandle_t *	zookeeper_init (const char *host, watcher_fn fn, int recv_timeout, void *clientid, void *context, int flags)
int	zookeeper_close (zhandle_t *zh)
int	zoo_get_children (zhandle_t *zh, const char *path, int watch, struct String_vector *strings)
int	zoo_get (zhandle_t *zh, const char *path, int watch, char *buffer, int *buffer_len, void *stat)
int	deallocate_String_vector (struct String_vector *v)

---

Detailed Description

Definition in file kafka_client_test.c.