Struct SagaProcessMetrics 

pub struct SagaProcessMetrics {

    pub quota_rejections_total: u64,
    pub action_rate_rejections_total: u64,
    pub kafka_result_processing_total: u64,
    pub kafka_result_processing_micros_sum: u64,
    pub kafka_result_retry_total: u64,
    pub kafka_result_dlt_requested_total: u64,
    pub kafka_result_ack_total: u64,
    pub kafka_result_duplicate_total: u64,
    pub kafka_command_processing_total: u64,
    pub kafka_command_processing_micros_sum: u64,
    pub kafka_command_retry_total: u64,
    pub kafka_command_dlt_requested_total: u64,
    pub kafka_command_ack_total: u64,
    pub kafka_command_duplicate_total: u64,
}

业务作用：保存同一进程内只允许存在一份的 Saga transport 与治理计数快照。

Fields

quota_rejections_total: u64

按租户配额拒绝的创建请求累计数。

action_rate_rejections_total: u64

按租户频率拒绝的管理动作累计数。

kafka_result_processing_total: u64

Kafka result handler 调用累计数。

kafka_result_processing_micros_sum: u64

Kafka result handler 累计耗时微秒数。

kafka_result_retry_total: u64

Kafka result 保留 offset 重投累计数。

kafka_result_dlt_requested_total: u64

Kafka result 请求进入 durability-first DLT 的累计数。

kafka_result_ack_total: u64

Kafka result 在本地提交后 ACK 的累计数。

kafka_result_duplicate_total: u64

Kafka result 被 Inbox 吸收后 ACK 的累计数。

kafka_command_processing_total: u64

Kafka command handler 调用累计数。

kafka_command_processing_micros_sum: u64

Kafka command handler 累计耗时微秒数。

kafka_command_retry_total: u64

Kafka command 因本地事务未提交而重投的累计数。

kafka_command_dlt_requested_total: u64

Kafka command 请求进入 durability-first DLT 的累计数。

kafka_command_ack_total: u64

Kafka command 在参与方提交后 ACK 的累计数。

kafka_command_duplicate_total: u64

Kafka command 被 Inbox 吸收后 ACK 的累计数。

Trait Implementations

impl Clone for SagaProcessMetrics

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Copy for SagaProcessMetrics

impl Debug for SagaProcessMetrics

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for SagaProcessMetrics

fn default() -> Self

Returns the “default value” for a type.

impl Eq for SagaProcessMetrics

impl PartialEq for SagaProcessMetrics

fn eq(&self, other: &Self) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for SagaProcessMetrics