Function TestBackendShards

modules/frontend/search_sharder_test.go:1050–1168

(t *testing.T)

}

func TestBackendShards(t *testing.T) {
	tcs := []struct {
		name      string
		maxShards int
		searchEnd uint32
		expected  []shardtracker.Shard
	}{
		{
			name:      "1 shard, puts all jobs in one shard",
			maxShards: 1,
			searchEnd: 50,
			expected: []shardtracker.Shard{
				{TotalJobs: 8, CompletedThroughSeconds: 1},
			},
		},
		{
			name:      "2 shards, split evenly between",
			maxShards: 2,
			searchEnd: 50,
			expected: []shardtracker.Shard{
				{TotalJobs: 4, CompletedThroughSeconds: 30},
				{TotalJobs: 4, CompletedThroughSeconds: 1},
			},
		},
		{
			name:      "3 shards, one for each block",
			maxShards: 3,
			searchEnd: 50,
			expected: []shardtracker.Shard{
				{TotalJobs: 2, CompletedThroughSeconds: 40},
				{TotalJobs: 2, CompletedThroughSeconds: 30},
				{TotalJobs: 4, CompletedThroughSeconds: 1},
			},
		},
		{
			name:      "4 shards, one for each block",
			maxShards: 4,
			searchEnd: 50,
			expected: []shardtracker.Shard{
				{TotalJobs: 2, CompletedThroughSeconds: 40},
				{TotalJobs: 2, CompletedThroughSeconds: 30},
				{TotalJobs: 2, CompletedThroughSeconds: 20},
				{TotalJobs: 2, CompletedThroughSeconds: 1},
			},
		},
		{
			name:      "5 shards, one for each block",
			maxShards: 5,
			searchEnd: 50,
			expected: []shardtracker.Shard{
				{TotalJobs: 2, CompletedThroughSeconds: 40},
				{TotalJobs: 2, CompletedThroughSeconds: 30},
				{TotalJobs: 2, CompletedThroughSeconds: 20},
				{TotalJobs: 2, CompletedThroughSeconds: 10},
			},
		},
		{
			name:      "4 shards, search end forces 2 blocks in the first shard",