Struct mockSender

internal/nodeagent/usage_test.go:51–56

mockSender 记录 push 与提供 ack 控制。

// mockSender 记录 push 与提供 ack 控制。
type mockSender struct {
	mu      sync.Mutex
	pushed  []uint64
	ackCh   map[uint64]chan struct{}
	failNext atomic.Bool
}

func newMockSender() *mockSender {
	return &mockSender{ackCh: make(map[uint64]chan struct{})}