Method currentSender

internal/nodeagent/usage.go:78–82

()

}

func (p *UsagePusher) currentSender() Sender {
	p.mu.Lock()
	defer p.mu.Unlock()
	return p.sender
}

// Run 阻塞循环 push usage，直到 ctx done。
func (p *UsagePusher) Run(ctx context.Context) error {