Function NewUsagePusher

internal/nodeagent/usage.go:47–57

NewUsagePusher 构造一个 pusher。interval==0 时取默认 60s。

(api UsageSnapshotProvider, interval time.Duration)

// NewUsagePusher 构造一个 pusher。interval==0 时取默认 60s。
func NewUsagePusher(api UsageSnapshotProvider, interval time.Duration) *UsagePusher {
	if interval <= 0 {
		interval = 60 * time.Second
	}
	return &UsagePusher{
		api:      api,
		interval: interval,
		logger:   slog.Default(),
		ackWait:  interval, // 默认 ack 超时 = 一个 interval
	}
}

// SetAckTimeout 自定义等待 ack 的超时；<=0 时复用 interval。
func (p *UsagePusher) SetAckTimeout(d time.Duration) {