pub struct SagaOperationalMetrics {Show 30 fields
pub started_total: u64,
pub completed_total: u64,
pub compensated_total: u64,
pub manual_intervention_total: u64,
pub manually_closed_total: u64,
pub quota_rejections_total: u64,
pub action_rate_rejections_total: u64,
pub unknown_result_total: u64,
pub retry_attempt_total: u64,
pub conflict_total: u64,
pub running_current: u64,
pub waiting_resolution_current: u64,
pub compensating_current: u64,
pub manual_intervention_current: u64,
pub due_timer_current: u64,
pub lifecycle_duration_count: u64,
pub lifecycle_duration_micros_sum: u64,
pub lifecycle_quantiles: Vec<SagaLifecycleQuantiles>,
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,
}Expand description
业务作用：聚合 Saga 已提交状态与当前进程 Kafka transport 指标。
Fields§
§started_total: u64历史创建实例数。
completed_total: u64进入 COMPLETED 的历史迁移数。
compensated_total: u64进入 COMPENSATED 的历史迁移数。
manual_intervention_total: u64进入 MANUAL_INTERVENTION 的历史迁移数。
manually_closed_total: u64进入 MANUALLY_CLOSED 的历史迁移数（系统外处置后人工关闭自动化）。
quota_rejections_total: u64当前进程按租户配额拒绝的创建请求数（不携带租户标签,精确用量走受鉴权管理查询）。
action_rate_rejections_total: u64当前进程按租户速率拒绝的变更类管理动作数（不携带租户标签,当前窗口用量走 受鉴权管理查询）。
unknown_result_total: u64历史 Unknown attempt 数。
retry_attempt_total: u64历史业务 attempt 重试数。
conflict_total: u64历史互斥事实数。
running_current: u64当前正向运行实例数。
waiting_resolution_current: u64当前等待 Unknown 裁决实例数。
compensating_current: u64当前补偿中实例数。
manual_intervention_current: u64当前人工介入实例数。
due_timer_current: u64当前已到期且可领取 timer 数。
lifecycle_duration_count: u64终态生命周期样本数。
lifecycle_duration_micros_sum: u64终态生命周期累计微秒数。
lifecycle_quantiles: Vec<SagaLifecycleQuantiles>按冻结 workflow/definition version 分组的端到端终态时延分位数。
kafka_result_processing_total: u64当前进程处理 Saga result 次数。
kafka_result_processing_micros_sum: u64当前进程处理 Saga result 累计微秒数。
kafka_result_retry_total: u64当前进程请求 Kafka 保留 offset 重投的次数。
kafka_result_dlt_requested_total: u64当前进程请求 nafka 进入 durability-first DLT 的次数。
kafka_result_ack_total: u64当前进程在本地事务提交后完成手动 ACK 的次数。
kafka_result_duplicate_total: u64当前进程由 Inbox 幂等吸收后 ACK 的重复结果数。
kafka_command_processing_total: u64当前进程处理 Saga command 次数。
kafka_command_processing_micros_sum: u64当前进程处理 Saga command 累计微秒数。
kafka_command_retry_total: u64当前进程因 Participant 事务未提交而保留 command offset 的次数。
kafka_command_dlt_requested_total: u64当前进程请求 command 进入 durability-first DLT 的次数。
kafka_command_ack_total: u64当前进程在 Participant COMMIT 后完成手动 ACK 的 command 数。
kafka_command_duplicate_total: u64当前进程由 Participant Inbox 幂等吸收后 ACK 的重复 command 数。
Implementations§
Source§impl SagaOperationalMetrics
impl SagaOperationalMetrics
Sourcepub fn render_prometheus(&self) -> String
pub fn render_prometheus(&self) -> String
业务作用：把低基数快照渲染为 Prometheus text exposition 格式。
参数说明: 无。
返回：可直接作为 /metrics 响应体的 UTF-8 文本，不包含高基数标签。
Trait Implementations§
Source§impl Clone for SagaOperationalMetrics
impl Clone for SagaOperationalMetrics
Source§impl Debug for SagaOperationalMetrics
impl Debug for SagaOperationalMetrics
Source§impl Default for SagaOperationalMetrics
impl Default for SagaOperationalMetrics
impl Eq for SagaOperationalMetrics
Source§impl From<SagaStoreMetrics> for SagaOperationalMetrics
impl From<SagaStoreMetrics> for SagaOperationalMetrics
Source§fn from(store: SagaStoreMetrics) -> Self
fn from(store: SagaStoreMetrics) -> Self
业务作用：将后端已提交快照与当前进程 transport 计数组装为对外指标。
参数说明：
store: 当前 Saga 后端聚合的已提交事实。
返回：包含完整业务与 transport 指标的快照。