| /dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/src/ |
| H A D | rdkafka_msg.c | 112 rd_kafka_msg_t *rkm; in rd_kafka_msg_new00() local
188 rd_kafka_msg_t *rkm; in rd_kafka_msg_new0() local
272 rd_kafka_msg_t *rkm; in rd_kafka_msg_new() local
790 rd_kafka_msg_t *rkm; in rd_kafka_msgq_set_metadata() local
820 rd_kafka_msg_t *rkm; in rd_kafka_msgq_move_acked() local
1171 rd_kafka_msg_t *rkm; in rd_kafka_message_timestamp() local
1189 rd_kafka_msg_t *rkm; in rd_kafka_message_latency() local
1271 rd_kafka_msg_t *rkm; in rd_kafka_message_headers() local
1304 rd_kafka_msg_t *rkm; in rd_kafka_message_detach_headers() local
1320 rd_kafka_msg_t *rkm; in rd_kafka_message_set_headers() local
[all …]
|
| H A D | rdkafka_msg.h | 139 #define rd_kafka_msg_enq_time(rkm) ((rkm)->rkm_ts_enq) argument
147 size_t rd_kafka_msg_wire_size (const rd_kafka_msg_t *rkm, int MsgVersion) { in rd_kafka_msg_wire_size()
303 rd_kafka_msg_t *rkm, *next; in rd_kafka_msgq_purge() local
322 rd_kafka_msg_t *rkm, in rd_kafka_msgq_deq()
339 rd_kafka_msg_t *rkm; in rd_kafka_msgq_pop() local
376 const rd_kafka_msg_t *rkm = TAILQ_FIRST(&rkmq->rkmq_msgs); in rd_kafka_msgq_first_msgid() local
436 rd_kafka_msg_t *rkm) { in rd_kafka_msgq_insert()
446 rd_kafka_msg_t *rkm) { in rd_kafka_msgq_enq()
|
| H A D | rdkafka_msgset_writer.c | 206 rd_kafka_msg_t *rkm; in rd_kafka_msgset_writer_select_MsgVersion() local
552 const rd_kafka_msg_t *rkm, in rd_kafka_msgset_writer_write_msg_payload()
613 rd_kafka_msg_t *rkm, in rd_kafka_msgset_writer_write_msg_v0_1()
683 rd_kafka_msg_t *rkm, in rd_kafka_msgset_writer_write_msg_v2()
792 rd_kafka_msg_t *rkm, in rd_kafka_msgset_writer_write_msg()
843 rd_kafka_msg_t *rkm; in rd_kafka_msgset_writer_write_msgq() local
1238 rd_kafka_msg_t rkm = { in rd_kafka_msgset_writer_compress() local
|
| /dports/net/librdkafka/librdkafka-1.8.2/src/ |
| H A D | rdkafka_msg.c | 146 rd_kafka_msg_t *rkm; in rd_kafka_msg_new00() local
223 rd_kafka_msg_t *rkm; in rd_kafka_msg_new0() local
307 rd_kafka_msg_t *rkm; in rd_kafka_msg_new() local
998 rd_kafka_msg_t *rkm; in rd_kafka_msgq_set_metadata() local
1029 rd_kafka_msg_t *rkm; in rd_kafka_msgq_move_acked() local
1421 rd_kafka_msg_t *rkm; in rd_kafka_message_timestamp() local
1439 rd_kafka_msg_t *rkm; in rd_kafka_message_latency() local
1451 rd_kafka_msg_t *rkm; in rd_kafka_message_broker_id() local
1530 rd_kafka_msg_t *rkm; in rd_kafka_message_headers() local
1563 rd_kafka_msg_t *rkm; in rd_kafka_message_detach_headers() local
[all …]
|
| H A D | rdkafka_msg.h | 141 #define rd_kafka_msg_enq_time(rkm) ((rkm)->rkm_ts_enq) argument
149 size_t rd_kafka_msg_wire_size (const rd_kafka_msg_t *rkm, int MsgVersion) { in rd_kafka_msg_wire_size()
305 rd_kafka_msg_t *rkm, *next; in rd_kafka_msgq_purge() local
324 rd_kafka_msg_t *rkm, in rd_kafka_msgq_deq()
341 rd_kafka_msg_t *rkm; in rd_kafka_msgq_pop() local
378 const rd_kafka_msg_t *rkm = TAILQ_FIRST(&rkmq->rkmq_msgs); in rd_kafka_msgq_first_msgid() local
438 rd_kafka_msg_t *rkm) { in rd_kafka_msgq_insert()
448 rd_kafka_msg_t *rkm) { in rd_kafka_msgq_enq()
|
| H A D | rdkafka_msgset_writer.c | 206 rd_kafka_msg_t *rkm; in rd_kafka_msgset_writer_select_MsgVersion() local
553 const rd_kafka_msg_t *rkm, in rd_kafka_msgset_writer_write_msg_payload()
614 rd_kafka_msg_t *rkm, in rd_kafka_msgset_writer_write_msg_v0_1()
684 rd_kafka_msg_t *rkm, in rd_kafka_msgset_writer_write_msg_v2()
793 rd_kafka_msg_t *rkm, in rd_kafka_msgset_writer_write_msg()
846 rd_kafka_msg_t *rkm; in rd_kafka_msgset_writer_write_msgq() local
1241 rd_kafka_msg_t rkm = { in rd_kafka_msgset_writer_compress() local
|
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/src/ |
| H A D | rdkafka_msg.c | 146 rd_kafka_msg_t *rkm; in rd_kafka_msg_new00() local
223 rd_kafka_msg_t *rkm; in rd_kafka_msg_new0() local
307 rd_kafka_msg_t *rkm; in rd_kafka_msg_new() local
998 rd_kafka_msg_t *rkm; in rd_kafka_msgq_set_metadata() local
1029 rd_kafka_msg_t *rkm; in rd_kafka_msgq_move_acked() local
1421 rd_kafka_msg_t *rkm; in rd_kafka_message_timestamp() local
1439 rd_kafka_msg_t *rkm; in rd_kafka_message_latency() local
1451 rd_kafka_msg_t *rkm; in rd_kafka_message_broker_id() local
1530 rd_kafka_msg_t *rkm; in rd_kafka_message_headers() local
1563 rd_kafka_msg_t *rkm; in rd_kafka_message_detach_headers() local
[all …]
|
| H A D | rdkafka_msg.h | 141 #define rd_kafka_msg_enq_time(rkm) ((rkm)->rkm_ts_enq) argument
149 size_t rd_kafka_msg_wire_size (const rd_kafka_msg_t *rkm, int MsgVersion) { in rd_kafka_msg_wire_size()
305 rd_kafka_msg_t *rkm, *next; in rd_kafka_msgq_purge() local
324 rd_kafka_msg_t *rkm, in rd_kafka_msgq_deq()
341 rd_kafka_msg_t *rkm; in rd_kafka_msgq_pop() local
378 const rd_kafka_msg_t *rkm = TAILQ_FIRST(&rkmq->rkmq_msgs); in rd_kafka_msgq_first_msgid() local
438 rd_kafka_msg_t *rkm) { in rd_kafka_msgq_insert()
448 rd_kafka_msg_t *rkm) { in rd_kafka_msgq_enq()
|
| H A D | rdkafka_msgset_writer.c | 206 rd_kafka_msg_t *rkm; in rd_kafka_msgset_writer_select_MsgVersion() local
553 const rd_kafka_msg_t *rkm, in rd_kafka_msgset_writer_write_msg_payload()
614 rd_kafka_msg_t *rkm, in rd_kafka_msgset_writer_write_msg_v0_1()
684 rd_kafka_msg_t *rkm, in rd_kafka_msgset_writer_write_msg_v2()
793 rd_kafka_msg_t *rkm, in rd_kafka_msgset_writer_write_msg()
846 rd_kafka_msg_t *rkm; in rd_kafka_msgset_writer_write_msgq() local
1241 rd_kafka_msg_t rkm = { in rd_kafka_msgset_writer_compress() local
|
| /dports/net/librdkafka/librdkafka-1.8.2/tests/ |
| H A D | 0089-max_poll_interval.c | 79 rd_kafka_message_t *rkm; in main_0089_max_poll_interval() local
157 rd_kafka_message_t *rkm; in main_0089_max_poll_interval() local
|
| H A D | 0091-max_poll_interval_timeout.c | 61 rd_kafka_message_t *rkm; in do_consume() local
207 rd_kafka_message_t *rkm; in do_test_with_assign() local
253 rd_kafka_message_t *rkm; in do_test_no_poll() local
|
| H A D | 0034-offset_reset.c | 65 rd_kafka_message_t *rkm; in do_test_reset() local
334 const rd_kafka_message_t *rkm = in offset_reset_errors() local
|
| H A D | 0030-offset_commit.c | 159 rd_kafka_message_t *rkm; in do_offset_test() local
316 rd_kafka_message_t *rkm; in do_offset_test() local
|
| H A D | 0093-holb.c | 54 rd_kafka_message_t *rkm; in do_consume() local
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/tests/ |
| H A D | 0089-max_poll_interval.c | 79 rd_kafka_message_t *rkm; in main_0089_max_poll_interval() local
157 rd_kafka_message_t *rkm; in main_0089_max_poll_interval() local
|
| H A D | 0091-max_poll_interval_timeout.c | 61 rd_kafka_message_t *rkm; in do_consume() local
207 rd_kafka_message_t *rkm; in do_test_with_assign() local
253 rd_kafka_message_t *rkm; in do_test_no_poll() local
|
| H A D | 0030-offset_commit.c | 153 rd_kafka_message_t *rkm; in do_offset_test() local
303 rd_kafka_message_t *rkm; in do_offset_test() local
|
| H A D | 0034-offset_reset.c | 62 rd_kafka_message_t *rkm; in do_test_reset() local
|
| H A D | 0093-holb.c | 54 rd_kafka_message_t *rkm; in do_consume() local
|
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/tests/ |
| H A D | 0091-max_poll_interval_timeout.c | 61 rd_kafka_message_t *rkm; in do_consume() local
207 rd_kafka_message_t *rkm; in do_test_with_assign() local
253 rd_kafka_message_t *rkm; in do_test_no_poll() local
|
| H A D | 0030-offset_commit.c | 155 rd_kafka_message_t *rkm; in do_offset_test() local
305 rd_kafka_message_t *rkm; in do_offset_test() local
|
| H A D | 0034-offset_reset.c | 63 rd_kafka_message_t *rkm; in do_test_reset() local
|
| /dports/net/librdkafka/librdkafka-1.8.2/examples/ |
| H A D | consumer.c | 208 rd_kafka_message_t *rkm; in main() local
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/examples/ |
| H A D | consumer.c | 208 rd_kafka_message_t *rkm; in main() local
|
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/examples/ |
| H A D | consumer.c | 208 rd_kafka_message_t *rkm; in main() local
|