Function testAppendableV2

util/teststorage/appender_test.go:84–129

(t *testing.T, appTest *Appendable, a storage.AppendableV2)

}

func testAppendableV2(t *testing.T, appTest *Appendable, a storage.AppendableV2) {
	for _, commit := range []bool{true, false} {
		appTest.ResultReset()

		app := a.AppenderV2(t.Context())

		m1 := metadata.Metadata{Type: "gauge", Unit: "", Help: "other help text"}
		e1 := exemplar.Exemplar{Labels: labels.FromStrings(model.MetricNameLabel, "yolo"), HasTs: true, Ts: 1}
		_, err := app.Append(0, labels.FromStrings(model.MetricNameLabel, "test_metric1", "app", "v2"), -1, 1, 2, nil, nil, storage.AOptions{
			MetricFamilyName: "test_metric1",
			Metadata:         m1,
			Exemplars:        []exemplar.Exemplar{e1},
		})
		require.NoError(t, err)

		h := tsdbutil.GenerateTestHistogram(0)
		_, err = app.Append(0, labels.FromStrings(model.MetricNameLabel, "test_metric2", "app", "v2"), -2, 2, 0, h, nil, storage.AOptions{})
		require.NoError(t, err)

		fh := tsdbutil.GenerateTestFloatHistogram(0)
		_, err = app.Append(0, labels.FromStrings(model.MetricNameLabel, "test_metric3", "app", "v2"), -3, 3, 0, nil, fh, storage.AOptions{})
		require.NoError(t, err)

		exp := []Sample{
			{L: labels.FromStrings(model.MetricNameLabel, "test_metric1", "app", "v2"), MF: "test_metric1", M: m1, ST: -1, T: 1, V: 2, ES: []exemplar.Exemplar{e1}},
			{L: labels.FromStrings(model.MetricNameLabel, "test_metric2", "app", "v2"), ST: -2, T: 2, H: h},
			{L: labels.FromStrings(model.MetricNameLabel, "test_metric3", "app", "v2"), ST: -3, T: 3, FH: fh},
		}
		testutil.RequireEqual(t, exp, appTest.PendingSamples())
		require.Nil(t, appTest.ResultSamples())
		require.Nil(t, appTest.RolledbackSamples())

		if commit {
			require.NoError(t, app.Commit())
			require.Nil(t, appTest.PendingSamples())
			testutil.RequireEqual(t, exp, appTest.ResultSamples())
			require.Nil(t, appTest.RolledbackSamples())
			break
		}

		require.NoError(t, app.Rollback())
		require.Nil(t, appTest.PendingSamples())
		require.Nil(t, appTest.ResultSamples())
		testutil.RequireEqual(t, exp, appTest.RolledbackSamples())
	}
}

func TestAppendable(t *testing.T) {
	appTest := NewAppendable()