/dports/net/librdkafka/librdkafka-1.8.2/tests/interceptor_test/ |
H A D | interceptor_test.c | 80 rd_kafka_resp_err_t on_send (rd_kafka_t *rk, in on_send() 89 rd_kafka_resp_err_t on_acknowledgement (rd_kafka_t *rk, in on_acknowledgement() 99 rd_kafka_resp_err_t on_consume (rd_kafka_t *rk, in on_consume() 108 rd_kafka_resp_err_t on_commit (rd_kafka_t *rk, in on_commit() 110 rd_kafka_resp_err_t err, void *ic_opaque) { in on_commit() 127 rd_kafka_resp_err_t on_destroy (rd_kafka_t *rk, void *ic_opaque) { in on_destroy() 138 static rd_kafka_resp_err_t on_new (rd_kafka_t *rk, const rd_kafka_conf_t *conf, in on_new() 234 static rd_kafka_resp_err_t on_conf_dup (rd_kafka_conf_t *new_conf, in on_conf_dup() 247 static rd_kafka_resp_err_t on_conf_destroy (void *ic_opaque) { in on_conf_destroy() 298 rd_kafka_resp_err_t conf_init (rd_kafka_conf_t *conf, in conf_init()
|
/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 | 80 rd_kafka_resp_err_t on_send (rd_kafka_t *rk, in on_send() 89 rd_kafka_resp_err_t on_acknowledgement (rd_kafka_t *rk, in on_acknowledgement() 99 rd_kafka_resp_err_t on_consume (rd_kafka_t *rk, in on_consume() 108 rd_kafka_resp_err_t on_commit (rd_kafka_t *rk, in on_commit() 110 rd_kafka_resp_err_t err, void *ic_opaque) { in on_commit() 127 rd_kafka_resp_err_t on_destroy (rd_kafka_t *rk, void *ic_opaque) { in on_destroy() 138 static rd_kafka_resp_err_t on_new (rd_kafka_t *rk, const rd_kafka_conf_t *conf, in on_new() 234 static rd_kafka_resp_err_t on_conf_dup (rd_kafka_conf_t *new_conf, in on_conf_dup() 247 static rd_kafka_resp_err_t on_conf_destroy (void *ic_opaque) { in on_conf_destroy() 298 rd_kafka_resp_err_t conf_init (rd_kafka_conf_t *conf, in conf_init()
|
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/tests/interceptor_test/ |
H A D | interceptor_test.c | 80 rd_kafka_resp_err_t on_send (rd_kafka_t *rk, 89 rd_kafka_resp_err_t on_acknowledgement (rd_kafka_t *rk, 99 rd_kafka_resp_err_t on_consume (rd_kafka_t *rk, 108 rd_kafka_resp_err_t on_commit (rd_kafka_t *rk, 110 rd_kafka_resp_err_t err, void *ic_opaque) { 127 rd_kafka_resp_err_t on_destroy (rd_kafka_t *rk, void *ic_opaque) { 138 static rd_kafka_resp_err_t on_new (rd_kafka_t *rk, const rd_kafka_conf_t *conf, 234 static rd_kafka_resp_err_t on_conf_dup (rd_kafka_conf_t *new_conf, 247 static rd_kafka_resp_err_t on_conf_destroy (void *ic_opaque) { 298 rd_kafka_resp_err_t conf_init (rd_kafka_conf_t *conf,
|
/dports/net/librdkafka/librdkafka-1.8.2/src/ |
H A D | rdkafka_assignor.h | 106 rd_kafka_resp_err_t (*rkas_assign_cb) ( 140 rd_kafka_resp_err_t 145 rd_kafka_resp_err_t (*assign_cb) ( 191 rd_kafka_resp_err_t 209 rd_kafka_resp_err_t rd_kafka_range_assignor_init (rd_kafka_t *rk); 210 rd_kafka_resp_err_t rd_kafka_roundrobin_assignor_init (rd_kafka_t *rk); 211 rd_kafka_resp_err_t rd_kafka_sticky_assignor_init (rd_kafka_t *rk);
|
H A D | rdkafka_error.c | 50 rd_kafka_error_t *rd_kafka_error_new_v (rd_kafka_resp_err_t code, in rd_kafka_error_new_v() 103 rd_kafka_error_t *rd_kafka_error_new (rd_kafka_resp_err_t code, in rd_kafka_error_new() 115 rd_kafka_error_t *rd_kafka_error_new_fatal (rd_kafka_resp_err_t code, in rd_kafka_error_new_fatal() 129 rd_kafka_error_t *rd_kafka_error_new_retriable (rd_kafka_resp_err_t code, in rd_kafka_error_new_retriable() 144 rd_kafka_resp_err_t code, const char *fmt, ...) { in rd_kafka_error_new_txn_requires_abort() 158 rd_kafka_resp_err_t rd_kafka_error_code (const rd_kafka_error_t *error) { in rd_kafka_error_code() 206 rd_kafka_resp_err_t 209 rd_kafka_resp_err_t err = error->code; in rd_kafka_error_to_legacy()
|
H A D | rdkafka_metadata.h | 34 rd_kafka_resp_err_t 56 rd_kafka_resp_err_t 62 rd_kafka_resp_err_t 65 rd_kafka_resp_err_t 69 rd_kafka_resp_err_t 72 rd_kafka_resp_err_t 76 rd_kafka_resp_err_t 161 rd_kafka_resp_err_t err,
|
H A D | rdkafka_offset.c | 259 static rd_kafka_resp_err_t 346 static rd_kafka_resp_err_t 386 rd_kafka_resp_err_t 390 rd_kafka_resp_err_t err; in rd_kafka_commit() 414 rd_kafka_resp_err_t 439 rd_kafka_resp_err_t 444 rd_kafka_resp_err_t err, in rd_kafka_commit_queue() 449 rd_kafka_resp_err_t err; in rd_kafka_commit_queue() 499 rd_kafka_resp_err_t err, in rd_kafka_offset_broker_commit_cb() 549 static rd_kafka_resp_err_t [all …]
|
H A D | rdkafka_partition.h | 59 rd_kafka_resp_err_t err; /**< Error code */ 461 rd_kafka_resp_err_t err, 478 rd_kafka_resp_err_t *errp); 512 rd_kafka_resp_err_t err); 540 rd_kafka_resp_err_t err); 545 rd_kafka_resp_err_t 548 rd_kafka_resp_err_t 676 rd_kafka_resp_err_t 738 rd_kafka_resp_err_t err); 740 rd_kafka_resp_err_t rd_kafka_topic_partition_list_get_err ( [all …]
|
H A D | rdkafka_cgrp.h | 170 rd_kafka_resp_err_t rkcg_last_heartbeat_err; /**< Last Heartbeat error, 257 rd_kafka_resp_err_t rkcg_last_err; /* Last error propagated to 317 rd_kafka_resp_err_t err); 322 rd_kafka_resp_err_t rd_kafka_cgrp_topic_pattern_del (rd_kafka_cgrp_t *rkcg, 324 rd_kafka_resp_err_t rd_kafka_cgrp_topic_pattern_add (rd_kafka_cgrp_t *rkcg, 336 void rd_kafka_cgrp_coord_dead (rd_kafka_cgrp_t *rkcg, rd_kafka_resp_err_t err,
|
H A D | rdkafka_mock_int.h | 42 rd_kafka_resp_err_t err; /**< Error response (or 0) */ 228 rd_kafka_resp_err_t err; /**< Error to return in protocol requests 356 rd_kafka_resp_err_t *errp); 380 rd_kafka_resp_err_t 384 rd_kafka_resp_err_t 412 rd_kafka_resp_err_t 417 rd_kafka_resp_err_t 422 rd_kafka_resp_err_t 431 rd_kafka_resp_err_t
|
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/src/ |
H A D | rdkafka_assignor.h | 106 rd_kafka_resp_err_t (*rkas_assign_cb) ( 140 rd_kafka_resp_err_t 145 rd_kafka_resp_err_t (*assign_cb) ( 191 rd_kafka_resp_err_t 209 rd_kafka_resp_err_t rd_kafka_range_assignor_init (rd_kafka_t *rk); 210 rd_kafka_resp_err_t rd_kafka_roundrobin_assignor_init (rd_kafka_t *rk); 211 rd_kafka_resp_err_t rd_kafka_sticky_assignor_init (rd_kafka_t *rk);
|
H A D | rdkafka_error.c | 50 rd_kafka_error_t *rd_kafka_error_new_v (rd_kafka_resp_err_t code, in rd_kafka_error_new_v() 103 rd_kafka_error_t *rd_kafka_error_new (rd_kafka_resp_err_t code, in rd_kafka_error_new() 115 rd_kafka_error_t *rd_kafka_error_new_fatal (rd_kafka_resp_err_t code, in rd_kafka_error_new_fatal() 129 rd_kafka_error_t *rd_kafka_error_new_retriable (rd_kafka_resp_err_t code, in rd_kafka_error_new_retriable() 144 rd_kafka_resp_err_t code, const char *fmt, ...) { in rd_kafka_error_new_txn_requires_abort() 158 rd_kafka_resp_err_t rd_kafka_error_code (const rd_kafka_error_t *error) { in rd_kafka_error_code() 206 rd_kafka_resp_err_t 209 rd_kafka_resp_err_t err = error->code; in rd_kafka_error_to_legacy()
|
H A D | rdkafka_metadata.h | 34 rd_kafka_resp_err_t 56 rd_kafka_resp_err_t 62 rd_kafka_resp_err_t 65 rd_kafka_resp_err_t 69 rd_kafka_resp_err_t 72 rd_kafka_resp_err_t 76 rd_kafka_resp_err_t 161 rd_kafka_resp_err_t err,
|
H A D | rdkafka_offset.c | 259 static rd_kafka_resp_err_t 346 static rd_kafka_resp_err_t in rd_kafka_broker_get_state() 386 rd_kafka_resp_err_t in rd_kafka_broker_supports() 390 rd_kafka_resp_err_t err; in rd_kafka_broker_supports() 414 rd_kafka_resp_err_t 439 rd_kafka_resp_err_t 444 rd_kafka_resp_err_t err, 449 rd_kafka_resp_err_t err; 499 rd_kafka_resp_err_t err, 549 static rd_kafka_resp_err_t in rd_kafka_broker_active_toppar_next() [all …]
|
H A D | rdkafka_cgrp.h | 170 rd_kafka_resp_err_t rkcg_last_heartbeat_err; /**< Last Heartbeat error, 250 rd_kafka_resp_err_t rkcg_last_err; /* Last error propagated to 310 rd_kafka_resp_err_t err); 315 rd_kafka_resp_err_t rd_kafka_cgrp_topic_pattern_del (rd_kafka_cgrp_t *rkcg, 317 rd_kafka_resp_err_t rd_kafka_cgrp_topic_pattern_add (rd_kafka_cgrp_t *rkcg, 326 rd_kafka_resp_err_t err, 333 void rd_kafka_cgrp_coord_dead (rd_kafka_cgrp_t *rkcg, rd_kafka_resp_err_t err,
|
H A D | rdkafka_partition.h | 59 rd_kafka_resp_err_t err; /**< Error code */ 461 rd_kafka_resp_err_t err, 478 rd_kafka_resp_err_t *errp); 512 rd_kafka_resp_err_t err); 540 rd_kafka_resp_err_t err); 545 rd_kafka_resp_err_t 548 rd_kafka_resp_err_t 676 rd_kafka_resp_err_t 738 rd_kafka_resp_err_t err); 740 rd_kafka_resp_err_t rd_kafka_topic_partition_list_get_err ( [all …]
|
/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/src/ |
H A D | rdkafka_cgrp.h | 175 rd_kafka_resp_err_t rkcg_last_heartbeat_err; /**< Last Heartbeat error, 221 rd_kafka_resp_err_t rkcg_last_err; /* Last error propagated to 283 rd_kafka_resp_err_t err); 288 rd_kafka_resp_err_t rd_kafka_cgrp_topic_pattern_del (rd_kafka_cgrp_t *rkcg, 290 rd_kafka_resp_err_t rd_kafka_cgrp_topic_pattern_add (rd_kafka_cgrp_t *rkcg, 299 rd_kafka_resp_err_t err, 305 void rd_kafka_cgrp_coord_dead (rd_kafka_cgrp_t *rkcg, rd_kafka_resp_err_t err,
|
H A D | rdkafka_offset.c | 261 static rd_kafka_resp_err_t 348 static rd_kafka_resp_err_t 388 rd_kafka_resp_err_t 392 rd_kafka_resp_err_t err; in rd_kafka_commit() 416 rd_kafka_resp_err_t 441 rd_kafka_resp_err_t 446 rd_kafka_resp_err_t err, in rd_kafka_commit_queue() 451 rd_kafka_resp_err_t err; in rd_kafka_commit_queue() 501 rd_kafka_resp_err_t err, in rd_kafka_offset_broker_commit_cb() 552 static rd_kafka_resp_err_t [all …]
|
H A D | rdkafka_partition.h | 59 rd_kafka_resp_err_t err; /**< Error code */ 455 rd_kafka_resp_err_t err, 472 rd_kafka_resp_err_t *errp); 498 rd_kafka_resp_err_t rd_kafka_toppar_op_seek (rd_kafka_toppar_t *rktp, 506 rd_kafka_resp_err_t err); 535 rd_kafka_resp_err_t err); 540 rd_kafka_resp_err_t 601 rd_kafka_resp_err_t 658 rd_kafka_resp_err_t err); 660 rd_kafka_resp_err_t rd_kafka_topic_partition_list_get_err ( [all …]
|
H A D | rdkafka_metadata.h | 34 rd_kafka_resp_err_t 54 rd_kafka_resp_err_t 58 rd_kafka_resp_err_t 61 rd_kafka_resp_err_t 64 rd_kafka_resp_err_t 68 rd_kafka_resp_err_t
|
H A D | rdkafka_mock_int.h | 48 rd_kafka_resp_err_t *errs; 215 rd_kafka_resp_err_t err; /**< Error to return in protocol requests 339 rd_kafka_resp_err_t *errp); 363 rd_kafka_resp_err_t 367 rd_kafka_resp_err_t 394 rd_kafka_resp_err_t 399 rd_kafka_resp_err_t 404 rd_kafka_resp_err_t 413 rd_kafka_resp_err_t
|
/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/tests/ |
H A D | test.h | 136 rd_kafka_resp_err_t produce_sync_err; /**< DR error */ 154 int (*is_fatal_cb) (rd_kafka_t *rk, rd_kafka_resp_err_t err, 341 rd_kafka_resp_err_t err, int msgnum); 447 rd_kafka_resp_err_t err, 540 rd_kafka_resp_err_t test_auto_create_topic_rkt (rd_kafka_t *rk, 590 rd_kafka_resp_err_t 596 rd_kafka_resp_err_t 602 rd_kafka_resp_err_t 609 rd_kafka_resp_err_t 615 rd_kafka_resp_err_t [all …]
|
H A D | 0106-cgrp_sess_timeout.c | 41 static rd_kafka_resp_err_t rebalance_exp_event; 42 static rd_kafka_resp_err_t commit_exp_err; 45 rd_kafka_resp_err_t err, in rebalance_cb() 61 rd_kafka_resp_err_t commit_err; in rebalance_cb() 64 rd_kafka_resp_err_t perr; in rebalance_cb() 105 rd_kafka_resp_err_t exp_event, in expect_rebalance()
|
/dports/net/librdkafka/librdkafka-1.8.2/tests/ |
H A D | 0106-cgrp_sess_timeout.c | 41 static rd_kafka_resp_err_t rebalance_exp_event; 42 static rd_kafka_resp_err_t commit_exp_err; 45 rd_kafka_resp_err_t err, in rebalance_cb() 61 rd_kafka_resp_err_t commit_err; in rebalance_cb() 64 rd_kafka_resp_err_t perr; in rebalance_cb() 110 rd_kafka_resp_err_t exp_event, in expect_rebalance() 233 rd_kafka_resp_err_t err; in do_test_commit_on_lost()
|
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/tests/ |
H A D | 0106-cgrp_sess_timeout.c | 41 static rd_kafka_resp_err_t rebalance_exp_event; 42 static rd_kafka_resp_err_t commit_exp_err; 45 rd_kafka_resp_err_t err, in rebalance_cb() 61 rd_kafka_resp_err_t commit_err; in rebalance_cb() 64 rd_kafka_resp_err_t perr; in rebalance_cb() 110 rd_kafka_resp_err_t exp_event, in expect_rebalance() 233 rd_kafka_resp_err_t err; in do_test_commit_on_lost()
|