#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 DescriptionDefinition in file kafka_client_test.c.
RetroSearch is an open source project built by @garambo | Open a GitHub Issue
Search and Browse the WWW like it's 1997 | Search results from DuckDuckGo
HTML:
3.2
| Encoding:
UTF-8
| Version:
0.7.4