Influxdata
/
influxdb
mirror of https://github.com/influxdata/influxdb.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

chore: delete pointless test for mixed-index shards (#22405)

pull/22416/head
Daniel Moran 2021-09-07 12:25:07 -04:00 committed by GitHub
parent 6418f693f7
commit af12281358
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 0 additions and 55 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

55
tsdb/store_test.go
View File

@ -143,61 +143,6 @@ func TestStore_CreateShard(t *testing.T) {
}
}
func TestStore_CreateMixedShards(t *testing.T) {
test := func(t *testing.T, index1 string, index2 string) {
s := MustOpenStore(t, index1)
defer s.Close()
// Create a new shard and verify that it exists.
if err := s.CreateShard(context.Background(), "db0", "rp0", 1, true); err != nil {
t.Fatal(err)
} else if sh := s.Shard(1); sh == nil {
t.Fatalf("expected shard")
}
s.EngineOptions.IndexVersion = index2
s.index = index2
if err := s.Reopen(t); err != nil {
t.Fatal(err)
}
// Create another shard and verify that it exists.
if err := s.CreateShard(context.Background(), "db0", "rp0", 2, true); err != nil {
t.Fatal(err)
} else if sh := s.Shard(2); sh == nil {
t.Fatalf("expected shard")
}
// Reopen shard and recheck.
if err := s.Reopen(t); err != nil {
t.Fatal(err)
} else if sh := s.Shard(1); sh == nil {
t.Fatalf("expected shard(1)")
} else if sh = s.Shard(2); sh == nil {
t.Fatalf("expected shard(2)")
}
sh := s.Shard(1)
if sh.IndexType() != index1 {
t.Fatalf("got index %v, expected %v", sh.IndexType(), index1)
}
sh = s.Shard(2)
if sh.IndexType() != index2 {
t.Fatalf("got index %v, expected %v", sh.IndexType(), index2)
}
}
indexes := tsdb.RegisteredIndexes()
for i := range indexes {
j := (i + 1) % len(indexes)
index1 := indexes[i]
index2 := indexes[j]
t.Run(fmt.Sprintf("%s-%s", index1, index2), func(t *testing.T) { test(t, index1, index2) })
}
}
func TestStore_DropConcurrentWriteMultipleShards(t *testing.T) {
test := func(t *testing.T, index string) {