PendingCount 返回当前未 ack 的 seq 数量(仅供测试/监控用)。
()
| 158 | |
| 159 | // PendingCount 返回当前未 ack 的 seq 数量(仅供测试/监控用)。 |
| 160 | func (p *UsagePusher) PendingCount() int { |
| 161 | n := 0 |
| 162 | p.pending.Range(func(_, _ any) bool { n++; return true }) |
| 163 | return n |
| 164 | } |
| 165 | |
| 166 | // 静态接口绑定,确保 *nodeapi.API 满足 UsageSnapshotProvider。 |
| 167 | var _ UsageSnapshotProvider = (*nodeapi.API)(nil) |
no outgoing calls