| /dports/net/py-confluent-kafka/confluent-kafka-1.2.0/confluent_kafka/src/ |
| H A D | confluent_kafka.c | 1266 if (!h->throttle_cb) { in throttle_cb()
1392 if (h->throttle_cb) { in Handle_clear()
1393 Py_DECREF(h->throttle_cb); in Handle_clear()
1394 h->throttle_cb = NULL; in Handle_clear()
1423 if (h->throttle_cb) in Handle_traverse()
1424 Py_VISIT(h->throttle_cb); in Handle_traverse()
1734 if (h->throttle_cb) { in common_conf_setup()
1735 Py_DECREF(h->throttle_cb); in common_conf_setup()
1736 h->throttle_cb = NULL; in common_conf_setup()
1739 h->throttle_cb = vo; in common_conf_setup()
[all …]
|
| H A D | confluent_kafka.h | 196 PyObject *throttle_cb; member
|
| /dports/net/py-confluent-kafka/confluent-kafka-1.2.0/tests/ |
| H A D | test_misc.py | 119 def throttle_cb(throttle_event): function
122 confluent_kafka.Producer({'throttle_cb': throttle_cb})
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/src/ |
| H A D | rdkafka_conf.h | 438 void (*throttle_cb) (rd_kafka_t *rk, const char *broker_name, member
|
| H A D | rdkafka_op.c | 644 if (!rkb->rkb_rk->rk_conf.throttle_cb || in rd_kafka_op_throttle_time()
|
| H A D | rdkafka_conf.c | 497 _RK(throttle_cb),
2530 void (*throttle_cb) ( in rd_kafka_conf_set_throttle_cb()
2537 throttle_cb); in rd_kafka_conf_set_throttle_cb()
|
| H A D | rdkafka.h | 1859 void (*throttle_cb) (
|
| H A D | rdkafka.c | 3615 if (rk->rk_conf.throttle_cb) in rd_kafka_poll_cb()
3616 rk->rk_conf.throttle_cb(rk, rko->rko_u.throttle.nodename, in rd_kafka_poll_cb()
|
| /dports/net/librdkafka/librdkafka-1.8.2/src/ |
| H A D | rdkafka_conf.h | 450 void (*throttle_cb) (rd_kafka_t *rk, const char *broker_name, member
|
| H A D | rdkafka_op.c | 789 if (!rkb->rkb_rk->rk_conf.throttle_cb || in rd_kafka_op_throttle_time()
|
| H A D | rdkafka_conf.c | 598 _RK(throttle_cb),
2767 void (*throttle_cb) ( in rd_kafka_conf_set_throttle_cb()
2774 throttle_cb); in rd_kafka_conf_set_throttle_cb()
|
| H A D | rdkafka.h | 2000 void (*throttle_cb) (
|
| H A D | rdkafka.c | 3821 if (rk->rk_conf.throttle_cb) in rd_kafka_poll_cb()
3822 rk->rk_conf.throttle_cb(rk, rko->rko_u.throttle.nodename, in rd_kafka_poll_cb()
|
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/src/ |
| H A D | rdkafka_conf.h | 449 void (*throttle_cb) (rd_kafka_t *rk, const char *broker_name,
|
| H A D | rdkafka_op.c | 789 if (!rkb->rkb_rk->rk_conf.throttle_cb || in rd_kafka_op_throttle_time()
|
| H A D | rdkafka_conf.c | 598 _RK(throttle_cb),
2765 void (*throttle_cb) ( in rd_kafka_conf_set_throttle_cb()
2772 throttle_cb); in rd_kafka_conf_set_throttle_cb()
|
| H A D | rdkafka.h | 2000 void (*throttle_cb) (
|
| H A D | rdkafka.c | 3820 if (rk->rk_conf.throttle_cb)
3821 rk->rk_conf.throttle_cb(rk, rko->rko_u.throttle.nodename,
|
| /dports/net/librdkafka/librdkafka-1.8.2/examples/ |
| H A D | rdkafka_performance.c | 144 static void throttle_cb (rd_kafka_t *rk, const char *broker_name, in throttle_cb() function
854 rd_kafka_conf_set_throttle_cb(conf, throttle_cb); in main()
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/examples/ |
| H A D | rdkafka_performance.c | 144 static void throttle_cb (rd_kafka_t *rk, const char *broker_name, in throttle_cb() function
830 rd_kafka_conf_set_throttle_cb(conf, throttle_cb); in main()
|
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/examples/ |
| H A D | rdkafka_performance.c | 144 static void throttle_cb (rd_kafka_t *rk, const char *broker_name, in throttle_cb() function
854 rd_kafka_conf_set_throttle_cb(conf, throttle_cb); in main()
|
| /dports/net/kcat/kcat-1.7.0/ |
| H A D | kcat.c | 668 static void throttle_cb (rd_kafka_t *rk, const char *broker_name, in throttle_cb() function
1717 rd_kafka_conf_set_throttle_cb(conf.rk_conf, throttle_cb); in try_conf_set()
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/src/ |
| H A D | bindings.rs | 670 throttle_cb: Option< in rd_kafka_conf_set_throttle_cb()
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/ |
| H A D | CONFIGURATION.md | 38 throttle_cb | * | | | low | Thr…
|
| /dports/net/librdkafka/librdkafka-1.8.2/ |
| H A D | CONFIGURATION.md | 39 throttle_cb | * | | | low | Thr…
|