Home
last modified time | relevance | path

Searched refs:rd_kafka_toppar_t (Results 1 – 25 of 85) sorted by relevance

1234

/dports/net/librdkafka/librdkafka-1.8.2/src/
H A Drdkafka_partition.h455 int rd_kafka_toppar_retry_msgq (rd_kafka_toppar_t *rktp,
460 void rd_kafka_toppar_enq_error (rd_kafka_toppar_t *rktp,
469 rd_kafka_toppar_t *rd_kafka_toppar_get2 (rd_kafka_t *rk,
474 rd_kafka_toppar_t *
575 rd_kafka_toppar_t *_private);
649 rd_kafka_toppar_t *
654 rd_kafka_toppar_t *
754 rd_kafka_toppar_t *rktp;
765 const rd_kafka_toppar_t *rktp_a = a->rktp; in rd_kafka_toppar_ver_cmp()
766 const rd_kafka_toppar_t *rktp_b = b->rktp; in rd_kafka_toppar_ver_cmp()
[all …]
H A Drdkafka_offset.h46 void rd_kafka_offset_store0 (rd_kafka_toppar_t *rktp, int64_t offset, in rd_kafka_offset_store0()
58 rd_kafka_resp_err_t rd_kafka_offset_sync (rd_kafka_toppar_t *rktp);
60 void rd_kafka_offset_store_term (rd_kafka_toppar_t *rktp,
62 rd_kafka_resp_err_t rd_kafka_offset_store_stop (rd_kafka_toppar_t *rktp);
63 void rd_kafka_offset_store_init (rd_kafka_toppar_t *rktp);
65 void rd_kafka_offset_reset (rd_kafka_toppar_t *rktp, int64_t err_offset,
H A Drdkafka_offset.c260 rd_kafka_offset_file_commit (rd_kafka_toppar_t *rktp) { in rd_kafka_offset_file_commit()
349 rd_kafka_toppar_t *rktp, in rd_kafka_commit0()
502 rd_kafka_toppar_t *rktp; in rd_kafka_offset_broker_commit_cb()
650 rd_kafka_toppar_t *rktp; in rd_kafka_offset_store()
679 rd_kafka_toppar_t *rktp; in rd_kafka_offsets_store()
731 rd_kafka_toppar_t *rktp = rko->rko_rktp; in rd_kafka_offset_reset_op_cb()
884 rd_kafka_toppar_t *rktp = arg; in rd_kafka_offset_sync_tmr_cb()
993 void rd_kafka_offset_store_term (rd_kafka_toppar_t *rktp, in rd_kafka_offset_store_term()
1087 rd_kafka_toppar_t *rktp = arg; in rd_kafka_offset_auto_commit_tmr_cb()
1092 rd_kafka_toppar_t *rktp = arg; in rd_kafka_offset_query_tmr_cb()
[all …]
H A Drdkafka_partition.c185 rd_kafka_toppar_t *rktp = arg; in rd_kafka_toppar_consumer_lag_tmr_cb()
217 rd_kafka_toppar_t *rktp; in rd_kafka_toppar_new0()
473 rd_kafka_toppar_t *
477 rd_kafka_toppar_t *rktp; in rd_kafka_toppar_get_avail()
555 rd_kafka_toppar_t *rktp; in rd_kafka_toppar_desired_get()
2530 rd_kafka_toppar_t *rktp; in rd_kafka_toppars_pause_resume()
2651 const rd_kafka_toppar_t *rktp = (const rd_kafka_toppar_t *)rktpar; in rd_kafka_topic_partition_topic()
2657 const rd_kafka_toppar_t *rktp = (const rd_kafka_toppar_t *)rktpar; in rd_kafka_topic_partition_partition()
2663 const rd_kafka_toppar_t *rktp = (const rd_kafka_toppar_t *)rktpar; in rd_kafka_topic_partition_get()
3018 rd_kafka_toppar_t *
[all …]
H A Drdkafka_idempotence.h80 void rd_kafka_idemp_drain_toppar (rd_kafka_toppar_t *rktp, const char *reason);
82 rd_kafka_toppar_t *rktp);
84 rd_kafka_toppar_t *rktp);
H A Drdkafka_txnmgr.h74 rd_kafka_txn_toppar_may_send_msg (rd_kafka_toppar_t *rktp) { in rd_kafka_txn_toppar_may_send_msg()
99 void rd_kafka_txn_add_partition (rd_kafka_toppar_t *rktp) { in rd_kafka_txn_add_partition()
124 rd_kafka_toppar_t *, rktp_txnlink, in rd_kafka_txn_add_partition()
H A Drdkafka_topic.h103 rd_kafka_toppar_t *rkt_ua; /**< Unassigned partition (-1) */
104 rd_kafka_toppar_t **rkt_p; /**< Partition array */
247 int rd_kafka_toppar_broker_update (rd_kafka_toppar_t *rktp,
251 int rd_kafka_toppar_delegate_to_leader (rd_kafka_toppar_t *rktp);
H A Drdkafka_msgbatch.h31 rd_kafka_toppar_t *rktp; /**< Reference to partition */
55 rd_kafka_toppar_t *rktp,
H A Drdkafka_msgset.h68 rd_kafka_toppar_t *rktp,
80 rd_kafka_toppar_t *rktp,
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/src/
H A Drdkafka_partition.h455 int rd_kafka_toppar_retry_msgq (rd_kafka_toppar_t *rktp,
460 void rd_kafka_toppar_enq_error (rd_kafka_toppar_t *rktp,
469 rd_kafka_toppar_t *rd_kafka_toppar_get2 (rd_kafka_t *rk,
474 rd_kafka_toppar_t *
575 rd_kafka_toppar_t *_private);
649 rd_kafka_toppar_t *
654 rd_kafka_toppar_t *
754 rd_kafka_toppar_t *rktp;
765 const rd_kafka_toppar_t *rktp_a = a->rktp; in rd_kafka_toppar_ver_cmp()
766 const rd_kafka_toppar_t *rktp_b = b->rktp; in rd_kafka_toppar_ver_cmp()
[all …]
H A Drdkafka_offset.h46 void rd_kafka_offset_store0 (rd_kafka_toppar_t *rktp, int64_t offset, in rd_kafka_offset_store0()
58 rd_kafka_resp_err_t rd_kafka_offset_sync (rd_kafka_toppar_t *rktp);
60 void rd_kafka_offset_store_term (rd_kafka_toppar_t *rktp,
62 rd_kafka_resp_err_t rd_kafka_offset_store_stop (rd_kafka_toppar_t *rktp);
63 void rd_kafka_offset_store_init (rd_kafka_toppar_t *rktp);
65 void rd_kafka_offset_reset (rd_kafka_toppar_t *rktp, int64_t err_offset,
H A Drdkafka_offset.c260 rd_kafka_offset_file_commit (rd_kafka_toppar_t *rktp) {
349 rd_kafka_toppar_t *rktp, in rd_kafka_broker_get_state()
502 rd_kafka_toppar_t *rktp;
650 rd_kafka_toppar_t *rktp;
679 rd_kafka_toppar_t *rktp;
731 rd_kafka_toppar_t *rktp = rko->rko_rktp;
869 rd_kafka_toppar_t *rktp = arg;
977 void rd_kafka_offset_store_term (rd_kafka_toppar_t *rktp,
1071 rd_kafka_toppar_t *rktp = arg;
1076 rd_kafka_toppar_t *rktp = arg;
[all …]
H A Drdkafka_partition.c185 rd_kafka_toppar_t *rktp = arg; in rd_kafka_toppar_consumer_lag_tmr_cb()
217 rd_kafka_toppar_t *rktp; in rd_kafka_toppar_new0()
473 rd_kafka_toppar_t *
477 rd_kafka_toppar_t *rktp; in rd_kafka_toppar_get_avail()
555 rd_kafka_toppar_t *rktp; in rd_kafka_toppar_desired_get()
2515 rd_kafka_toppar_t *rktp; in rd_kafka_toppars_pause_resume()
2636 const rd_kafka_toppar_t *rktp = (const rd_kafka_toppar_t *)rktpar; in rd_kafka_topic_partition_topic()
2642 const rd_kafka_toppar_t *rktp = (const rd_kafka_toppar_t *)rktpar; in rd_kafka_topic_partition_partition()
2648 const rd_kafka_toppar_t *rktp = (const rd_kafka_toppar_t *)rktpar; in rd_kafka_topic_partition_get()
3003 rd_kafka_toppar_t *
[all …]
H A Drdkafka_idempotence.h79 void rd_kafka_idemp_drain_toppar (rd_kafka_toppar_t *rktp, const char *reason);
81 rd_kafka_toppar_t *rktp);
83 rd_kafka_toppar_t *rktp);
H A Drdkafka_txnmgr.h74 rd_kafka_txn_toppar_may_send_msg (rd_kafka_toppar_t *rktp) { in rd_kafka_txn_toppar_may_send_msg()
99 void rd_kafka_txn_add_partition (rd_kafka_toppar_t *rktp) { in rd_kafka_txn_add_partition()
124 rd_kafka_toppar_t *, rktp_txnlink, in rd_kafka_txn_add_partition()
H A Drdkafka_topic.h103 rd_kafka_toppar_t *rkt_ua; /**< Unassigned partition (-1) */
104 rd_kafka_toppar_t **rkt_p; /**< Partition array */
247 int rd_kafka_toppar_broker_update (rd_kafka_toppar_t *rktp,
251 int rd_kafka_toppar_delegate_to_leader (rd_kafka_toppar_t *rktp);
H A Drdkafka_msgbatch.h31 rd_kafka_toppar_t *rktp; /**< Reference to partition */
55 rd_kafka_toppar_t *rktp,
H A Drdkafka_msgset.h68 rd_kafka_toppar_t *rktp,
80 rd_kafka_toppar_t *rktp,
/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/src/
H A Drdkafka_partition.h435 void rd_kafka_toppar_destroy_final (rd_kafka_toppar_t *rktp);
436 void rd_kafka_toppar_purge_queues (rd_kafka_toppar_t *rktp);
449 int rd_kafka_toppar_retry_msgq (rd_kafka_toppar_t *rktp,
452 void rd_kafka_toppar_insert_msgq (rd_kafka_toppar_t *rktp,
454 void rd_kafka_toppar_enq_error (rd_kafka_toppar_t *rktp,
476 void rd_kafka_toppar_desired_add0 (rd_kafka_toppar_t *rktp);
479 void rd_kafka_toppar_desired_link (rd_kafka_toppar_t *rktp);
481 void rd_kafka_toppar_desired_del (rd_kafka_toppar_t *rktp);
505 void rd_kafka_toppar_fetch_stopped (rd_kafka_toppar_t *rktp,
520 void rd_kafka_toppar_offset_fetch (rd_kafka_toppar_t *rktp,
[all …]
H A Drdkafka_offset.h46 void rd_kafka_offset_store0 (rd_kafka_toppar_t *rktp, int64_t offset, in rd_kafka_offset_store0()
58 rd_kafka_resp_err_t rd_kafka_offset_sync (rd_kafka_toppar_t *rktp);
60 void rd_kafka_offset_store_term (rd_kafka_toppar_t *rktp,
62 rd_kafka_resp_err_t rd_kafka_offset_store_stop (rd_kafka_toppar_t *rktp);
63 void rd_kafka_offset_store_init (rd_kafka_toppar_t *rktp);
65 void rd_kafka_offset_reset (rd_kafka_toppar_t *rktp, int64_t err_offset,
H A Drdkafka_offset.c146 static int rd_kafka_offset_file_open (rd_kafka_toppar_t *rktp) { in rd_kafka_offset_file_open()
236 static int rd_kafka_offset_file_sync (rd_kafka_toppar_t *rktp) { in rd_kafka_offset_file_sync()
262 rd_kafka_offset_file_commit (rd_kafka_toppar_t *rktp) { in rd_kafka_offset_file_commit()
351 rd_kafka_toppar_t *rktp, in rd_kafka_commit0()
505 rd_kafka_toppar_t *rktp; in rd_kafka_offset_broker_commit_cb()
735 rd_kafka_toppar_t *rktp = in rd_kafka_offset_reset_op_cb()
882 rd_kafka_toppar_t *rktp = arg; in rd_kafka_offset_sync_tmr_cb()
990 void rd_kafka_offset_store_term (rd_kafka_toppar_t *rktp, in rd_kafka_offset_store_term()
1084 rd_kafka_toppar_t *rktp = arg; in rd_kafka_offset_auto_commit_tmr_cb()
1089 rd_kafka_toppar_t *rktp = arg; in rd_kafka_offset_query_tmr_cb()
[all …]
H A Drdkafka_partition.c184 rd_kafka_toppar_t *rktp = arg; in rd_kafka_toppar_consumer_lag_tmr_cb()
198 rd_kafka_toppar_t *rktp; in rd_kafka_toppar_new0()
605 rd_kafka_toppar_t *rktp; in rd_kafka_toppar_desired_add()
1730 void rd_kafka_toppar_seek (rd_kafka_toppar_t *rktp, in rd_kafka_toppar_seek()
2095 rd_kafka_toppar_t *rktp = NULL; in rd_kafka_toppar_op_serve()
2475 rd_kafka_toppar_t *rktp; in rd_kafka_toppars_pause_resume()
2597 const rd_kafka_toppar_t *rktp = (const rd_kafka_toppar_t *)rktpar; in rd_kafka_topic_partition_topic()
2603 const rd_kafka_toppar_t *rktp = (const rd_kafka_toppar_t *)rktpar; in rd_kafka_topic_partition_partition()
2609 const rd_kafka_toppar_t *rktp = (const rd_kafka_toppar_t *)rktpar; in rd_kafka_topic_partition_get()
3373 rd_kafka_toppar_t *rktp; in rd_kafka_topic_partition_list_get_topics()
[all …]
H A Drdkafka_idempotence.h78 void rd_kafka_idemp_drain_toppar (rd_kafka_toppar_t *rktp, const char *reason);
80 rd_kafka_toppar_t *rktp);
82 rd_kafka_toppar_t *rktp);
H A Drdkafka_txnmgr.h74 rd_kafka_txn_toppar_may_send_msg (rd_kafka_toppar_t *rktp) { in rd_kafka_txn_toppar_may_send_msg()
99 void rd_kafka_txn_add_partition (rd_kafka_toppar_t *rktp) { in rd_kafka_txn_add_partition()
124 rd_kafka_toppar_t *, rktp_txnlink, in rd_kafka_txn_add_partition()
H A Drdkafka_msgset.h68 rd_kafka_toppar_t *rktp,
79 rd_kafka_toppar_t *rktp,

1234