Struct PushHealthSnapshot 

pub struct PushHealthSnapshot {

    pub push_stream_healthy: bool,
    pub last_push_received_at_ms: i64,
    pub last_push_by_sub_type: Vec<PushSubTypeWatermark>,
    pub consecutive_parse_errors: u32,
    pub total_parse_errors: u64,
    pub total_pushes_received: u64,
    pub resubscribe_triggers: u64,
    pub circuit_breaker_trips: u64,
    pub circuit_breaker_tripped_at_ms: i64,
    pub is_circuit_tripped_now: bool,
    pub orphan_orders_detected: u64,
    pub last_orphan_scan_at_ms: i64,
    pub last_resubscribe_at_ms: i64,
    pub f2_circuit_tripped_total: u64,
    pub trade_requery_queue_dropped_total: u64,
    pub last_trade_requery_drop_at_ms: i64,
    pub last_resubscribe_partial_at_ms: i64,
    pub resubscribe_partial_total: u64,
    pub last_missed_keys_count: u32,
    pub degraded_reason: Option<String>,
}

v1.4.83 §9 F5 结构化 snapshot, 给 /api/push-subscriber-info 直接序列化.

Fields

push_stream_healthy: bool

last_push_received_at_ms: i64

last_push_by_sub_type: Vec<PushSubTypeWatermark>

consecutive_parse_errors: u32

total_parse_errors: u64

total_pushes_received: u64

resubscribe_triggers: u64

circuit_breaker_trips: u64

circuit_breaker_tripped_at_ms: i64

is_circuit_tripped_now: bool

orphan_orders_detected: u64

last_orphan_scan_at_ms: i64

last_resubscribe_at_ms: i64

f2_circuit_tripped_total: u64

v1.4.90 P2-B: F2 (TradeReQuery) account-level circuit-break 总 trip 次数.

trade_requery_queue_dropped_total: u64

v1.4.106 codex 0932 F1: TradeReQuery 队列丢弃总数 (queue full / closed). 持续 > 0 表明 dispatcher 跟不上 push 速度, 需要 ops 关注.

last_trade_requery_drop_at_ms: i64

v1.4.106 codex 0932 F1: 最近一次 TradeReQuery drop 的 Unix ms. 0 = 从未丢弃过. 60s 内非 0 → is_healthy() 返 false.

last_resubscribe_partial_at_ms: i64

v1.4.106 codex 0631 F4 [P2]: 最近一次 resubscribe 部分失败的 Unix ms. 0 = 从未部分失败. 60s 内非 0 → push_stream_healthy=false (degraded).

resubscribe_partial_total: u64

v1.4.106 codex 0631 F4 [P2]: resubscribe 部分失败累计次数 (monotonic). 监控 alarm: rate-of-change 显著 → 后端 / 网络异常.

last_missed_keys_count: u32

v1.4.106 codex 0631 F4 [P2]: 最近一次 resubscribe 缺失的 keys 数 (cache miss / unresolved). 0 = 全部 OK; >0 = 部分 ghost subscription.

degraded_reason: Option<String>

v1.4.106 codex 0631 F4 [P2]: 导致 push_stream_healthy=false 的人类 可读理由 (None = 健康).

Implementations

impl PushHealthSnapshot

pub fn render_prometheus(&self) -> String

Render the snapshot as Prometheus text exposition.

Trait Implementations

impl Clone for PushHealthSnapshot

fn clone(&self) -> PushHealthSnapshot

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PushHealthSnapshot

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

Formats the value using the given formatter.

impl Serialize for PushHealthSnapshot

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.