Struct failOnceMessagingClient

core/services/nodes/unloader_test.go:226–231

failOnceMessagingClient wraps fakeMessagingClient but fails the Publish call at index failOn (0-based) and succeeds all others.

// failOnceMessagingClient wraps fakeMessagingClient but fails the Publish call
// at index failOn (0-based) and succeeds all others.
type failOnceMessagingClient struct {
	inner   *fakeMessagingClient
	failOn  int
	callIdx int
	mu      sync.Mutex
}

func (f *failOnceMessagingClient) Publish(subject string, data any) error {
	f.mu.Lock()