Function BenchmarkFullPoller

tempodb/blocklist/poller_test.go:1151–1278

(b *testing.B)

}

func BenchmarkFullPoller(b *testing.B) {
	cases := []struct {
		name            string
		tenants         int
		blocksPerTenant int
		iterations      int
		blocksPer       int
		compactionsPer  int
	}{
		{
			name: "no tenants",
		},
		{
			name:            "single tenant",
			tenants:         1,
			blocksPerTenant: 1000,
		},
		{
			name:            "multi tenant",
			tenants:         10,
			blocksPerTenant: 1000,
		},
		{
			name:            "multi tenant growth",
			tenants:         10,
			blocksPerTenant: 1000,
			iterations:      10,
			blocksPer:       100,
		},
		{
			name:            "multi tenant growth and compactions",
			tenants:         10,
			blocksPerTenant: 1000,
			iterations:      10,
			blocksPer:       100,
			compactionsPer:  10,
		},
	}

	for _, bc := range cases {
		b.Run(fmt.Sprintf("%sTenants%dBlocks%dGrow%dCompactions%d", bc.name, bc.tenants, bc.blocksPerTenant, bc.blocksPer, bc.compactionsPer), func(b *testing.B) {
			s := &mockJobSharder{owns: true}

			d := b.TempDir()
			defer os.RemoveAll(d)

			rr, ww, cc, err := local.New(&local.Config{
				Path: d,
			})
			require.NoError(b, err)

			var (
				ctx = context.Background()
				r   = backend.NewReader(rr)
				w   = backend.NewWriter(ww)
				// c   = backend.NewCompactor(cc)
			)