MCPcopy Create free account
hub / github.com/0xUnixIO/pulse / PendingCount

Method PendingCount

internal/nodeagent/usage.go:160–164  ·  view source on GitHub ↗

PendingCount 返回当前未 ack 的 seq 数量(仅供测试/监控用)。

()

Source from the content-addressed store, hash-verified

158
159// PendingCount 返回当前未 ack 的 seq 数量(仅供测试/监控用)。
160func (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。
167var _ UsageSnapshotProvider = (*nodeapi.API)(nil)

Calls

no outgoing calls

Tested by 5

TestE2E_UsagePushAckFunction · 0.76
TestE2E_MultiNodeFunction · 0.64