| /dports/net/librdkafka/librdkafka-1.8.2/tests/ |
| H A D | 0073-headers.c | 48 rd_kafka_message_t *rkmessage, int is_const) { in expect_check()
190 rd_kafka_message_t *rkmessage, int is_const) { in msg_final_check()
211 static void handle_consumed_msg (rd_kafka_message_t *rkmessage) { in handle_consumed_msg()
219 const rd_kafka_message_t *rkmessage, void *opaque) { in dr_msg_cb()
232 rd_kafka_message_t *rkmessage, in on_send1()
266 rd_kafka_message_t *rkmessage, in on_send2()
|
| H A D | 0072-headers_ut.c | 49 const rd_kafka_message_t *rkmessage) { in expect_check()
159 const rd_kafka_message_t *rkmessage, void *opaque) { in dr_msg_cb()
243 rd_kafka_message_t *rkmessage, in on_send1()
325 rd_kafka_message_t *rkmessage, in on_send2()
|
| H A D | 0012-produce_consume.c | 245 rd_kafka_message_t *rkmessage) { in verify_consumed_msg0()
297 #define verify_consumed_msg(testid,part,msgnum,rkmessage) \ argument
333 rd_kafka_message_t *rkmessage; in consume_messages() local
417 rd_kafka_message_t *rkmessage; in consume_messages_with_queues() local
|
| H A D | 0013-null-msgs.c | 208 rd_kafka_message_t *rkmessage) { in verify_consumed_msg0()
264 #define verify_consumed_msg(testid,part,msgnum,rkmessage) \ argument
298 rd_kafka_message_t *rkmessage; in consume_messages() local
372 rd_kafka_message_t *rkmessage; in consume_messages_with_queues() local
|
| H A D | 0064-interceptors.c | 113 rd_kafka_message_t *rkmessage, void *ic_opaque) { in verify_msg()
155 rd_kafka_message_t *rkmessage, in on_send()
163 rd_kafka_message_t *rkmessage, in on_ack()
171 rd_kafka_message_t *rkmessage, in on_consume()
|
| H A D | 0014-reconsume-191.c | 235 rd_kafka_message_t *rkmessage) { in verify_consumed_msg0()
287 #define verify_consumed_msg(testid,part,msgnum,rkmessage) \ argument
291 static void consume_cb (rd_kafka_message_t *rkmessage, void *opaque) { in consume_cb()
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/tests/ |
| H A D | 0073-headers.c | 48 rd_kafka_message_t *rkmessage, int is_const) { in expect_check()
190 rd_kafka_message_t *rkmessage, int is_const) { in msg_final_check()
211 static void handle_consumed_msg (rd_kafka_message_t *rkmessage) { in handle_consumed_msg()
219 const rd_kafka_message_t *rkmessage, void *opaque) { in dr_msg_cb()
232 rd_kafka_message_t *rkmessage, in on_send1()
266 rd_kafka_message_t *rkmessage, in on_send2()
|
| H A D | 0072-headers_ut.c | 49 const rd_kafka_message_t *rkmessage) { in expect_check()
159 const rd_kafka_message_t *rkmessage, void *opaque) { in dr_msg_cb()
243 rd_kafka_message_t *rkmessage, in on_send1()
325 rd_kafka_message_t *rkmessage, in on_send2()
|
| H A D | 0012-produce_consume.c | 245 rd_kafka_message_t *rkmessage) { in verify_consumed_msg0()
297 #define verify_consumed_msg(testid,part,msgnum,rkmessage) \ argument
333 rd_kafka_message_t *rkmessage; in consume_messages() local
417 rd_kafka_message_t *rkmessage; in consume_messages_with_queues() local
|
| H A D | 0013-null-msgs.c | 208 rd_kafka_message_t *rkmessage) { in verify_consumed_msg0()
264 #define verify_consumed_msg(testid,part,msgnum,rkmessage) \ argument
298 rd_kafka_message_t *rkmessage; in consume_messages() local
372 rd_kafka_message_t *rkmessage; in consume_messages_with_queues() local
|
| H A D | 0064-interceptors.c | 112 rd_kafka_message_t *rkmessage, void *ic_opaque) { in verify_msg()
150 rd_kafka_message_t *rkmessage, in on_send()
158 rd_kafka_message_t *rkmessage, in on_ack()
166 rd_kafka_message_t *rkmessage, in on_consume()
|
| H A D | 0014-reconsume-191.c | 235 rd_kafka_message_t *rkmessage) { in verify_consumed_msg0()
287 #define verify_consumed_msg(testid,part,msgnum,rkmessage) \ argument
291 static void consume_cb (rd_kafka_message_t *rkmessage, void *opaque) { in consume_cb()
|
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/tests/ |
| H A D | 0073-headers.c | 48 rd_kafka_message_t *rkmessage, int is_const) { in expect_check()
190 rd_kafka_message_t *rkmessage, int is_const) { in msg_final_check()
211 static void handle_consumed_msg (rd_kafka_message_t *rkmessage) { in handle_consumed_msg()
219 const rd_kafka_message_t *rkmessage, void *opaque) { in dr_msg_cb()
232 rd_kafka_message_t *rkmessage, in on_send1()
266 rd_kafka_message_t *rkmessage, in on_send2()
|
| H A D | 0072-headers_ut.c | 49 const rd_kafka_message_t *rkmessage) { in expect_check()
159 const rd_kafka_message_t *rkmessage, void *opaque) { in dr_msg_cb()
243 rd_kafka_message_t *rkmessage, in on_send1()
325 rd_kafka_message_t *rkmessage, in on_send2()
|
| H A D | 0012-produce_consume.c | 245 rd_kafka_message_t *rkmessage) { in verify_consumed_msg0()
297 #define verify_consumed_msg(testid,part,msgnum,rkmessage) \ argument
333 rd_kafka_message_t *rkmessage; in consume_messages() local
417 rd_kafka_message_t *rkmessage; in consume_messages_with_queues() local
|
| H A D | 0013-null-msgs.c | 208 rd_kafka_message_t *rkmessage) { in verify_consumed_msg0()
264 #define verify_consumed_msg(testid,part,msgnum,rkmessage) \ argument
298 rd_kafka_message_t *rkmessage; in consume_messages() local
372 rd_kafka_message_t *rkmessage; in consume_messages_with_queues() local
|
| H A D | 0064-interceptors.c | 113 rd_kafka_message_t *rkmessage, void *ic_opaque) { in verify_msg()
155 rd_kafka_message_t *rkmessage, in on_send()
163 rd_kafka_message_t *rkmessage, in on_ack()
171 rd_kafka_message_t *rkmessage, in on_consume()
|
| /dports/net/librdkafka/librdkafka-1.8.2/tests/interceptor_test/ |
| H A D | interceptor_test.c | 81 rd_kafka_message_t *rkmessage, in on_send()
90 rd_kafka_message_t *rkmessage, in on_acknowledgement()
100 rd_kafka_message_t *rkmessage, in on_consume()
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/tests/interceptor_test/ |
| H A D | interceptor_test.c | 81 rd_kafka_message_t *rkmessage, in on_send()
90 rd_kafka_message_t *rkmessage, in on_acknowledgement()
100 rd_kafka_message_t *rkmessage, in on_consume()
|
| /dports/net/librdkafka/librdkafka-1.8.2/examples/ |
| H A D | rdkafka_example.c | 108 const rd_kafka_message_t *rkmessage, void *opaque) { in msg_delivered()
125 static void msg_consume (rd_kafka_message_t *rkmessage, in msg_consume()
747 rd_kafka_message_t *rkmessage; in main() local
|
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/examples/ |
| H A D | rdkafka_example.c | 108 const rd_kafka_message_t *rkmessage, void *opaque) { in msg_delivered()
125 static void msg_consume (rd_kafka_message_t *rkmessage, in msg_consume()
747 rd_kafka_message_t *rkmessage; in main() local
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/src/ |
| H A D | rdkafka_event.c | 93 rd_kafka_message_t *rkmessage; in rd_kafka_event_message_next() local
137 const rd_kafka_message_t *rkmessage; in rd_kafka_event_message_array() local
|
| /dports/net/librdkafka/librdkafka-1.8.2/src/ |
| H A D | rdkafka_msg.c | 50 const char *rd_kafka_message_errstr (const rd_kafka_message_t *rkmessage) { in rd_kafka_message_errstr()
1302 void rd_kafka_message_destroy (rd_kafka_message_t *rkmessage) { in rd_kafka_message_destroy()
1327 rd_kafka_message_setup (rd_kafka_op_t *rko, rd_kafka_message_t *rkmessage) { in rd_kafka_message_setup()
1388 rd_kafka_message_t *rkmessage; in rd_kafka_message_get() local
1419 int64_t rd_kafka_message_timestamp (const rd_kafka_message_t *rkmessage, in rd_kafka_message_timestamp()
1438 int64_t rd_kafka_message_latency (const rd_kafka_message_t *rkmessage) { in rd_kafka_message_latency()
1450 int32_t rd_kafka_message_broker_id (const rd_kafka_message_t *rkmessage) { in rd_kafka_message_broker_id()
1528 rd_kafka_message_headers (const rd_kafka_message_t *rkmessage, in rd_kafka_message_headers()
1561 rd_kafka_message_detach_headers (rd_kafka_message_t *rkmessage, in rd_kafka_message_detach_headers()
1577 void rd_kafka_message_set_headers (rd_kafka_message_t *rkmessage, in rd_kafka_message_set_headers()
[all …]
|
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/src/ |
| H A D | rdkafka_msg.c | 50 const char *rd_kafka_message_errstr (const rd_kafka_message_t *rkmessage) { in rd_kafka_message_errstr()
1302 void rd_kafka_message_destroy (rd_kafka_message_t *rkmessage) { in rd_kafka_message_destroy()
1327 rd_kafka_message_setup (rd_kafka_op_t *rko, rd_kafka_message_t *rkmessage) { in rd_kafka_message_setup()
1388 rd_kafka_message_t *rkmessage; in rd_kafka_message_get() local
1419 int64_t rd_kafka_message_timestamp (const rd_kafka_message_t *rkmessage, in rd_kafka_message_timestamp()
1438 int64_t rd_kafka_message_latency (const rd_kafka_message_t *rkmessage) { in rd_kafka_message_latency()
1450 int32_t rd_kafka_message_broker_id (const rd_kafka_message_t *rkmessage) { in rd_kafka_message_broker_id()
1528 rd_kafka_message_headers (const rd_kafka_message_t *rkmessage, in rd_kafka_message_headers()
1561 rd_kafka_message_detach_headers (rd_kafka_message_t *rkmessage, in rd_kafka_message_detach_headers()
1577 void rd_kafka_message_set_headers (rd_kafka_message_t *rkmessage, in rd_kafka_message_set_headers()
[all …]
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/examples/ |
| H A D | rdkafka_example.c | 108 const rd_kafka_message_t *rkmessage, void *opaque) { in msg_delivered()
122 static void msg_consume (rd_kafka_message_t *rkmessage, in msg_consume()
746 rd_kafka_message_t *rkmessage; in main() local
|