/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/src/ |
H A D | rdkafka_idempotence.c | 62 if (rk->rk_eos.idemp_state == new_state) in rd_kafka_idemp_set_state() 74 idemp_state), in rd_kafka_idemp_set_state() 83 idemp_state), in rd_kafka_idemp_set_state() 86 rk->rk_eos.idemp_state = new_state; in rd_kafka_idemp_set_state() 201 switch (rk->rk_eos.idemp_state) in rd_kafka_idemp_pid_fsm() 413 if (rk->rk_eos.idemp_state != RD_KAFKA_IDEMP_STATE_WAIT_PID) { in rd_kafka_idemp_pid_update() 418 rd_kafka_idemp_state2str(rk->rk_eos.idemp_state)); in rd_kafka_idemp_pid_update() 468 if (rk->rk_eos.idemp_state == RD_KAFKA_IDEMP_STATE_DRAIN_RESET) { in rd_kafka_idemp_drain_done() 473 } else if (rk->rk_eos.idemp_state == RD_KAFKA_IDEMP_STATE_DRAIN_BUMP && in rd_kafka_idemp_drain_done()
|
H A D | rdkafka_txnmgr.c | 414 rd_kafka_idemp_state_t idemp_state) { in rd_kafka_txn_idemp_state_change() argument 416 if (idemp_state == RD_KAFKA_IDEMP_STATE_ASSIGNED && in rd_kafka_txn_idemp_state_change() 430 } else if (idemp_state == RD_KAFKA_IDEMP_STATE_FATAL_ERROR && in rd_kafka_txn_idemp_state_change() 772 rd_kafka_idemp_state2str(rk->rk_eos.idemp_state)); in rd_kafka_txn_register_partitions() 1773 rd_kafka_idemp_state2str(rk->rk_eos.idemp_state)); in rd_kafka_txn_op_send_offsets_to_transaction() 2019 rd_kafka_idemp_state2str(rk->rk_eos.idemp_state)); in rd_kafka_txn_op_commit_transaction() 2231 rd_kafka_idemp_state2str(rk->rk_eos.idemp_state)); in rd_kafka_txn_op_abort_transaction() 2651 if (rk->rk_eos.idemp_state < RD_KAFKA_IDEMP_STATE_ASSIGNED) { in rd_kafka_txn_coord_monitor_cb() 2655 } else if (rk->rk_eos.idemp_state == in rd_kafka_txn_coord_monitor_cb()
|
H A D | rdkafka_idempotence.h | 57 if (likely(rk->rk_eos.idemp_state == RD_KAFKA_IDEMP_STATE_ASSIGNED)) in rd_kafka_idemp_get_pid0()
|
H A D | rdkafka_int.h | 358 rd_kafka_idemp_state_t idemp_state; /**< Idempotent Producer member
|
H A D | rdkafka.c | 1746 rd_kafka_idemp_state2str(rk->rk_eos.idemp_state), in rd_kafka_stats_emit_all()
|
/dports/net/librdkafka/librdkafka-1.8.2/src/ |
H A D | rdkafka_idempotence.c | 62 if (rk->rk_eos.idemp_state == new_state) in rd_kafka_idemp_set_state() 74 idemp_state), in rd_kafka_idemp_set_state() 83 idemp_state), in rd_kafka_idemp_set_state() 86 rk->rk_eos.idemp_state = new_state; in rd_kafka_idemp_set_state() 217 switch (rk->rk_eos.idemp_state) in rd_kafka_idemp_pid_fsm() 467 if (rk->rk_eos.idemp_state != RD_KAFKA_IDEMP_STATE_WAIT_PID) { in rd_kafka_idemp_pid_update() 472 rd_kafka_idemp_state2str(rk->rk_eos.idemp_state)); in rd_kafka_idemp_pid_update() 522 if (rk->rk_eos.idemp_state == RD_KAFKA_IDEMP_STATE_DRAIN_RESET) { in rd_kafka_idemp_drain_done() 527 } else if (rk->rk_eos.idemp_state == RD_KAFKA_IDEMP_STATE_DRAIN_BUMP && in rd_kafka_idemp_drain_done()
|
H A D | rdkafka_txnmgr.c | 475 rd_kafka_idemp_state_t idemp_state) { in rd_kafka_txn_idemp_state_change() argument 478 if (idemp_state == RD_KAFKA_IDEMP_STATE_ASSIGNED && in rd_kafka_txn_idemp_state_change() 485 } else if (idemp_state == RD_KAFKA_IDEMP_STATE_ASSIGNED && in rd_kafka_txn_idemp_state_change() 493 } else if (idemp_state == RD_KAFKA_IDEMP_STATE_FATAL_ERROR && in rd_kafka_txn_idemp_state_change() 1208 rd_kafka_idemp_state2str(rk->rk_eos.idemp_state)); in rd_kafka_txn_curr_api_req() 2008 rd_kafka_idemp_state2str(rk->rk_eos.idemp_state)); in rd_kafka_txn_op_send_offsets_to_transaction() 2384 rd_kafka_idemp_state2str(rk->rk_eos.idemp_state)); in rd_kafka_txn_op_commit_transaction() 2685 rk->rk_eos.idemp_state != RD_KAFKA_IDEMP_STATE_ASSIGNED) { in rd_kafka_txn_op_abort_transaction() 2741 rd_kafka_idemp_state2str(rk->rk_eos.idemp_state)); in rd_kafka_txn_op_abort_transaction() 3215 if (rk->rk_eos.idemp_state < RD_KAFKA_IDEMP_STATE_ASSIGNED) { in rd_kafka_txn_coord_monitor_cb() [all …]
|
H A D | rdkafka_idempotence.h | 57 if (likely(rk->rk_eos.idemp_state == RD_KAFKA_IDEMP_STATE_ASSIGNED)) in rd_kafka_idemp_get_pid0()
|
H A D | rdkafka_int.h | 362 rd_kafka_idemp_state_t idemp_state; /**< Idempotent Producer member
|
H A D | rdkafka.c | 1862 rd_kafka_idemp_state2str(rk->rk_eos.idemp_state), in rd_kafka_stats_emit_all()
|
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/src/ |
H A D | rdkafka_idempotence.c | 62 if (rk->rk_eos.idemp_state == new_state) in rd_segment_init() 74 idemp_state), in rd_buf_append_segment() 83 idemp_state), 86 rk->rk_eos.idemp_state = new_state; 217 switch (rk->rk_eos.idemp_state) in rd_buf_write_ensure() 467 if (rk->rk_eos.idemp_state != RD_KAFKA_IDEMP_STATE_WAIT_PID) { 472 rd_kafka_idemp_state2str(rk->rk_eos.idemp_state)); 522 if (rk->rk_eos.idemp_state == RD_KAFKA_IDEMP_STATE_DRAIN_RESET) { in rd_segment_write_update() 527 } else if (rk->rk_eos.idemp_state == RD_KAFKA_IDEMP_STATE_DRAIN_BUMP && in rd_segment_write_update()
|
H A D | rdkafka_txnmgr.c | 475 rd_kafka_idemp_state_t idemp_state) { 478 if (idemp_state == RD_KAFKA_IDEMP_STATE_ASSIGNED && 485 } else if (idemp_state == RD_KAFKA_IDEMP_STATE_ASSIGNED && 493 } else if (idemp_state == RD_KAFKA_IDEMP_STATE_FATAL_ERROR && 1208 rd_kafka_idemp_state2str(rk->rk_eos.idemp_state)); 2001 rd_kafka_idemp_state2str(rk->rk_eos.idemp_state)); 2377 rd_kafka_idemp_state2str(rk->rk_eos.idemp_state)); 2678 rk->rk_eos.idemp_state != RD_KAFKA_IDEMP_STATE_ASSIGNED) { 2734 rd_kafka_idemp_state2str(rk->rk_eos.idemp_state)); 3206 if (rk->rk_eos.idemp_state < RD_KAFKA_IDEMP_STATE_ASSIGNED) { [all …]
|
H A D | rdkafka_idempotence.h | 57 if (likely(rk->rk_eos.idemp_state == RD_KAFKA_IDEMP_STATE_ASSIGNED)) in rd_kafka_idemp_get_pid0()
|
H A D | rdkafka_int.h | 362 rd_kafka_idemp_state_t idemp_state; /**< Idempotent Producer member
|
H A D | rdkafka.c | 1862 rd_kafka_idemp_state2str(rk->rk_eos.idemp_state),
|
/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-0.24.0/src/ |
H A D | statistics.rs | 314 pub idemp_state: String, field
|
/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/ |
H A D | STATISTICS.md | 212 idemp_state | string | "Assigned" | Current idempotent producer id state. 213 idemp_stateage | int gauge | | Time elapsed since last idemp_state change (milliseconds).
|
/dports/net/librdkafka/librdkafka-1.8.2/ |
H A D | STATISTICS.md | 217 idemp_state | string | "Assigned" | Current idempotent producer id state. 218 idemp_stateage | int gauge | | Time elapsed since last idemp_state change (milliseconds).
|
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/ |
H A D | STATISTICS.md | 217 idemp_state | string | "Assigned" | Current idempotent producer id state. 218 idemp_stateage | int gauge | | Time elapsed since last idemp_state change (milliseconds).
|