mudhorn/prometheus
1
0
Fork 0
mirror of https://github.com/prometheus/prometheus.git synced 2025-03-05 20:59:13 -08:00
Code Issues Actions 5 Packages Projects Releases Wiki Activity

Remove test

Browse source 
Signed-off-by: Patryk Prus <p@trykpr.us>
This commit is contained in:
Patryk Prus 2025-03-05 12:24:37 -05:00
parent f3b51c343d
commit 8a5cf7be16
No known key found for this signature in database
GPG key ID: 795650115CA6A58F
1 changed files with 0 additions and 99 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

99
tsdb/head_test.go
View file

@ -886,105 +886,6 @@ func TestHead_KeepSeriesInWALCheckpoint(t *testing.T) {
}
}
func TestHead_WALMultiRef_Checkpoint(t *testing.T) {
head, w := newTestHead(t, 10000, wlog.CompressionNone, false)
require.NoError(t, head.Init(0))
// Write a sample.
app := head.Appender(context.Background())
ref1, err := app.Append(0, labels.FromStrings("foo", "bar"), 100, 1)
require.NoError(t, err)
require.NoError(t, app.Commit())
// Truncate head to remove first series entirely.
require.NoError(t, head.Truncate(500))
// Write another sample -- will create a new series ID.
app = head.Appender(context.Background())
ref2, err := app.Append(0, labels.FromStrings("foo", "bar"), 600, 2)
require.NoError(t, err)
require.NoError(t, app.Commit())
require.NotEqual(t, ref1, ref2, "refs should be different")
// Start a new WAL segment so we can checkpoint the series entry separately from future samples.
seg, err := w.NextSegment()
require.NoError(t, err)
require.Equal(t, 2, seg)
// Write another sample -- will be written using the new series ID.
app = head.Appender(context.Background())
ref3, err := app.Append(0, labels.FromStrings("foo", "bar"), 1000, 3)
require.NoError(t, err)
require.NoError(t, app.Commit())
require.Equal(t, ref2, ref3, "refs should be the same")
// Close and re-open head (simulated restart).
require.NoError(t, head.Close())
w, err = wlog.NewSize(nil, nil, w.Dir(), 32768, wlog.CompressionNone)
require.NoError(t, err)
head, err = NewHead(nil, nil, w, nil, head.opts, nil)
require.NoError(t, err)
require.NoError(t, head.Init(500))
// WAL replay will use the original series ID for all samples in the WAL, as well
// as any new samples for the series written after replay.
// Write another sample -- will be written using the original series ID.
app = head.Appender(context.Background())
ref4, err := app.Append(0, labels.FromStrings("foo", "bar"), 1500, 4)
require.NoError(t, err)
require.NoError(t, app.Commit())
require.Equal(t, ref1, ref4, "refs should be the same")
// At this point the WAL is:
// - segment 0:
// - series 1 record
// - series 1 sample @ 100
// - segment 1:
// - series 2 record
// - series 2 sample @ 600
// - segment 2:
// - series 2 sample @ 1000
// - segment 3:
// - series 1 sample @ 1500
// Truncate head again
require.NoError(t, head.Truncate(700))
// Ensure a checkpoint was created.
_, chkidx, err := wlog.LastCheckpoint(w.Dir())
require.NoError(t, err)
require.Equal(t, 1, chkidx)
// Close and re-open head again (simulated restart).
require.NoError(t, head.Close())
w, err = wlog.NewSize(nil, nil, w.Dir(), 32768, wlog.CompressionNone)
require.NoError(t, err)
head, err = NewHead(nil, nil, w, nil, head.opts, nil)
require.NoError(t, err)
require.NoError(t, head.Init(700))
defer func() {
require.NoError(t, head.Close())
}()
q, err := NewBlockQuerier(head, 0, 1600)
require.NoError(t, err)
series := query(t, q, labels.MustNewMatcher(labels.MatchEqual, "foo", "bar"))
// We expect only the samples after the truncation.
require.Equal(t, map[string][]chunks.Sample{`{foo="bar"}`: {
sample{1000, 3, nil, nil},
sample{1500, 4, nil, nil},
}}, series)
}
func TestHead_ActiveAppenders(t *testing.T) {
head, _ := newTestHead(t, 1000, wlog.CompressionNone, false)
defer head.Close()