Home
last modified time | relevance | path

Searched refs:rd_kafka_resp_err_t (Results 1 – 25 of 463) sorted by relevance

12345678910>>...19

/dports/net/librdkafka/librdkafka-1.8.2/src/
H A Drdkafka_request.h74 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 Drdkafka_mock.h186 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 Drdkafka.h618 } 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 Drdkafka_interceptor.c664 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 Drdkafka_error.h41 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 Drdkafka_subscription.c39 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 Drdkafka_offset.h55 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 Drdkafka_request.h72 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 Drdkafka_mock.h182 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 Drdkafka.h618 } 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 Drdkafka_interceptor.c664 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 Drdkafka_error.h41 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 Drdkafka_subscription.c39 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 Drdkafka_offset.h55 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 Drdkafka.h568 } 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 Drdkafka_request.h68 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 Drdkafka_mock.h147 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 Drdkafka_error.h39 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 Drdkafka_interceptor.c618 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 Drdkafka_subscription.c39 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 Drdkafka_error.c49 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 Drdkafka_offset.h55 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 Dbindings.rs113 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 Dtest.h461 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 Dtest.h138 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 …]

12345678910>>...19