Struct scriptedMessagingClient

core/services/nodes/managers_distributed_test.go:26–35

scriptedMessagingClient maps a NATS subject to a canned reply payload (or error). Used so each fan-out request can simulate a different worker outcome without spinning up real NATS.

// (or error). Used so each fan-out request can simulate a different worker
// outcome without spinning up real NATS.
type scriptedMessagingClient struct {
	mu                         sync.Mutex
	replies                    map[string][]byte
	errs                       map[string]error
	calls                      []requestCall
	matchedReplies             map[string][]matchedReply
	publishes                  []progressPublishCall
	scheduledProgressPublishes []scheduledProgressPublish
	subscribes                 []string
}

// progressPublishCall records a single Publish invocation. The progress
// publisher tests assert on the sequence of BackendInstallProgressEvent