Home
last modified time | relevance | path

Searched refs:RD_KAFKA_V_HEADER (Results 1 – 13 of 13) sorted by relevance

/dports/net/librdkafka/librdkafka-1.8.2/tests/
H A D0072-headers_ut.c420 RD_KAFKA_V_HEADER("will_be_removed", "yep", -1), in main_0072_headers_ut()
422 RD_KAFKA_V_HEADER("empty", "", 0), in main_0072_headers_ut()
446 RD_KAFKA_V_HEADER("msgid", &i, sizeof(i)), in main_0072_headers_ut()
447 RD_KAFKA_V_HEADER("static", "hey", -1), in main_0072_headers_ut()
448 RD_KAFKA_V_HEADER("multi", "multi1", -1), in main_0072_headers_ut()
449 RD_KAFKA_V_HEADER("multi", "multi2", 6), in main_0072_headers_ut()
450 RD_KAFKA_V_HEADER("multi", "multi3", strlen("multi3")), in main_0072_headers_ut()
451 RD_KAFKA_V_HEADER("null", NULL, 0), in main_0072_headers_ut()
452 RD_KAFKA_V_HEADER("empty", "", 0), in main_0072_headers_ut()
H A D0073-headers.c330 RD_KAFKA_V_HEADER("msgid", &i, sizeof(i)), in do_produce()
331 RD_KAFKA_V_HEADER("static", "hey", -1), in do_produce()
332 RD_KAFKA_V_HEADER("multi", "multi1", -1), in do_produce()
333 RD_KAFKA_V_HEADER("multi", "multi2", 6), in do_produce()
334 RD_KAFKA_V_HEADER("multi", "multi3", strlen("multi3")), in do_produce()
335 RD_KAFKA_V_HEADER("null", NULL, 0), in do_produce()
336 RD_KAFKA_V_HEADER("empty", "", 0), in do_produce()
H A D0077-compaction.c268 RD_KAFKA_V_HEADER("rdk_msgid", rdk_msgid, -1), in do_test_compaction()
/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/tests/
H A D0072-headers_ut.c420 RD_KAFKA_V_HEADER("will_be_removed", "yep", -1), in main_0072_headers_ut()
422 RD_KAFKA_V_HEADER("empty", "", 0), in main_0072_headers_ut()
446 RD_KAFKA_V_HEADER("msgid", &i, sizeof(i)), in main_0072_headers_ut()
447 RD_KAFKA_V_HEADER("static", "hey", -1), in main_0072_headers_ut()
448 RD_KAFKA_V_HEADER("multi", "multi1", -1), in main_0072_headers_ut()
449 RD_KAFKA_V_HEADER("multi", "multi2", 6), in main_0072_headers_ut()
450 RD_KAFKA_V_HEADER("multi", "multi3", strlen("multi3")), in main_0072_headers_ut()
451 RD_KAFKA_V_HEADER("null", NULL, 0), in main_0072_headers_ut()
452 RD_KAFKA_V_HEADER("empty", "", 0), in main_0072_headers_ut()
H A D0073-headers.c330 RD_KAFKA_V_HEADER("msgid", &i, sizeof(i)), in do_produce()
331 RD_KAFKA_V_HEADER("static", "hey", -1), in do_produce()
332 RD_KAFKA_V_HEADER("multi", "multi1", -1), in do_produce()
333 RD_KAFKA_V_HEADER("multi", "multi2", 6), in do_produce()
334 RD_KAFKA_V_HEADER("multi", "multi3", strlen("multi3")), in do_produce()
335 RD_KAFKA_V_HEADER("null", NULL, 0), in do_produce()
336 RD_KAFKA_V_HEADER("empty", "", 0), in do_produce()
H A D0077-compaction.c268 RD_KAFKA_V_HEADER("rdk_msgid", rdk_msgid, -1), in do_test_compaction()
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/tests/
H A D0072-headers_ut.c420 RD_KAFKA_V_HEADER("will_be_removed", "yep", -1), in main_0072_headers_ut()
422 RD_KAFKA_V_HEADER("empty", "", 0), in main_0072_headers_ut()
446 RD_KAFKA_V_HEADER("msgid", &i, sizeof(i)), in main_0072_headers_ut()
447 RD_KAFKA_V_HEADER("static", "hey", -1), in main_0072_headers_ut()
448 RD_KAFKA_V_HEADER("multi", "multi1", -1), in main_0072_headers_ut()
449 RD_KAFKA_V_HEADER("multi", "multi2", 6), in main_0072_headers_ut()
450 RD_KAFKA_V_HEADER("multi", "multi3", strlen("multi3")), in main_0072_headers_ut()
451 RD_KAFKA_V_HEADER("null", NULL, 0), in main_0072_headers_ut()
452 RD_KAFKA_V_HEADER("empty", "", 0), in main_0072_headers_ut()
H A D0073-headers.c330 RD_KAFKA_V_HEADER("msgid", &i, sizeof(i)), in do_produce()
331 RD_KAFKA_V_HEADER("static", "hey", -1), in do_produce()
332 RD_KAFKA_V_HEADER("multi", "multi1", -1), in do_produce()
333 RD_KAFKA_V_HEADER("multi", "multi2", 6), in do_produce()
334 RD_KAFKA_V_HEADER("multi", "multi3", strlen("multi3")), in do_produce()
335 RD_KAFKA_V_HEADER("null", NULL, 0), in do_produce()
336 RD_KAFKA_V_HEADER("empty", "", 0), in do_produce()
H A D0077-compaction.c268 RD_KAFKA_V_HEADER("rdk_msgid", rdk_msgid, -1),
/dports/net/kcat/kcat-1.7.0/
H A Dkcat.h50 #ifdef RD_KAFKA_V_HEADER
/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/src/
H A Drdkafka.h1108 #define RD_KAFKA_V_HEADER(NAME,VALUE,LEN) \ macro
/dports/net/librdkafka/librdkafka-1.8.2/src/
H A Drdkafka.h1214 #define RD_KAFKA_V_HEADER(NAME,VALUE,LEN) \ macro
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/src/
H A Drdkafka.h1214 #define RD_KAFKA_V_HEADER(NAME,VALUE,LEN) \ macro