Home
last modified time | relevance | path

Searched refs:rd_kafkap_bytes_t (Results 1 – 25 of 44) sorted by relevance

12

/dports/net/librdkafka/librdkafka-1.8.2/src/
H A Drdkafka_assignor.h69 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 Drdkafka_proto.h381 } 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 Drdkafka_mock_int.h69 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 Drdkafka_assignor.c108 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 Drdkafka_msgset_reader.c556 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 Drdkafka_buf.h1227 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 Drdkafka_msg.h130 rd_kafkap_bytes_t binhdrs; /**< Unparsed
H A Drdkafka_mock_handlers.c90 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 Drdkafka_assignor.h69 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 Drdkafka_proto.h381 } 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 Drdkafka_mock_int.h69 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 Drdkafka_assignor.c108 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 Drdkafka_msgset_reader.c556 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 Drdkafka_cgrp.h327 const rd_kafkap_bytes_t *member_state);
H A Drdkafka_buf.h1174 const rd_kafkap_bytes_t *kbytes) {
1195 const rd_kafkap_bytes_t *kbytes){
H A Drdkafka_msg.h130 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 Drdkafka_proto.h375 } 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 Drdkafka_assignor.h39 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 Drdkafka_mock_int.h61 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 Drdkafka_assignor.c104 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 Drdkafka_cgrp.h300 const rd_kafkap_bytes_t *member_state);
H A Drdkafka_msgset_reader.c552 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 Drdkafka_buf.h1080 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 Drdkafka_msg.h128 rd_kafkap_bytes_t binhdrs; /**< Unparsed
H A Drdkafka_mock_handlers.c91 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()

12