/dports/net/librdkafka/librdkafka-1.8.2/src/ |
H A D | rdkafka_partition.h | 455 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 D | rdkafka_offset.h | 46 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 D | rdkafka_offset.c | 260 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 D | rdkafka_partition.c | 185 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 D | rdkafka_idempotence.h | 80 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 D | rdkafka_txnmgr.h | 74 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 D | rdkafka_topic.h | 103 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 D | rdkafka_msgbatch.h | 31 rd_kafka_toppar_t *rktp; /**< Reference to partition */ 55 rd_kafka_toppar_t *rktp,
|
H A D | rdkafka_msgset.h | 68 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 D | rdkafka_partition.h | 455 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 D | rdkafka_offset.h | 46 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 D | rdkafka_offset.c | 260 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 D | rdkafka_partition.c | 185 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 D | rdkafka_idempotence.h | 79 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 D | rdkafka_txnmgr.h | 74 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 D | rdkafka_topic.h | 103 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 D | rdkafka_msgbatch.h | 31 rd_kafka_toppar_t *rktp; /**< Reference to partition */ 55 rd_kafka_toppar_t *rktp,
|
H A D | rdkafka_msgset.h | 68 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 D | rdkafka_partition.h | 435 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 D | rdkafka_offset.h | 46 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 D | rdkafka_offset.c | 146 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 D | rdkafka_partition.c | 184 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 D | rdkafka_idempotence.h | 78 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 D | rdkafka_txnmgr.h | 74 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 D | rdkafka_msgset.h | 68 rd_kafka_toppar_t *rktp, 79 rd_kafka_toppar_t *rktp,
|