Method tick

internal/nodeagent/usage.go:103–157

tick 执行单次推送循环。导出名仅用于测试。

(ctx context.Context)

// tick 执行单次推送循环。导出名仅用于测试。
func (p *UsagePusher) tick(ctx context.Context) {
	sender := p.currentSender()
	if sender == nil {
		return
	}

	// 第一次启动：清零 xray 累计，建立 baseline，不 push。
	if !p.primed {
		_ = p.api.DoUsage(true)
		p.primed = true
		return
	}

	// 取一次 delta 快照（不 reset）。
	stats := p.api.DoUsage(false)
	body, err := json.Marshal(stats)
	if err != nil {
		p.logger.Warn("nodeagent: marshal usage failed", "err", err)
		return
	}

	// 重发尚未 ack 的旧 seq（按 seq 升序，server 端去重）。
	var pendings []pendingUsage
	p.pending.Range(func(k, v any) bool {
		pendings = append(pendings, v.(pendingUsage))
		return true
	})
	for _, pu := range pendings {
		if err := sender.PushEvent("", "usage_push", pu.body, pu.seq); err != nil {
			p.logger.Warn("nodeagent: re-push usage failed", "seq", pu.seq, "err", err)
			return
		}
	}

	seq := p.nextSeq.Add(1)
	pend := pendingUsage{seq: seq, body: body}
	p.pending.Store(seq, pend)

	if err := sender.PushEvent("", "usage_push", body, seq); err != nil {
		p.logger.Warn("nodeagent: push usage failed", "seq", seq, "err", err)
		return
	}

	// 异步等待 ack：成功 → DoUsage(true) 推进 baseline；超时 → 保留 pending 给下轮重发。
	go func(s Sender, seq uint64) {
		waitCtx, cancel := context.WithTimeout(ctx, p.ackWait)
		defer cancel()
		if err := s.WaitAck(waitCtx, seq); err != nil {
			p.logger.Debug("nodeagent: usage ack timeout", "seq", seq, "err", err)
			return
		}
		_ = p.api.DoUsage(true)
		p.pending.Delete(seq)
	}(sender, seq)
}

// PendingCount 返回当前未 ack 的 seq 数量（仅供测试/监控用）。
func (p *UsagePusher) PendingCount() int {