Function NewTestWriteClient

storage/remote/queue_manager_test.go:882–892

NewTestWriteClient creates a new testing write client.

(protoMsg remoteapi.WriteMessageType)

// NewTestWriteClient creates a new testing write client.
func NewTestWriteClient(protoMsg remoteapi.WriteMessageType) *TestWriteClient {
	return &TestWriteClient{
		receivedSamples:  map[string][]writev2.Sample{},
		expectedSamples:  map[string][]writev2.Sample{},
		receivedMetadata: map[string][]prompb.MetricMetadata{},
		expectedMetadata: map[string][]prompb.MetricMetadata{},
		protoMsg:         protoMsg,
		storeWait:        0,
		returnError:      nil,
	}
}

func (c *TestWriteClient) injectErrors(injectedErrs []error) {
	c.injectedErrs = injectedErrs