Function newMockSender

internal/nodeagent/usage_test.go:58–60

()

}

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

func (s *mockSender) PushEvent(reqID, event string, body []byte, seq uint64) error {
	if s.failNext.Swap(false) {