/dports/net/librdkafka/librdkafka-1.8.2/src/ |
H A D | rdkafka_assignor.h | 69 rd_kafkap_bytes_t *rkgm_userdata; 71 rd_kafkap_bytes_t *rkgm_member_metadata; 119 rd_kafkap_bytes_t *(*rkas_get_metadata_cb) ( 129 const rd_kafkap_bytes_t *assignment_userdata, 155 rd_kafkap_bytes_t *(*get_metadata_cb) ( 165 const rd_kafkap_bytes_t *userdata, 171 rd_kafkap_bytes_t * 178 rd_kafkap_bytes_t *
|
H A D | rdkafka_proto.h | 381 } rd_kafkap_bytes_t; typedef 407 static RD_UNUSED void rd_kafkap_bytes_destroy (rd_kafkap_bytes_t *kbytes) { in rd_kafkap_bytes_destroy() 424 rd_kafkap_bytes_t *rd_kafkap_bytes_new (const char *bytes, int32_t len) { in rd_kafkap_bytes_new() 425 rd_kafkap_bytes_t *kbytes; in rd_kafkap_bytes_new() 431 kbytes = (rd_kafkap_bytes_t *)rd_malloc(sizeof(*kbytes) + 4 + in rd_kafkap_bytes_new() 455 rd_kafkap_bytes_t *rd_kafkap_bytes_copy (const rd_kafkap_bytes_t *src) { in rd_kafkap_bytes_copy() 461 static RD_INLINE RD_UNUSED int rd_kafkap_bytes_cmp (const rd_kafkap_bytes_t *a, in rd_kafkap_bytes_cmp() 462 const rd_kafkap_bytes_t *b) { in rd_kafkap_bytes_cmp() 472 int rd_kafkap_bytes_cmp_data (const rd_kafkap_bytes_t *a, in rd_kafkap_bytes_cmp_data()
|
H A D | rdkafka_mock_int.h | 69 rd_kafkap_bytes_t *metadata; 82 rd_kafkap_bytes_t *assignment; /**< Current assignment */ 164 rd_kafkap_bytes_t bytes; 386 const rd_kafkap_bytes_t *bytes, 411 const rd_kafkap_bytes_t *Metadata);
|
H A D | rdkafka_assignor.c | 108 rd_kafkap_bytes_t * 115 rd_kafkap_bytes_t *kbytes; in rd_kafka_consumer_protocol_member_metadata_new() 173 rd_kafkap_bytes_t * 500 rd_kafkap_bytes_t *(*get_metadata_cb) ( in rd_kafka_assignor_add() 510 const rd_kafkap_bytes_t *userdata, in rd_kafka_assignor_add()
|
H A D | rdkafka_msgset_reader.c | 556 rd_kafkap_bytes_t Key; in rd_kafka_msgset_reader_msg_v0_1() 557 rd_kafkap_bytes_t Value; in rd_kafka_msgset_reader_msg_v0_1() 732 rd_kafkap_bytes_t Key; in rd_kafka_msgset_reader_msg_v2() 733 rd_kafkap_bytes_t Value; in rd_kafka_msgset_reader_msg_v2() 734 rd_kafkap_bytes_t Headers; in rd_kafka_msgset_reader_msg_v2()
|
H A D | rdkafka_buf.h | 1227 const rd_kafkap_bytes_t *kbytes) { in rd_kafka_buf_write_kbytes() 1248 const rd_kafkap_bytes_t *kbytes){ in rd_kafka_buf_push_kbytes()
|
H A D | rdkafka_msg.h | 130 rd_kafkap_bytes_t binhdrs; /**< Unparsed
|
H A D | rdkafka_mock_handlers.c | 90 rd_kafkap_bytes_t records; in rd_kafka_mock_handle_Produce() 1127 rd_kafkap_bytes_t Metadata; in rd_kafka_mock_handle_JoinGroup() 1420 rd_kafkap_bytes_t Metadata; in rd_kafka_mock_handle_SyncGroup()
|
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/src/ |
H A D | rdkafka_assignor.h | 69 rd_kafkap_bytes_t *rkgm_userdata; 71 rd_kafkap_bytes_t *rkgm_member_metadata; 119 rd_kafkap_bytes_t *(*rkas_get_metadata_cb) ( 129 const rd_kafkap_bytes_t *assignment_userdata, 155 rd_kafkap_bytes_t *(*get_metadata_cb) ( 165 const rd_kafkap_bytes_t *userdata, 171 rd_kafkap_bytes_t * 178 rd_kafkap_bytes_t *
|
H A D | rdkafka_proto.h | 381 } rd_kafkap_bytes_t; typedef 407 static RD_UNUSED void rd_kafkap_bytes_destroy (rd_kafkap_bytes_t *kbytes) { in rd_kafkap_bytes_destroy() 424 rd_kafkap_bytes_t *rd_kafkap_bytes_new (const char *bytes, int32_t len) { in rd_kafkap_bytes_new() 425 rd_kafkap_bytes_t *kbytes; in rd_kafkap_bytes_new() 431 kbytes = (rd_kafkap_bytes_t *)rd_malloc(sizeof(*kbytes) + 4 + in rd_kafkap_bytes_new() 455 rd_kafkap_bytes_t *rd_kafkap_bytes_copy (const rd_kafkap_bytes_t *src) { in rd_kafkap_bytes_copy() 461 static RD_INLINE RD_UNUSED int rd_kafkap_bytes_cmp (const rd_kafkap_bytes_t *a, in rd_kafkap_bytes_cmp() 462 const rd_kafkap_bytes_t *b) { in rd_kafkap_bytes_cmp() 472 int rd_kafkap_bytes_cmp_data (const rd_kafkap_bytes_t *a, in rd_kafkap_bytes_cmp_data()
|
H A D | rdkafka_mock_int.h | 69 rd_kafkap_bytes_t *metadata; 82 rd_kafkap_bytes_t *assignment; /**< Current assignment */ 164 rd_kafkap_bytes_t bytes; 386 const rd_kafkap_bytes_t *bytes, 411 const rd_kafkap_bytes_t *Metadata);
|
H A D | rdkafka_assignor.c | 108 rd_kafkap_bytes_t * 115 rd_kafkap_bytes_t *kbytes; in rd_kafka_consumer_protocol_member_metadata_new() 173 rd_kafkap_bytes_t * 500 rd_kafkap_bytes_t *(*get_metadata_cb) ( in rd_kafka_assignor_add() 510 const rd_kafkap_bytes_t *userdata, in rd_kafka_assignor_add()
|
H A D | rdkafka_msgset_reader.c | 556 rd_kafkap_bytes_t Key; in rd_kafka_msgset_reader_msg_v0_1() 557 rd_kafkap_bytes_t Value; in rd_kafka_msgset_reader_msg_v0_1() 732 rd_kafkap_bytes_t Key; in rd_kafka_msgset_reader_msg_v2() 733 rd_kafkap_bytes_t Value; in rd_kafka_msgset_reader_msg_v2() 734 rd_kafkap_bytes_t Headers; in rd_kafka_msgset_reader_msg_v2()
|
H A D | rdkafka_cgrp.h | 327 const rd_kafkap_bytes_t *member_state);
|
H A D | rdkafka_buf.h | 1174 const rd_kafkap_bytes_t *kbytes) { 1195 const rd_kafkap_bytes_t *kbytes){
|
H A D | rdkafka_msg.h | 130 rd_kafkap_bytes_t binhdrs; /**< Unparsed
|
/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/src/ |
H A D | rdkafka_proto.h | 375 } rd_kafkap_bytes_t; typedef 401 static RD_UNUSED void rd_kafkap_bytes_destroy (rd_kafkap_bytes_t *kbytes) { in rd_kafkap_bytes_destroy() 418 rd_kafkap_bytes_t *rd_kafkap_bytes_new (const char *bytes, int32_t len) { in rd_kafkap_bytes_new() 419 rd_kafkap_bytes_t *kbytes; in rd_kafkap_bytes_new() 449 rd_kafkap_bytes_t *rd_kafkap_bytes_copy (const rd_kafkap_bytes_t *src) { in rd_kafkap_bytes_copy() 454 static RD_INLINE RD_UNUSED int rd_kafkap_bytes_cmp (const rd_kafkap_bytes_t *a, in rd_kafkap_bytes_cmp() 455 const rd_kafkap_bytes_t *b) { in rd_kafkap_bytes_cmp() 465 int rd_kafkap_bytes_cmp_data (const rd_kafkap_bytes_t *a, in rd_kafkap_bytes_cmp_data()
|
H A D | rdkafka_assignor.h | 39 rd_kafkap_bytes_t *rkgm_userdata; 40 rd_kafkap_bytes_t *rkgm_member_metadata; 87 rd_kafkap_bytes_t *(*rkas_get_metadata_cb) ( 100 rd_kafkap_bytes_t *
|
H A D | rdkafka_mock_int.h | 61 rd_kafkap_bytes_t *metadata; 74 rd_kafkap_bytes_t *assignment; /**< Current assignment */ 151 rd_kafkap_bytes_t bytes; 369 const rd_kafkap_bytes_t *bytes, 393 const rd_kafkap_bytes_t *Metadata);
|
H A D | rdkafka_assignor.c | 104 static rd_kafkap_bytes_t * 109 rd_kafkap_bytes_t *kbytes; in rd_kafka_consumer_protocol_member_metadata_new() 148 rd_kafkap_bytes_t *
|
H A D | rdkafka_cgrp.h | 300 const rd_kafkap_bytes_t *member_state);
|
H A D | rdkafka_msgset_reader.c | 552 rd_kafkap_bytes_t Key; in rd_kafka_msgset_reader_msg_v0_1() 553 rd_kafkap_bytes_t Value; in rd_kafka_msgset_reader_msg_v0_1() 725 rd_kafkap_bytes_t Key; in rd_kafka_msgset_reader_msg_v2() 726 rd_kafkap_bytes_t Value; in rd_kafka_msgset_reader_msg_v2() 727 rd_kafkap_bytes_t Headers; in rd_kafka_msgset_reader_msg_v2()
|
H A D | rdkafka_buf.h | 1080 const rd_kafkap_bytes_t *kbytes) { in rd_kafka_buf_write_kbytes() 1101 const rd_kafkap_bytes_t *kbytes){ in rd_kafka_buf_push_kbytes()
|
H A D | rdkafka_msg.h | 128 rd_kafkap_bytes_t binhdrs; /**< Unparsed
|
H A D | rdkafka_mock_handlers.c | 91 rd_kafkap_bytes_t records; in rd_kafka_mock_handle_Produce() 1134 rd_kafkap_bytes_t Metadata; in rd_kafka_mock_handle_JoinGroup() 1433 rd_kafkap_bytes_t Metadata; in rd_kafka_mock_handle_SyncGroup()
|