Function TestSampleDeliveryOrder

storage/remote/queue_manager_test.go:421–443

(t *testing.T)

}

func TestSampleDeliveryOrder(t *testing.T) {
	t.Parallel()
	for _, protoMsg := range []remoteapi.WriteMessageType{remoteapi.WriteV1MessageType, remoteapi.WriteV2MessageType} {
		t.Run(fmt.Sprint(protoMsg), func(t *testing.T) {
			ts := 10
			n := config.DefaultQueueConfig.MaxSamplesPerSend * ts
			recs := testwal.GenerateRecords(recCase{
				NoST:   protoMsg == remoteapi.WriteV1MessageType, // RW1 does not support ST.
				Series: n, SamplesPerSeries: 1,
			})

			c, m := newTestClientAndQueueManager(t, defaultFlushDeadline, protoMsg)
			c.expectSamples(recs.Samples, recs.Series)
			m.StoreSeries(recs.Series, 0)

			m.Start()
			defer m.Stop()
			// These should be received by the client.
			m.Append(recs.Samples)
			c.waitForExpectedData(t, 30*time.Second)
		})
	}
}

func TestShutdown(t *testing.T) {
	t.Parallel()