Home
last modified time | relevance | path

Searched refs:rd_kafka_resp_err_t (Results 26 – 50 of 463) sorted by relevance

12345678910>>...19

/dports/net/librdkafka/librdkafka-1.8.2/tests/interceptor_test/
H A Dinterceptor_test.c80 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 Dinterceptor_test.c80 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 Dinterceptor_test.c80 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 Drdkafka_assignor.h106 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 Drdkafka_error.c50 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 Drdkafka_metadata.h34 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 Drdkafka_offset.c259 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 Drdkafka_partition.h59 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 Drdkafka_cgrp.h170 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 Drdkafka_mock_int.h42 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 Drdkafka_assignor.h106 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 Drdkafka_error.c50 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 Drdkafka_metadata.h34 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 Drdkafka_offset.c259 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 Drdkafka_cgrp.h170 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 Drdkafka_partition.h59 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 Drdkafka_cgrp.h175 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 Drdkafka_offset.c261 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 Drdkafka_partition.h59 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 Drdkafka_metadata.h34 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 Drdkafka_mock_int.h48 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 Dtest.h136 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 D0106-cgrp_sess_timeout.c41 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 D0106-cgrp_sess_timeout.c41 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 D0106-cgrp_sess_timeout.c41 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()

12345678910>>...19