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

Ensure TSI tests run with TSI index

pull/8685/head
Edd Robinson 2017-08-08 14:36:04 +01:00
parent bca4393494
commit dd808bb77a
1 changed files with 48 additions and 76 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

68
tsdb/store_test.go
View File

@ -592,11 +592,12 @@ func testStoreCardinalityTombstoning(t *testing.T, store *Store) {
}
}
func TestStore_Cardinality_Tombstoning_Inmem(t *testing.T) {
func TestStore_Cardinality_Tombstoning(t *testing.T) {
t.Parallel()
test := func(index string) {
store := NewStore()
store.EngineOptions.Config.Index = "inmem"
store.EngineOptions.IndexVersion = index
if err := store.Open(); err != nil {
panic(err)
}
@ -604,16 +605,9 @@ func TestStore_Cardinality_Tombstoning_Inmem(t *testing.T) {
testStoreCardinalityTombstoning(t, store)
}
func TestStore_Cardinality_Tombstoning_TSI(t *testing.T) {
t.Parallel()
store := NewStore()
store.EngineOptions.Config.Index = "tsi1"
if err := store.Open(); err != nil {
panic(err)
for _, index := range tsdb.RegisteredIndexes() {
t.Run(index, func(t *testing.T) { test(index) })
}
defer store.Close()
testStoreCardinalityTombstoning(t, store)
}
func testStoreCardinalityUnique(t *testing.T, store *Store) {
@ -664,11 +658,12 @@ func testStoreCardinalityUnique(t *testing.T, store *Store) {
}
}
func TestStore_Cardinality_Unique_Inmem(t *testing.T) {
func TestStore_Cardinality_Unique(t *testing.T) {
t.Parallel()
test := func(index string) {
store := NewStore()
store.EngineOptions.Config.Index = "inmem"
store.EngineOptions.IndexVersion = index
store.EngineOptions.Config.MaxSeriesPerDatabase = 0
if err := store.Open(); err != nil {
panic(err)
@ -677,17 +672,9 @@ func TestStore_Cardinality_Unique_Inmem(t *testing.T) {
testStoreCardinalityUnique(t, store)
}
func TestStore_Cardinality_Unique_TSI1(t *testing.T) {
t.Parallel()
store := NewStore()
store.EngineOptions.Config.Index = "tsi1"
store.EngineOptions.Config.MaxSeriesPerDatabase = 0
if err := store.Open(); err != nil {
panic(err)
for _, index := range tsdb.RegisteredIndexes() {
t.Run(index, func(t *testing.T) { test(index) })
}
defer store.Close()
testStoreCardinalityUnique(t, store)
}
// This test tests cardinality estimation when series data is duplicated across
@ -754,11 +741,12 @@ func testStoreCardinalityDuplicates(t *testing.T, store *Store) {
}
}
func TestStore_Cardinality_Duplicates_Inmem(t *testing.T) {
func TestStore_Cardinality_Duplicates(t *testing.T) {
t.Parallel()
test := func(index string) {
store := NewStore()
store.EngineOptions.Config.Index = "inmem"
store.EngineOptions.IndexVersion = index
store.EngineOptions.Config.MaxSeriesPerDatabase = 0
if err := store.Open(); err != nil {
panic(err)
@ -767,17 +755,9 @@ func TestStore_Cardinality_Duplicates_Inmem(t *testing.T) {
testStoreCardinalityDuplicates(t, store)
}
func TestStore_Cardinality_Duplicates_TSI1(t *testing.T) {
t.Parallel()
store := NewStore()
store.EngineOptions.Config.Index = "tsi1"
store.EngineOptions.Config.MaxSeriesPerDatabase = 0
if err := store.Open(); err != nil {
panic(err)
for _, index := range tsdb.RegisteredIndexes() {
t.Run(index, func(t *testing.T) { test(index) })
}
defer store.Close()
testStoreCardinalityDuplicates(t, store)
}
// Creates a large number of series in multiple shards, which will force
@ -830,9 +810,10 @@ func testStoreCardinalityCompactions(t *testing.T, store *Store) {
}
}
func TestStore_Cardinality_Compactions_Inmem(t *testing.T) {
func TestStore_Cardinality_Compactions(t *testing.T) {
t.Parallel()
test := func(index string) {
store := NewStore()
store.EngineOptions.Config.Index = "inmem"
store.EngineOptions.Config.MaxSeriesPerDatabase = 0
@ -843,17 +824,9 @@ func TestStore_Cardinality_Compactions_Inmem(t *testing.T) {
testStoreCardinalityCompactions(t, store)
}
func TestStore_Cardinality_Compactions_TSI1(t *testing.T) {
t.Parallel()
store := NewStore()
store.EngineOptions.Config.Index = "tsi1"
store.EngineOptions.Config.MaxSeriesPerDatabase = 0
if err := store.Open(); err != nil {
panic(err)
for _, index := range tsdb.RegisteredIndexes() {
t.Run(index, func(t *testing.T) { test(index) })
}
defer store.Close()
testStoreCardinalityCompactions(t, store)
}
func TestStore_TagValues(t *testing.T) {
@ -961,9 +934,8 @@ func TestStore_TagValues(t *testing.T) {
}
}
indexes := []string{"inmem", "tsi1"}
for _, example := range examples {
for _, index := range indexes {
for _, index := range tsdb.RegisteredIndexes() {
setup(index)
t.Run(example.Name+"_"+index, func(t *testing.T) {
got, err := s.TagValues("db0", example.Expr)