parent
c8d974048a
commit
56c4a09de1
|
@ -26,7 +26,12 @@ func TestHandlers(t *testing.T) {
|
|||
if err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
defer os.RemoveAll(basePath)
|
||||
defer func() {
|
||||
err := os.RemoveAll(basePath)
|
||||
if err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
}()
|
||||
|
||||
createIndexHandler := NewCreateIndexHandler(basePath)
|
||||
createIndexHandler.IndexNameLookup = indexNameLookup
|
||||
|
|
|
@ -22,7 +22,12 @@ func TestStore(t *testing.T) {
|
|||
if err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
defer os.RemoveAll("test")
|
||||
defer func() {
|
||||
err := os.RemoveAll("test")
|
||||
if err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
}()
|
||||
|
||||
CommonTestKVStore(t, s)
|
||||
}
|
||||
|
@ -32,7 +37,12 @@ func TestReaderIsolation(t *testing.T) {
|
|||
if err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
defer os.RemoveAll("test")
|
||||
defer func() {
|
||||
err := os.RemoveAll("test")
|
||||
if err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
}()
|
||||
|
||||
CommonTestReaderIsolation(t, s)
|
||||
}
|
||||
|
|
|
@ -19,10 +19,18 @@ import (
|
|||
"github.com/blevesearch/bleve/index/store"
|
||||
)
|
||||
|
||||
func TestLevelDBStore(t *testing.T) {
|
||||
defer os.RemoveAll("testdir")
|
||||
func TestForestDBStore(t *testing.T) {
|
||||
defer func() {
|
||||
err := os.RemoveAll("testdir")
|
||||
if err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
}()
|
||||
|
||||
os.MkdirAll("testdir", 0700)
|
||||
err := os.MkdirAll("testdir", 0700)
|
||||
if err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
s, err := Open("testdir/test", true, nil)
|
||||
if err != nil {
|
||||
t.Fatal(err)
|
||||
|
@ -33,9 +41,17 @@ func TestLevelDBStore(t *testing.T) {
|
|||
}
|
||||
|
||||
func TestReaderIsolation(t *testing.T) {
|
||||
defer os.RemoveAll("testdir")
|
||||
defer func() {
|
||||
err := os.RemoveAll("testdir")
|
||||
if err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
}()
|
||||
|
||||
os.MkdirAll("testdir", 0700)
|
||||
err := os.MkdirAll("testdir", 0700)
|
||||
if err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
s, err := Open("testdir/test", true, nil)
|
||||
if err != nil {
|
||||
t.Fatal(err)
|
||||
|
@ -49,9 +65,17 @@ func TestReaderIsolation(t *testing.T) {
|
|||
// and ensure that subsequent reads from it also
|
||||
// reflect the rollback
|
||||
func TestRollbackSameHandle(t *testing.T) {
|
||||
defer os.RemoveAll("testdir")
|
||||
defer func() {
|
||||
err := os.RemoveAll("testdir")
|
||||
if err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
}()
|
||||
|
||||
os.MkdirAll("testdir", 0700)
|
||||
err := os.MkdirAll("testdir", 0700)
|
||||
if err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
s, err := Open("testdir/test", true, nil)
|
||||
if err != nil {
|
||||
t.Fatal(err)
|
||||
|
@ -136,9 +160,17 @@ func TestRollbackSameHandle(t *testing.T) {
|
|||
// database, then opens a new handle, and ensures
|
||||
// that the rollback is reflected there as well
|
||||
func TestRollbackNewHandle(t *testing.T) {
|
||||
defer os.RemoveAll("testdir")
|
||||
defer func() {
|
||||
err := os.RemoveAll("testdir")
|
||||
if err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
}()
|
||||
|
||||
os.MkdirAll("testdir", 0700)
|
||||
err := os.MkdirAll("testdir", 0700)
|
||||
if err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
s, err := Open("testdir/test", true, nil)
|
||||
if err != nil {
|
||||
t.Fatal(err)
|
||||
|
@ -230,9 +262,17 @@ func TestRollbackNewHandle(t *testing.T) {
|
|||
// at the beginning, then rollback one of them
|
||||
// and ensure it affects the other
|
||||
func TestRollbackOtherHandle(t *testing.T) {
|
||||
defer os.RemoveAll("testdir")
|
||||
defer func() {
|
||||
err := os.RemoveAll("testdir")
|
||||
if err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
}()
|
||||
|
||||
os.MkdirAll("testdir", 0700)
|
||||
err := os.MkdirAll("testdir", 0700)
|
||||
if err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
s, err := Open("testdir/test", true, nil)
|
||||
if err != nil {
|
||||
t.Fatal(err)
|
||||
|
|
|
@ -24,7 +24,12 @@ var leveldbTestOptions = map[string]interface{}{
|
|||
}
|
||||
|
||||
func TestLevelDBStore(t *testing.T) {
|
||||
defer os.RemoveAll("test")
|
||||
defer func() {
|
||||
err := os.RemoveAll("test")
|
||||
if err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
}()
|
||||
|
||||
s, err := Open("test", leveldbTestOptions)
|
||||
if err != nil {
|
||||
|
@ -36,7 +41,12 @@ func TestLevelDBStore(t *testing.T) {
|
|||
}
|
||||
|
||||
func TestReaderIsolation(t *testing.T) {
|
||||
defer os.RemoveAll("test")
|
||||
defer func() {
|
||||
err := os.RemoveAll("test")
|
||||
if err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
}()
|
||||
|
||||
s, err := Open("test", leveldbTestOptions)
|
||||
if err != nil {
|
||||
|
|
|
@ -1,7 +1,6 @@
|
|||
package null
|
||||
|
||||
import (
|
||||
"os"
|
||||
"testing"
|
||||
|
||||
"github.com/blevesearch/bleve/index/store"
|
||||
|
@ -12,7 +11,6 @@ func TestStore(t *testing.T) {
|
|||
if err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
defer os.RemoveAll("test")
|
||||
|
||||
CommonTestKVStore(t, s)
|
||||
}
|
||||
|
|
|
@ -21,7 +21,12 @@ func BenchmarkBoltDBIndexing1Workers(b *testing.B) {
|
|||
if err != nil {
|
||||
b.Fatal(err)
|
||||
}
|
||||
defer os.RemoveAll("test")
|
||||
defer func() {
|
||||
err := os.RemoveAll("test")
|
||||
if err != nil {
|
||||
b.Fatal(err)
|
||||
}
|
||||
}()
|
||||
defer s.Close()
|
||||
|
||||
CommonBenchmarkIndex(b, s, 1)
|
||||
|
@ -32,7 +37,12 @@ func BenchmarkBoltDBIndexing2Workers(b *testing.B) {
|
|||
if err != nil {
|
||||
b.Fatal(err)
|
||||
}
|
||||
defer os.RemoveAll("test")
|
||||
defer func() {
|
||||
err := os.RemoveAll("test")
|
||||
if err != nil {
|
||||
b.Fatal(err)
|
||||
}
|
||||
}()
|
||||
defer s.Close()
|
||||
|
||||
CommonBenchmarkIndex(b, s, 2)
|
||||
|
@ -43,7 +53,12 @@ func BenchmarkBoltDBIndexing4Workers(b *testing.B) {
|
|||
if err != nil {
|
||||
b.Fatal(err)
|
||||
}
|
||||
defer os.RemoveAll("test")
|
||||
defer func() {
|
||||
err := os.RemoveAll("test")
|
||||
if err != nil {
|
||||
b.Fatal(err)
|
||||
}
|
||||
}()
|
||||
defer s.Close()
|
||||
|
||||
CommonBenchmarkIndex(b, s, 4)
|
||||
|
@ -56,7 +71,12 @@ func BenchmarkBoltDBIndexing1Workers10Batch(b *testing.B) {
|
|||
if err != nil {
|
||||
b.Fatal(err)
|
||||
}
|
||||
defer os.RemoveAll("test")
|
||||
defer func() {
|
||||
err := os.RemoveAll("test")
|
||||
if err != nil {
|
||||
b.Fatal(err)
|
||||
}
|
||||
}()
|
||||
defer s.Close()
|
||||
|
||||
CommonBenchmarkIndexBatch(b, s, 1, 10)
|
||||
|
@ -67,7 +87,12 @@ func BenchmarkBoltDBIndexing2Workers10Batch(b *testing.B) {
|
|||
if err != nil {
|
||||
b.Fatal(err)
|
||||
}
|
||||
defer os.RemoveAll("test")
|
||||
defer func() {
|
||||
err := os.RemoveAll("test")
|
||||
if err != nil {
|
||||
b.Fatal(err)
|
||||
}
|
||||
}()
|
||||
defer s.Close()
|
||||
|
||||
CommonBenchmarkIndexBatch(b, s, 2, 10)
|
||||
|
@ -78,7 +103,12 @@ func BenchmarkBoltDBIndexing4Workers10Batch(b *testing.B) {
|
|||
if err != nil {
|
||||
b.Fatal(err)
|
||||
}
|
||||
defer os.RemoveAll("test")
|
||||
defer func() {
|
||||
err := os.RemoveAll("test")
|
||||
if err != nil {
|
||||
b.Fatal(err)
|
||||
}
|
||||
}()
|
||||
defer s.Close()
|
||||
|
||||
CommonBenchmarkIndexBatch(b, s, 4, 10)
|
||||
|
@ -89,7 +119,12 @@ func BenchmarkBoltDBIndexing1Workers100Batch(b *testing.B) {
|
|||
if err != nil {
|
||||
b.Fatal(err)
|
||||
}
|
||||
defer os.RemoveAll("test")
|
||||
defer func() {
|
||||
err := os.RemoveAll("test")
|
||||
if err != nil {
|
||||
b.Fatal(err)
|
||||
}
|
||||
}()
|
||||
defer s.Close()
|
||||
|
||||
CommonBenchmarkIndexBatch(b, s, 1, 100)
|
||||
|
@ -100,7 +135,12 @@ func BenchmarkBoltDBIndexing2Workers100Batch(b *testing.B) {
|
|||
if err != nil {
|
||||
b.Fatal(err)
|
||||
}
|
||||
defer os.RemoveAll("test")
|
||||
defer func() {
|
||||
err := os.RemoveAll("test")
|
||||
if err != nil {
|
||||
b.Fatal(err)
|
||||
}
|
||||
}()
|
||||
defer s.Close()
|
||||
|
||||
CommonBenchmarkIndexBatch(b, s, 2, 100)
|
||||
|
@ -111,7 +151,12 @@ func BenchmarkBoltDBIndexing4Workers100Batch(b *testing.B) {
|
|||
if err != nil {
|
||||
b.Fatal(err)
|
||||
}
|
||||
defer os.RemoveAll("test")
|
||||
defer func() {
|
||||
err := os.RemoveAll("test")
|
||||
if err != nil {
|
||||
b.Fatal(err)
|
||||
}
|
||||
}()
|
||||
defer s.Close()
|
||||
|
||||
CommonBenchmarkIndexBatch(b, s, 4, 100)
|
||||
|
|
|
@ -19,9 +19,17 @@ import (
|
|||
)
|
||||
|
||||
func BenchmarkForestDBIndexing1Workers(b *testing.B) {
|
||||
defer os.RemoveAll("testdir")
|
||||
defer func() {
|
||||
err := os.RemoveAll("testdir")
|
||||
if err != nil {
|
||||
b.Fatal(err)
|
||||
}
|
||||
}()
|
||||
|
||||
os.MkdirAll("testdir", 0700)
|
||||
err := os.MkdirAll("testdir", 0700)
|
||||
if err != nil {
|
||||
b.Fatal(err)
|
||||
}
|
||||
s, err := forestdb.Open("testdir/test", true, nil)
|
||||
if err != nil {
|
||||
b.Fatal(err)
|
||||
|
@ -32,9 +40,17 @@ func BenchmarkForestDBIndexing1Workers(b *testing.B) {
|
|||
}
|
||||
|
||||
func BenchmarkForestDBIndexing2Workers(b *testing.B) {
|
||||
defer os.RemoveAll("testdir")
|
||||
defer func() {
|
||||
err := os.RemoveAll("testdir")
|
||||
if err != nil {
|
||||
b.Fatal(err)
|
||||
}
|
||||
}()
|
||||
|
||||
os.MkdirAll("testdir", 0700)
|
||||
err := os.MkdirAll("testdir", 0700)
|
||||
if err != nil {
|
||||
b.Fatal(err)
|
||||
}
|
||||
s, err := forestdb.Open("testdir/test", true, nil)
|
||||
if err != nil {
|
||||
b.Fatal(err)
|
||||
|
@ -45,9 +61,17 @@ func BenchmarkForestDBIndexing2Workers(b *testing.B) {
|
|||
}
|
||||
|
||||
func BenchmarkForestDBIndexing4Workers(b *testing.B) {
|
||||
defer os.RemoveAll("testdir")
|
||||
defer func() {
|
||||
err := os.RemoveAll("testdir")
|
||||
if err != nil {
|
||||
b.Fatal(err)
|
||||
}
|
||||
}()
|
||||
|
||||
os.MkdirAll("testdir", 0700)
|
||||
err := os.MkdirAll("testdir", 0700)
|
||||
if err != nil {
|
||||
b.Fatal(err)
|
||||
}
|
||||
s, err := forestdb.Open("testdir/test", true, nil)
|
||||
if err != nil {
|
||||
b.Fatal(err)
|
||||
|
@ -60,9 +84,17 @@ func BenchmarkForestDBIndexing4Workers(b *testing.B) {
|
|||
// batches
|
||||
|
||||
func BenchmarkForestDBIndexing1Workers10Batch(b *testing.B) {
|
||||
defer os.RemoveAll("testdir")
|
||||
defer func() {
|
||||
err := os.RemoveAll("testdir")
|
||||
if err != nil {
|
||||
b.Fatal(err)
|
||||
}
|
||||
}()
|
||||
|
||||
os.MkdirAll("testdir", 0700)
|
||||
err := os.MkdirAll("testdir", 0700)
|
||||
if err != nil {
|
||||
b.Fatal(err)
|
||||
}
|
||||
s, err := forestdb.Open("testdir/test", true, nil)
|
||||
if err != nil {
|
||||
b.Fatal(err)
|
||||
|
@ -73,9 +105,17 @@ func BenchmarkForestDBIndexing1Workers10Batch(b *testing.B) {
|
|||
}
|
||||
|
||||
func BenchmarkForestDBIndexing2Workers10Batch(b *testing.B) {
|
||||
defer os.RemoveAll("testdir")
|
||||
defer func() {
|
||||
err := os.RemoveAll("testdir")
|
||||
if err != nil {
|
||||
b.Fatal(err)
|
||||
}
|
||||
}()
|
||||
|
||||
os.MkdirAll("testdir", 0700)
|
||||
err := os.MkdirAll("testdir", 0700)
|
||||
if err != nil {
|
||||
b.Fatal(err)
|
||||
}
|
||||
s, err := forestdb.Open("testdir/test", true, nil)
|
||||
if err != nil {
|
||||
b.Fatal(err)
|
||||
|
@ -86,9 +126,17 @@ func BenchmarkForestDBIndexing2Workers10Batch(b *testing.B) {
|
|||
}
|
||||
|
||||
func BenchmarkForestDBIndexing4Workers10Batch(b *testing.B) {
|
||||
defer os.RemoveAll("testdir")
|
||||
defer func() {
|
||||
err := os.RemoveAll("testdir")
|
||||
if err != nil {
|
||||
b.Fatal(err)
|
||||
}
|
||||
}()
|
||||
|
||||
os.MkdirAll("testdir", 0700)
|
||||
err := os.MkdirAll("testdir", 0700)
|
||||
if err != nil {
|
||||
b.Fatal(err)
|
||||
}
|
||||
s, err := forestdb.Open("testdir/test", true, nil)
|
||||
if err != nil {
|
||||
b.Fatal(err)
|
||||
|
@ -99,9 +147,17 @@ func BenchmarkForestDBIndexing4Workers10Batch(b *testing.B) {
|
|||
}
|
||||
|
||||
func BenchmarkForestDBIndexing1Workers100Batch(b *testing.B) {
|
||||
defer os.RemoveAll("testdir")
|
||||
defer func() {
|
||||
err := os.RemoveAll("testdir")
|
||||
if err != nil {
|
||||
b.Fatal(err)
|
||||
}
|
||||
}()
|
||||
|
||||
os.MkdirAll("testdir", 0700)
|
||||
err := os.MkdirAll("testdir", 0700)
|
||||
if err != nil {
|
||||
b.Fatal(err)
|
||||
}
|
||||
s, err := forestdb.Open("testdir/test", true, nil)
|
||||
if err != nil {
|
||||
b.Fatal(err)
|
||||
|
@ -112,9 +168,17 @@ func BenchmarkForestDBIndexing1Workers100Batch(b *testing.B) {
|
|||
}
|
||||
|
||||
func BenchmarkForestDBIndexing2Workers100Batch(b *testing.B) {
|
||||
defer os.RemoveAll("testdir")
|
||||
defer func() {
|
||||
err := os.RemoveAll("testdir")
|
||||
if err != nil {
|
||||
b.Fatal(err)
|
||||
}
|
||||
}()
|
||||
|
||||
os.MkdirAll("testdir", 0700)
|
||||
err := os.MkdirAll("testdir", 0700)
|
||||
if err != nil {
|
||||
b.Fatal(err)
|
||||
}
|
||||
s, err := forestdb.Open("testdir/test", true, nil)
|
||||
if err != nil {
|
||||
b.Fatal(err)
|
||||
|
@ -125,9 +189,17 @@ func BenchmarkForestDBIndexing2Workers100Batch(b *testing.B) {
|
|||
}
|
||||
|
||||
func BenchmarkForestDBIndexing4Workers100Batch(b *testing.B) {
|
||||
defer os.RemoveAll("testdir")
|
||||
defer func() {
|
||||
err := os.RemoveAll("testdir")
|
||||
if err != nil {
|
||||
b.Fatal(err)
|
||||
}
|
||||
}()
|
||||
|
||||
os.MkdirAll("testdir", 0700)
|
||||
err := os.MkdirAll("testdir", 0700)
|
||||
if err != nil {
|
||||
b.Fatal(err)
|
||||
}
|
||||
s, err := forestdb.Open("testdir/test", true, nil)
|
||||
if err != nil {
|
||||
b.Fatal(err)
|
||||
|
|
|
@ -27,7 +27,12 @@ func BenchmarkLevelDBIndexing1Workers(b *testing.B) {
|
|||
if err != nil {
|
||||
b.Fatal(err)
|
||||
}
|
||||
defer os.RemoveAll("test")
|
||||
defer func() {
|
||||
err := os.RemoveAll("test")
|
||||
if err != nil {
|
||||
b.Fatal(err)
|
||||
}
|
||||
}()
|
||||
defer s.Close()
|
||||
|
||||
CommonBenchmarkIndex(b, s, 1)
|
||||
|
@ -38,7 +43,12 @@ func BenchmarkLevelDBIndexing2Workers(b *testing.B) {
|
|||
if err != nil {
|
||||
b.Fatal(err)
|
||||
}
|
||||
defer os.RemoveAll("test")
|
||||
defer func() {
|
||||
err := os.RemoveAll("test")
|
||||
if err != nil {
|
||||
b.Fatal(err)
|
||||
}
|
||||
}()
|
||||
defer s.Close()
|
||||
|
||||
CommonBenchmarkIndex(b, s, 2)
|
||||
|
@ -49,7 +59,12 @@ func BenchmarkLevelDBIndexing4Workers(b *testing.B) {
|
|||
if err != nil {
|
||||
b.Fatal(err)
|
||||
}
|
||||
defer os.RemoveAll("test")
|
||||
defer func() {
|
||||
err := os.RemoveAll("test")
|
||||
if err != nil {
|
||||
b.Fatal(err)
|
||||
}
|
||||
}()
|
||||
defer s.Close()
|
||||
|
||||
CommonBenchmarkIndex(b, s, 4)
|
||||
|
@ -62,7 +77,12 @@ func BenchmarkLevelDBIndexing1Workers10Batch(b *testing.B) {
|
|||
if err != nil {
|
||||
b.Fatal(err)
|
||||
}
|
||||
defer os.RemoveAll("test")
|
||||
defer func() {
|
||||
err := os.RemoveAll("test")
|
||||
if err != nil {
|
||||
b.Fatal(err)
|
||||
}
|
||||
}()
|
||||
defer s.Close()
|
||||
|
||||
CommonBenchmarkIndexBatch(b, s, 1, 10)
|
||||
|
@ -73,7 +93,12 @@ func BenchmarkLevelDBIndexing2Workers10Batch(b *testing.B) {
|
|||
if err != nil {
|
||||
b.Fatal(err)
|
||||
}
|
||||
defer os.RemoveAll("test")
|
||||
defer func() {
|
||||
err := os.RemoveAll("test")
|
||||
if err != nil {
|
||||
b.Fatal(err)
|
||||
}
|
||||
}()
|
||||
defer s.Close()
|
||||
|
||||
CommonBenchmarkIndexBatch(b, s, 2, 10)
|
||||
|
@ -84,7 +109,12 @@ func BenchmarkLevelDBIndexing4Workers10Batch(b *testing.B) {
|
|||
if err != nil {
|
||||
b.Fatal(err)
|
||||
}
|
||||
defer os.RemoveAll("test")
|
||||
defer func() {
|
||||
err := os.RemoveAll("test")
|
||||
if err != nil {
|
||||
b.Fatal(err)
|
||||
}
|
||||
}()
|
||||
defer s.Close()
|
||||
|
||||
CommonBenchmarkIndexBatch(b, s, 4, 10)
|
||||
|
@ -95,7 +125,12 @@ func BenchmarkLevelDBIndexing1Workers100Batch(b *testing.B) {
|
|||
if err != nil {
|
||||
b.Fatal(err)
|
||||
}
|
||||
defer os.RemoveAll("test")
|
||||
defer func() {
|
||||
err := os.RemoveAll("test")
|
||||
if err != nil {
|
||||
b.Fatal(err)
|
||||
}
|
||||
}()
|
||||
defer s.Close()
|
||||
|
||||
CommonBenchmarkIndexBatch(b, s, 1, 100)
|
||||
|
@ -106,7 +141,12 @@ func BenchmarkLevelDBIndexing2Workers100Batch(b *testing.B) {
|
|||
if err != nil {
|
||||
b.Fatal(err)
|
||||
}
|
||||
defer os.RemoveAll("test")
|
||||
defer func() {
|
||||
err := os.RemoveAll("test")
|
||||
if err != nil {
|
||||
b.Fatal(err)
|
||||
}
|
||||
}()
|
||||
defer s.Close()
|
||||
|
||||
CommonBenchmarkIndexBatch(b, s, 2, 100)
|
||||
|
@ -117,7 +157,12 @@ func BenchmarkLevelDBIndexing4Workers100Batch(b *testing.B) {
|
|||
if err != nil {
|
||||
b.Fatal(err)
|
||||
}
|
||||
defer os.RemoveAll("test")
|
||||
defer func() {
|
||||
err := os.RemoveAll("test")
|
||||
if err != nil {
|
||||
b.Fatal(err)
|
||||
}
|
||||
}()
|
||||
defer s.Close()
|
||||
|
||||
CommonBenchmarkIndexBatch(b, s, 4, 100)
|
||||
|
@ -128,7 +173,12 @@ func BenchmarkLevelDBIndexing1Workers1000Batch(b *testing.B) {
|
|||
if err != nil {
|
||||
b.Fatal(err)
|
||||
}
|
||||
defer os.RemoveAll("test")
|
||||
defer func() {
|
||||
err := os.RemoveAll("test")
|
||||
if err != nil {
|
||||
b.Fatal(err)
|
||||
}
|
||||
}()
|
||||
defer s.Close()
|
||||
|
||||
CommonBenchmarkIndexBatch(b, s, 1, 1000)
|
||||
|
@ -139,7 +189,12 @@ func BenchmarkLevelDBIndexing2Workers1000Batch(b *testing.B) {
|
|||
if err != nil {
|
||||
b.Fatal(err)
|
||||
}
|
||||
defer os.RemoveAll("test")
|
||||
defer func() {
|
||||
err := os.RemoveAll("test")
|
||||
if err != nil {
|
||||
b.Fatal(err)
|
||||
}
|
||||
}()
|
||||
defer s.Close()
|
||||
|
||||
CommonBenchmarkIndexBatch(b, s, 2, 1000)
|
||||
|
@ -150,7 +205,12 @@ func BenchmarkLevelDBIndexing4Workers1000Batch(b *testing.B) {
|
|||
if err != nil {
|
||||
b.Fatal(err)
|
||||
}
|
||||
defer os.RemoveAll("test")
|
||||
defer func() {
|
||||
err := os.RemoveAll("test")
|
||||
if err != nil {
|
||||
b.Fatal(err)
|
||||
}
|
||||
}()
|
||||
defer s.Close()
|
||||
|
||||
CommonBenchmarkIndexBatch(b, s, 4, 1000)
|
||||
|
|
|
@ -19,7 +19,12 @@ import (
|
|||
)
|
||||
|
||||
func TestDump(t *testing.T) {
|
||||
defer os.RemoveAll("test")
|
||||
defer func() {
|
||||
err := os.RemoveAll("test")
|
||||
if err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
}()
|
||||
|
||||
store, err := boltdb.Open("test", "bleve")
|
||||
if err != nil {
|
||||
|
|
|
@ -19,7 +19,12 @@ import (
|
|||
)
|
||||
|
||||
func TestIndexFieldDict(t *testing.T) {
|
||||
defer os.RemoveAll("test")
|
||||
defer func() {
|
||||
err := os.RemoveAll("test")
|
||||
if err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
}()
|
||||
|
||||
store, err := boltdb.Open("test", "bleve")
|
||||
analysisQueue := NewAnalysisQueue(1)
|
||||
|
|
|
@ -20,7 +20,12 @@ import (
|
|||
)
|
||||
|
||||
func TestIndexReader(t *testing.T) {
|
||||
defer os.RemoveAll("test")
|
||||
defer func() {
|
||||
err := os.RemoveAll("test")
|
||||
if err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
}()
|
||||
|
||||
store, err := boltdb.Open("test", "bleve")
|
||||
analysisQueue := NewAnalysisQueue(1)
|
||||
|
@ -178,7 +183,12 @@ func TestIndexReader(t *testing.T) {
|
|||
}
|
||||
|
||||
func TestIndexDocIdReader(t *testing.T) {
|
||||
defer os.RemoveAll("test")
|
||||
defer func() {
|
||||
err := os.RemoveAll("test")
|
||||
if err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
}()
|
||||
|
||||
store, err := boltdb.Open("test", "bleve")
|
||||
analysisQueue := NewAnalysisQueue(1)
|
||||
|
|
|
@ -28,7 +28,12 @@ var testAnalyzer = &analysis.Analyzer{
|
|||
}
|
||||
|
||||
func TestIndexOpenReopen(t *testing.T) {
|
||||
defer os.RemoveAll("test")
|
||||
defer func() {
|
||||
err := os.RemoveAll("test")
|
||||
if err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
}()
|
||||
|
||||
store, err := boltdb.Open("test", "bleve")
|
||||
analysisQueue := NewAnalysisQueue(1)
|
||||
|
@ -81,7 +86,12 @@ func TestIndexOpenReopen(t *testing.T) {
|
|||
}
|
||||
|
||||
func TestIndexInsert(t *testing.T) {
|
||||
defer os.RemoveAll("test")
|
||||
defer func() {
|
||||
err := os.RemoveAll("test")
|
||||
if err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
}()
|
||||
|
||||
store, err := boltdb.Open("test", "bleve")
|
||||
analysisQueue := NewAnalysisQueue(1)
|
||||
|
@ -129,7 +139,12 @@ func TestIndexInsert(t *testing.T) {
|
|||
}
|
||||
|
||||
func TestIndexInsertThenDelete(t *testing.T) {
|
||||
defer os.RemoveAll("test")
|
||||
defer func() {
|
||||
err := os.RemoveAll("test")
|
||||
if err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
}()
|
||||
|
||||
store, err := boltdb.Open("test", "bleve")
|
||||
analysisQueue := NewAnalysisQueue(1)
|
||||
|
@ -213,7 +228,12 @@ func TestIndexInsertThenDelete(t *testing.T) {
|
|||
}
|
||||
|
||||
func TestIndexInsertThenUpdate(t *testing.T) {
|
||||
defer os.RemoveAll("test")
|
||||
defer func() {
|
||||
err := os.RemoveAll("test")
|
||||
if err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
}()
|
||||
|
||||
store, err := boltdb.Open("test", "bleve")
|
||||
analysisQueue := NewAnalysisQueue(1)
|
||||
|
@ -269,7 +289,12 @@ func TestIndexInsertThenUpdate(t *testing.T) {
|
|||
}
|
||||
|
||||
func TestIndexInsertMultiple(t *testing.T) {
|
||||
defer os.RemoveAll("test")
|
||||
defer func() {
|
||||
err := os.RemoveAll("test")
|
||||
if err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
}()
|
||||
|
||||
store, err := boltdb.Open("test", "bleve")
|
||||
analysisQueue := NewAnalysisQueue(1)
|
||||
|
@ -339,7 +364,12 @@ func TestIndexInsertMultiple(t *testing.T) {
|
|||
}
|
||||
|
||||
func TestIndexInsertWithStore(t *testing.T) {
|
||||
defer os.RemoveAll("test")
|
||||
defer func() {
|
||||
err := os.RemoveAll("test")
|
||||
if err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
}()
|
||||
|
||||
store, err := boltdb.Open("test", "bleve")
|
||||
if err != nil {
|
||||
|
@ -412,7 +442,12 @@ func TestIndexInsertWithStore(t *testing.T) {
|
|||
}
|
||||
|
||||
func TestIndexInternalCRUD(t *testing.T) {
|
||||
defer os.RemoveAll("test")
|
||||
defer func() {
|
||||
err := os.RemoveAll("test")
|
||||
if err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
}()
|
||||
|
||||
store, err := boltdb.Open("test", "bleve")
|
||||
analysisQueue := NewAnalysisQueue(1)
|
||||
|
@ -482,7 +517,12 @@ func TestIndexInternalCRUD(t *testing.T) {
|
|||
}
|
||||
|
||||
func TestIndexBatch(t *testing.T) {
|
||||
defer os.RemoveAll("test")
|
||||
defer func() {
|
||||
err := os.RemoveAll("test")
|
||||
if err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
}()
|
||||
|
||||
store, err := boltdb.Open("test", "bleve")
|
||||
analysisQueue := NewAnalysisQueue(1)
|
||||
|
@ -563,7 +603,12 @@ func TestIndexBatch(t *testing.T) {
|
|||
}
|
||||
|
||||
func TestIndexInsertUpdateDeleteWithMultipleTypesStored(t *testing.T) {
|
||||
defer os.RemoveAll("test")
|
||||
defer func() {
|
||||
err := os.RemoveAll("test")
|
||||
if err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
}()
|
||||
|
||||
store, err := boltdb.Open("test", "bleve")
|
||||
if err != nil {
|
||||
|
@ -739,7 +784,12 @@ func TestIndexInsertUpdateDeleteWithMultipleTypesStored(t *testing.T) {
|
|||
}
|
||||
|
||||
func TestIndexInsertFields(t *testing.T) {
|
||||
defer os.RemoveAll("test")
|
||||
defer func() {
|
||||
err := os.RemoveAll("test")
|
||||
if err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
}()
|
||||
|
||||
store, err := boltdb.Open("test", "bleve")
|
||||
if err != nil {
|
||||
|
@ -785,7 +835,12 @@ func TestIndexInsertFields(t *testing.T) {
|
|||
}
|
||||
|
||||
func TestIndexUpdateComposites(t *testing.T) {
|
||||
defer os.RemoveAll("test")
|
||||
defer func() {
|
||||
err := os.RemoveAll("test")
|
||||
if err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
}()
|
||||
|
||||
store, err := boltdb.Open("test", "bleve")
|
||||
if err != nil {
|
||||
|
@ -867,7 +922,12 @@ func TestIndexUpdateComposites(t *testing.T) {
|
|||
}
|
||||
|
||||
func TestIndexFieldsMisc(t *testing.T) {
|
||||
defer os.RemoveAll("test")
|
||||
defer func() {
|
||||
err := os.RemoveAll("test")
|
||||
if err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
}()
|
||||
|
||||
store, err := boltdb.Open("test", "bleve")
|
||||
if err != nil {
|
||||
|
@ -905,7 +965,12 @@ func TestIndexFieldsMisc(t *testing.T) {
|
|||
}
|
||||
|
||||
func TestIndexTermReaderCompositeFields(t *testing.T) {
|
||||
defer os.RemoveAll("test")
|
||||
defer func() {
|
||||
err := os.RemoveAll("test")
|
||||
if err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
}()
|
||||
|
||||
store, err := boltdb.Open("test", "bleve")
|
||||
if err != nil {
|
||||
|
@ -952,7 +1017,12 @@ func TestIndexTermReaderCompositeFields(t *testing.T) {
|
|||
}
|
||||
|
||||
func TestIndexDocumentFieldTerms(t *testing.T) {
|
||||
defer os.RemoveAll("test")
|
||||
defer func() {
|
||||
err := os.RemoveAll("test")
|
||||
if err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
}()
|
||||
|
||||
store, err := boltdb.Open("test", "bleve")
|
||||
if err != nil {
|
||||
|
|
|
@ -16,7 +16,12 @@ import (
|
|||
|
||||
func TestIndexMeta(t *testing.T) {
|
||||
var testIndexPath = "doesnotexit.bleve"
|
||||
defer os.RemoveAll(testIndexPath)
|
||||
defer func() {
|
||||
err := os.RemoveAll(testIndexPath)
|
||||
if err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
}()
|
||||
|
||||
// open non-existent meta should give an error
|
||||
_, err := openIndexMeta(testIndexPath)
|
||||
|
|
|
@ -19,7 +19,12 @@ import (
|
|||
)
|
||||
|
||||
func TestCrud(t *testing.T) {
|
||||
defer os.RemoveAll("testidx")
|
||||
defer func() {
|
||||
err := os.RemoveAll("testidx")
|
||||
if err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
}()
|
||||
|
||||
index, err := New("testidx", NewIndexMapping())
|
||||
if err != nil {
|
||||
|
@ -182,7 +187,12 @@ func TestCrud(t *testing.T) {
|
|||
}
|
||||
|
||||
func TestIndexCreateNewOverExisting(t *testing.T) {
|
||||
defer os.RemoveAll("testidx")
|
||||
defer func() {
|
||||
err := os.RemoveAll("testidx")
|
||||
if err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
}()
|
||||
|
||||
index, err := New("testidx", NewIndexMapping())
|
||||
if err != nil {
|
||||
|
@ -206,7 +216,12 @@ func TestIndexOpenNonExisting(t *testing.T) {
|
|||
}
|
||||
|
||||
func TestIndexOpenMetaMissingOrCorrupt(t *testing.T) {
|
||||
defer os.RemoveAll("testidx")
|
||||
defer func() {
|
||||
err := os.RemoveAll("testidx")
|
||||
if err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
}()
|
||||
|
||||
index, err := New("testidx", NewIndexMapping())
|
||||
if err != nil {
|
||||
|
@ -311,7 +326,12 @@ func TestClosedIndex(t *testing.T) {
|
|||
}
|
||||
|
||||
func TestSlowSearch(t *testing.T) {
|
||||
defer os.RemoveAll("testidx")
|
||||
defer func() {
|
||||
err := os.RemoveAll("testidx")
|
||||
if err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
}()
|
||||
|
||||
defer func() {
|
||||
// reset logger back to normal
|
||||
|
@ -361,7 +381,12 @@ func (s *sawDataWriter) Write(p []byte) (n int, err error) {
|
|||
}
|
||||
|
||||
func TestStoredFieldPreserved(t *testing.T) {
|
||||
defer os.RemoveAll("testidx")
|
||||
defer func() {
|
||||
err := os.RemoveAll("testidx")
|
||||
if err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
}()
|
||||
|
||||
index, err := New("testidx", NewIndexMapping())
|
||||
if err != nil {
|
||||
|
@ -400,7 +425,12 @@ func TestStoredFieldPreserved(t *testing.T) {
|
|||
}
|
||||
|
||||
func TestDict(t *testing.T) {
|
||||
defer os.RemoveAll("testidx")
|
||||
defer func() {
|
||||
err := os.RemoveAll("testidx")
|
||||
if err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
}()
|
||||
|
||||
index, err := New("testidx", NewIndexMapping())
|
||||
if err != nil {
|
||||
|
|
|
@ -71,7 +71,12 @@ func runTestDir(t *testing.T, dir string) {
|
|||
|
||||
// open new index
|
||||
if !*keepIndex {
|
||||
defer os.RemoveAll("test.bleve")
|
||||
defer func() {
|
||||
err := os.RemoveAll("test.bleve")
|
||||
if err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
}()
|
||||
}
|
||||
index, err := bleve.New("test.bleve", &mapping)
|
||||
if err != nil {
|
||||
|
|
Loading…
Reference in New Issue