Home
last modified time | relevance | path

Searched refs:idemp_state (Results 1 – 19 of 19) sorted by relevance

/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/src/
H A Drdkafka_idempotence.c62 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 Drdkafka_txnmgr.c414 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 Drdkafka_idempotence.h57 if (likely(rk->rk_eos.idemp_state == RD_KAFKA_IDEMP_STATE_ASSIGNED)) in rd_kafka_idemp_get_pid0()
H A Drdkafka_int.h358 rd_kafka_idemp_state_t idemp_state; /**< Idempotent Producer member
H A Drdkafka.c1746 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 Drdkafka_idempotence.c62 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 Drdkafka_txnmgr.c475 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 Drdkafka_idempotence.h57 if (likely(rk->rk_eos.idemp_state == RD_KAFKA_IDEMP_STATE_ASSIGNED)) in rd_kafka_idemp_get_pid0()
H A Drdkafka_int.h362 rd_kafka_idemp_state_t idemp_state; /**< Idempotent Producer member
H A Drdkafka.c1862 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 Drdkafka_idempotence.c62 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 Drdkafka_txnmgr.c475 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 Drdkafka_idempotence.h57 if (likely(rk->rk_eos.idemp_state == RD_KAFKA_IDEMP_STATE_ASSIGNED)) in rd_kafka_idemp_get_pid0()
H A Drdkafka_int.h362 rd_kafka_idemp_state_t idemp_state; /**< Idempotent Producer member
H A Drdkafka.c1862 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 Dstatistics.rs314 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 DSTATISTICS.md212 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 DSTATISTICS.md217 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 DSTATISTICS.md217 idemp_state | string | "Assigned" | Current idempotent producer id state.
218 idemp_stateage | int gauge | | Time elapsed since last idemp_state change (milliseconds).