expectSamples injects samples that will be expected on waitForExpectedData.
(ss []record.RefSample, series []record.RefSeries)
| 899 | |
| 900 | // expectSamples injects samples that will be expected on waitForExpectedData. |
| 901 | func (c *TestWriteClient) expectSamples(ss []record.RefSample, series []record.RefSeries) { |
| 902 | c.mtx.Lock() |
| 903 | defer c.mtx.Unlock() |
| 904 | |
| 905 | c.expectedSamples = map[string][]writev2.Sample{} |
| 906 | c.receivedSamples = map[string][]writev2.Sample{} |
| 907 | |
| 908 | for _, s := range ss { |
| 909 | tsID := getSeriesIDFromRef(series[s.Ref]) |
| 910 | c.expectedSamples[tsID] = append(c.expectedSamples[tsID], writev2.Sample{ |
| 911 | StartTimestamp: s.ST, |
| 912 | Timestamp: s.T, |
| 913 | Value: s.V, |
| 914 | }) |
| 915 | } |
| 916 | } |
| 917 | |
| 918 | func (c *TestWriteClient) expectExemplars(ss []record.RefExemplar, series []record.RefSeries) { |
| 919 | c.mtx.Lock() |
no test coverage detected