mirrors/prometheus
1
0
Fork 0
mirror of https://github.com/prometheus/prometheus.git synced 2026-05-06 04:46:13 +02:00
Code Issues Projects Releases Wiki Activity

Parallel tsdb/wlog test

Browse Source 
Signed-off-by: pipiland2612 <nguyen.t.dang.minh@gmail.com>
This commit is contained in:
pipiland2612 2025-08-06 20:39:12 +03:00 committed by Ayoub Mrini
parent 294f36e802
commit de93387f0b
4 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
tsdb/wlog/checkpoint_test.go
View File

@ -113,6 +113,7 @@ func TestDeleteCheckpoints(t *testing.T) {
}
func TestCheckpoint(t *testing.T) {
t.Parallel()
makeHistogram := func(i int) *histogram.Histogram {
return &histogram.Histogram{
Count: 5 + uint64(i*4),

2
tsdb/wlog/reader_test.go
View File

@ -314,6 +314,7 @@ func allSegments(dir string) (io.ReadCloser, error) {
}
func TestReaderFuzz(t *testing.T) {
t.Parallel()
for name, fn := range readerConstructors {
for _, compress := range compression.Types() {
t.Run(fmt.Sprintf("%s,compress=%s", name, compress), func(t *testing.T) {
@ -353,6 +354,7 @@ func TestReaderFuzz(t *testing.T) {
}
func TestReaderFuzz_Live(t *testing.T) {
t.Parallel()
logger := promslog.NewNopLogger()
for _, compress := range compression.Types() {
t.Run(fmt.Sprintf("compress=%s", compress), func(t *testing.T) {

2
tsdb/wlog/watcher_test.go
View File

@ -443,6 +443,7 @@ func TestReadToEndWithCheckpoint(t *testing.T) {
}
func TestReadCheckpoint(t *testing.T) {
t.Parallel()
pageSize := 32 * 1024
const seriesCount = 10
const samplesCount = 250
@ -677,6 +678,7 @@ func TestCheckpointSeriesReset(t *testing.T) {
}
func TestRun_StartupTime(t *testing.T) {
t.Parallel()
const pageSize = 32 * 1024
const segments = 10
const seriesCount = 20

1
tsdb/wlog/wlog_test.go
View File

@ -369,6 +369,7 @@ func TestSegmentMetric(t *testing.T) {
}
func TestCompression(t *testing.T) {
t.Parallel()
bootstrap := func(compressed compression.Type) string {
const (
segmentSize = pageSize