/dports/net/librdkafka/librdkafka-1.8.2/src/ |
H A D | rdkafka_request.h | 74 rd_kafka_resp_err_t 97 rd_kafka_resp_err_t 124 rd_kafka_resp_err_t 138 rd_kafka_resp_err_t 212 rd_kafka_resp_err_t 219 rd_kafka_resp_err_t 256 rd_kafka_resp_err_t 265 rd_kafka_resp_err_t 274 rd_kafka_resp_err_t 283 rd_kafka_resp_err_t [all …]
|
H A D | rdkafka_mock.h | 186 RD_EXPORT rd_kafka_resp_err_t 212 RD_EXPORT rd_kafka_resp_err_t 226 RD_EXPORT rd_kafka_resp_err_t 238 RD_EXPORT rd_kafka_resp_err_t 252 RD_EXPORT rd_kafka_resp_err_t 263 RD_EXPORT rd_kafka_resp_err_t 271 RD_EXPORT rd_kafka_resp_err_t 279 RD_EXPORT rd_kafka_resp_err_t 286 RD_EXPORT rd_kafka_resp_err_t 300 RD_EXPORT rd_kafka_resp_err_t [all …]
|
H A D | rdkafka.h | 618 } rd_kafka_resp_err_t; typedef 785 RD_EXPORT rd_kafka_resp_err_t 4610 rd_kafka_resp_err_t 4707 rd_kafka_resp_err_t 5361 typedef rd_kafka_resp_err_t 5468 typedef rd_kafka_resp_err_t 5482 typedef rd_kafka_resp_err_t 5503 typedef rd_kafka_resp_err_t 5516 typedef rd_kafka_resp_err_t 7307 rd_kafka_resp_err_t [all …]
|
H A D | rdkafka_interceptor.c | 664 rd_kafka_resp_err_t 674 rd_kafka_resp_err_t 684 rd_kafka_resp_err_t 696 rd_kafka_resp_err_t 707 rd_kafka_resp_err_t 718 rd_kafka_resp_err_t 729 rd_kafka_resp_err_t 743 rd_kafka_resp_err_t 756 rd_kafka_resp_err_t 769 rd_kafka_resp_err_t [all …]
|
H A D | rdkafka_error.h | 41 rd_kafka_resp_err_t code; /**< Error code. */ 52 rd_kafka_error_t *rd_kafka_error_new_v (rd_kafka_resp_err_t code, 62 rd_kafka_error_t *rd_kafka_error_new_fatal (rd_kafka_resp_err_t code, 65 rd_kafka_error_t *rd_kafka_error_new_retriable (rd_kafka_resp_err_t code, 69 rd_kafka_error_new_txn_requires_abort (rd_kafka_resp_err_t code, 74 rd_kafka_resp_err_t rd_kafka_error_to_legacy (rd_kafka_error_t *error,
|
H A D | rdkafka_subscription.c | 39 rd_kafka_resp_err_t rd_kafka_unsubscribe (rd_kafka_t *rk) { in rd_kafka_unsubscribe() 71 rd_kafka_resp_err_t 128 rd_kafka_resp_err_t 132 rd_kafka_resp_err_t err; in rd_kafka_assign() 212 rd_kafka_resp_err_t 216 rd_kafka_resp_err_t err; in rd_kafka_assignment() 240 rd_kafka_resp_err_t 244 rd_kafka_resp_err_t err; in rd_kafka_subscription() 269 rd_kafka_resp_err_t 280 rd_kafka_resp_err_t
|
H A D | rdkafka_offset.h | 55 rd_kafka_resp_err_t rd_kafka_offset_store (rd_kafka_topic_t *rkt, 58 rd_kafka_resp_err_t rd_kafka_offset_sync (rd_kafka_toppar_t *rktp); 61 rd_kafka_resp_err_t err); 62 rd_kafka_resp_err_t rd_kafka_offset_store_stop (rd_kafka_toppar_t *rktp); 66 rd_kafka_resp_err_t err, const char *reason);
|
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/src/ |
H A D | rdkafka_request.h | 72 rd_kafka_resp_err_t 95 rd_kafka_resp_err_t 122 rd_kafka_resp_err_t 136 rd_kafka_resp_err_t 210 rd_kafka_resp_err_t 217 rd_kafka_resp_err_t 254 rd_kafka_resp_err_t 263 rd_kafka_resp_err_t 272 rd_kafka_resp_err_t 281 rd_kafka_resp_err_t [all …]
|
H A D | rdkafka_mock.h | 182 RD_EXPORT rd_kafka_resp_err_t 208 RD_EXPORT rd_kafka_resp_err_t 222 RD_EXPORT rd_kafka_resp_err_t 234 RD_EXPORT rd_kafka_resp_err_t 248 RD_EXPORT rd_kafka_resp_err_t 259 RD_EXPORT rd_kafka_resp_err_t 267 RD_EXPORT rd_kafka_resp_err_t 275 RD_EXPORT rd_kafka_resp_err_t 282 RD_EXPORT rd_kafka_resp_err_t 296 RD_EXPORT rd_kafka_resp_err_t [all …]
|
H A D | rdkafka.h | 618 } rd_kafka_resp_err_t; typedef 785 RD_EXPORT rd_kafka_resp_err_t 4604 rd_kafka_resp_err_t 4701 rd_kafka_resp_err_t 5355 typedef rd_kafka_resp_err_t 5462 typedef rd_kafka_resp_err_t 5476 typedef rd_kafka_resp_err_t 5497 typedef rd_kafka_resp_err_t 5510 typedef rd_kafka_resp_err_t 7301 rd_kafka_resp_err_t [all …]
|
H A D | rdkafka_interceptor.c | 664 rd_kafka_resp_err_t 674 rd_kafka_resp_err_t 684 rd_kafka_resp_err_t 696 rd_kafka_resp_err_t 707 rd_kafka_resp_err_t 718 rd_kafka_resp_err_t 729 rd_kafka_resp_err_t 743 rd_kafka_resp_err_t 756 rd_kafka_resp_err_t 769 rd_kafka_resp_err_t [all …]
|
H A D | rdkafka_error.h | 41 rd_kafka_resp_err_t code; /**< Error code. */ 52 rd_kafka_error_t *rd_kafka_error_new_v (rd_kafka_resp_err_t code, 62 rd_kafka_error_t *rd_kafka_error_new_fatal (rd_kafka_resp_err_t code, 65 rd_kafka_error_t *rd_kafka_error_new_retriable (rd_kafka_resp_err_t code, 69 rd_kafka_error_new_txn_requires_abort (rd_kafka_resp_err_t code, 74 rd_kafka_resp_err_t rd_kafka_error_to_legacy (rd_kafka_error_t *error,
|
H A D | rdkafka_subscription.c | 39 rd_kafka_resp_err_t rd_kafka_unsubscribe (rd_kafka_t *rk) { in rd_kafka_unsubscribe() 71 rd_kafka_resp_err_t 128 rd_kafka_resp_err_t 132 rd_kafka_resp_err_t err; in rd_kafka_assign() 212 rd_kafka_resp_err_t 216 rd_kafka_resp_err_t err; in rd_kafka_assignment() 240 rd_kafka_resp_err_t 244 rd_kafka_resp_err_t err; in rd_kafka_subscription() 269 rd_kafka_resp_err_t 280 rd_kafka_resp_err_t
|
H A D | rdkafka_offset.h | 55 rd_kafka_resp_err_t rd_kafka_offset_store (rd_kafka_topic_t *rkt, 58 rd_kafka_resp_err_t rd_kafka_offset_sync (rd_kafka_toppar_t *rktp); 61 rd_kafka_resp_err_t err); 62 rd_kafka_resp_err_t rd_kafka_offset_store_stop (rd_kafka_toppar_t *rktp); 66 rd_kafka_resp_err_t err, const char *reason);
|
/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/src/ |
H A D | rdkafka.h | 568 } rd_kafka_resp_err_t; typedef 735 RD_EXPORT rd_kafka_resp_err_t 4179 rd_kafka_resp_err_t 4276 rd_kafka_resp_err_t 4866 typedef rd_kafka_resp_err_t 4973 typedef rd_kafka_resp_err_t 4987 typedef rd_kafka_resp_err_t 5008 typedef rd_kafka_resp_err_t 5021 typedef rd_kafka_resp_err_t 6460 rd_kafka_resp_err_t [all …]
|
H A D | rdkafka_request.h | 68 rd_kafka_resp_err_t 91 rd_kafka_resp_err_t 116 rd_kafka_resp_err_t 196 rd_kafka_resp_err_t 201 rd_kafka_resp_err_t 237 rd_kafka_resp_err_t 246 rd_kafka_resp_err_t 255 rd_kafka_resp_err_t 264 rd_kafka_resp_err_t 273 rd_kafka_resp_err_t [all …]
|
H A D | rdkafka_mock.h | 147 rd_kafka_resp_err_t err); 159 RD_EXPORT rd_kafka_resp_err_t 172 RD_EXPORT rd_kafka_resp_err_t 184 RD_EXPORT rd_kafka_resp_err_t 198 RD_EXPORT rd_kafka_resp_err_t 209 RD_EXPORT rd_kafka_resp_err_t 217 RD_EXPORT rd_kafka_resp_err_t 226 RD_EXPORT rd_kafka_resp_err_t 240 RD_EXPORT rd_kafka_resp_err_t 260 RD_EXPORT rd_kafka_resp_err_t
|
H A D | rdkafka_error.h | 39 rd_kafka_resp_err_t code; /**< Error code. */ 50 rd_kafka_error_t *rd_kafka_error_new_v (rd_kafka_resp_err_t code, 58 rd_kafka_error_t *rd_kafka_error_new_fatal (rd_kafka_resp_err_t code, 60 rd_kafka_error_t *rd_kafka_error_new_retriable (rd_kafka_resp_err_t code, 62 rd_kafka_error_t *rd_kafka_error_new_txn_requires_abort (rd_kafka_resp_err_t code, 66 rd_kafka_resp_err_t rd_kafka_error_to_legacy (rd_kafka_error_t *error,
|
H A D | rdkafka_interceptor.c | 618 rd_kafka_resp_err_t 628 rd_kafka_resp_err_t 638 rd_kafka_resp_err_t 650 rd_kafka_resp_err_t 661 rd_kafka_resp_err_t 672 rd_kafka_resp_err_t 683 rd_kafka_resp_err_t 697 rd_kafka_resp_err_t 710 rd_kafka_resp_err_t 723 rd_kafka_resp_err_t [all …]
|
H A D | rdkafka_subscription.c | 39 rd_kafka_resp_err_t rd_kafka_unsubscribe (rd_kafka_t *rk) { in rd_kafka_unsubscribe() 71 rd_kafka_resp_err_t 95 rd_kafka_resp_err_t 115 rd_kafka_resp_err_t 119 rd_kafka_resp_err_t err; in rd_kafka_assignment() 143 rd_kafka_resp_err_t 147 rd_kafka_resp_err_t err; in rd_kafka_subscription() 172 rd_kafka_resp_err_t 183 rd_kafka_resp_err_t
|
H A D | rdkafka_error.c | 49 rd_kafka_error_t *rd_kafka_error_new_v (rd_kafka_resp_err_t code, in rd_kafka_error_new_v() 77 rd_kafka_error_t *rd_kafka_error_new (rd_kafka_resp_err_t code, in rd_kafka_error_new() 89 rd_kafka_error_t *rd_kafka_error_new_fatal (rd_kafka_resp_err_t code, in rd_kafka_error_new_fatal() 103 rd_kafka_error_t *rd_kafka_error_new_retriable (rd_kafka_resp_err_t code, in rd_kafka_error_new_retriable() 117 rd_kafka_error_t *rd_kafka_error_new_txn_requires_abort (rd_kafka_resp_err_t code, in rd_kafka_error_new_txn_requires_abort() 132 rd_kafka_resp_err_t rd_kafka_error_code (const rd_kafka_error_t *error) { in rd_kafka_error_code() 178 rd_kafka_resp_err_t 181 rd_kafka_resp_err_t err = error->code; in rd_kafka_error_to_legacy()
|
H A D | rdkafka_offset.h | 55 rd_kafka_resp_err_t rd_kafka_offset_store (rd_kafka_topic_t *rkt, 58 rd_kafka_resp_err_t rd_kafka_offset_sync (rd_kafka_toppar_t *rktp); 61 rd_kafka_resp_err_t err); 62 rd_kafka_resp_err_t rd_kafka_offset_store_stop (rd_kafka_toppar_t *rktp); 66 rd_kafka_resp_err_t err, const char *reason);
|
/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/src/ |
H A D | bindings.rs | 113 pub enum rd_kafka_resp_err_t { enum 289 ) -> rd_kafka_resp_err_t; in rd_kafka_fatal_error() argument 296 ) -> rd_kafka_resp_err_t; in rd_kafka_test_fatal_error() argument 394 ) -> rd_kafka_resp_err_t; in rd_kafka_topic_partition_list_set_offset() argument 453 ) -> rd_kafka_resp_err_t; in rd_kafka_header_add() argument 459 ) -> rd_kafka_resp_err_t; in rd_kafka_header_remove() argument 467 ) -> rd_kafka_resp_err_t; in rd_kafka_header_get_last() argument 476 ) -> rd_kafka_resp_err_t; in rd_kafka_header_get() argument 485 ) -> rd_kafka_resp_err_t; in rd_kafka_header_get_all() argument 516 ) -> rd_kafka_resp_err_t; in rd_kafka_message_headers() argument [all …]
|
/dports/net/librdkafka/librdkafka-1.8.2/tests/ |
H A D | test.h | 461 rd_kafka_resp_err_t err, 465 rd_kafka_resp_err_t err, 472 rd_kafka_resp_err_t err, 637 rd_kafka_resp_err_t 643 rd_kafka_resp_err_t 649 rd_kafka_resp_err_t 656 rd_kafka_resp_err_t 662 rd_kafka_resp_err_t 668 rd_kafka_resp_err_t 674 rd_kafka_resp_err_t [all …]
|
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/tests/ |
H A D | test.h | 138 rd_kafka_resp_err_t produce_sync_err; /**< DR error */ 461 rd_kafka_resp_err_t err, 468 rd_kafka_resp_err_t err, 633 rd_kafka_resp_err_t 639 rd_kafka_resp_err_t 645 rd_kafka_resp_err_t 652 rd_kafka_resp_err_t 658 rd_kafka_resp_err_t 664 rd_kafka_resp_err_t 670 rd_kafka_resp_err_t [all …]
|