more golint cleanups
This commit is contained in:
parent
377ae090d0
commit
e1b77956d4
@ -55,7 +55,7 @@ func IndexNames() []string {
|
|||||||
|
|
||||||
rv := make([]string, len(indexNameMapping))
|
rv := make([]string, len(indexNameMapping))
|
||||||
count := 0
|
count := 0
|
||||||
for k, _ := range indexNameMapping {
|
for k := range indexNameMapping {
|
||||||
rv[count] = k
|
rv[count] = k
|
||||||
count++
|
count++
|
||||||
}
|
}
|
||||||
|
@ -50,7 +50,7 @@ func Open(path string, bucket string) (*BoltDBStore, error) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func (bs *BoltDBStore) Get(key []byte) ([]byte, error) {
|
func (bs *BoltDBStore) Get(key []byte) ([]byte, error) {
|
||||||
var rv []byte = nil
|
var rv []byte
|
||||||
|
|
||||||
err := bs.db.View(func(tx *bolt.Tx) error {
|
err := bs.db.View(func(tx *bolt.Tx) error {
|
||||||
rv = tx.Bucket([]byte(bs.bucket)).Get(key)
|
rv = tx.Bucket([]byte(bs.bucket)).Get(key)
|
||||||
|
@ -32,7 +32,7 @@ func TestDump(t *testing.T) {
|
|||||||
}
|
}
|
||||||
defer idx.Close()
|
defer idx.Close()
|
||||||
|
|
||||||
var expectedCount uint64 = 0
|
var expectedCount uint64
|
||||||
docCount := idx.DocCount()
|
docCount := idx.DocCount()
|
||||||
if docCount != expectedCount {
|
if docCount != expectedCount {
|
||||||
t.Errorf("Expected document count to be %d got %d", expectedCount, docCount)
|
t.Errorf("Expected document count to be %d got %d", expectedCount, docCount)
|
||||||
|
@ -29,14 +29,14 @@ func TestIndexFieldReader(t *testing.T) {
|
|||||||
}
|
}
|
||||||
defer idx.Close()
|
defer idx.Close()
|
||||||
|
|
||||||
var expectedCount uint64 = 0
|
var expectedCount uint64
|
||||||
doc := document.NewDocument("1")
|
doc := document.NewDocument("1")
|
||||||
doc.AddField(document.NewTextField("name", []uint64{}, []byte("test")))
|
doc.AddField(document.NewTextField("name", []uint64{}, []byte("test")))
|
||||||
err = idx.Update(doc)
|
err = idx.Update(doc)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
t.Errorf("Error updating index: %v", err)
|
t.Errorf("Error updating index: %v", err)
|
||||||
}
|
}
|
||||||
expectedCount += 1
|
expectedCount++
|
||||||
|
|
||||||
doc = document.NewDocument("2")
|
doc = document.NewDocument("2")
|
||||||
doc.AddField(document.NewTextFieldWithAnalyzer("name", []uint64{}, []byte("test test test"), testAnalyzer))
|
doc.AddField(document.NewTextFieldWithAnalyzer("name", []uint64{}, []byte("test test test"), testAnalyzer))
|
||||||
@ -46,7 +46,7 @@ func TestIndexFieldReader(t *testing.T) {
|
|||||||
if err != nil {
|
if err != nil {
|
||||||
t.Errorf("Error updating index: %v", err)
|
t.Errorf("Error updating index: %v", err)
|
||||||
}
|
}
|
||||||
expectedCount += 1
|
expectedCount++
|
||||||
|
|
||||||
reader, err := idx.FieldReader("name", nil, nil)
|
reader, err := idx.FieldReader("name", nil, nil)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
@ -28,7 +28,7 @@ func newUpsideDownCouchTermFieldReader(index *UpsideDownCouch, term []byte, fiel
|
|||||||
tfr := NewTermFrequencyRow(term, field, "", 0, 0)
|
tfr := NewTermFrequencyRow(term, field, "", 0, 0)
|
||||||
it := index.store.Iterator(tfr.Key())
|
it := index.store.Iterator(tfr.Key())
|
||||||
|
|
||||||
var count uint64 = 0
|
var count uint64
|
||||||
key, val, valid := it.Current()
|
key, val, valid := it.Current()
|
||||||
if valid {
|
if valid {
|
||||||
if bytes.Equal(key, tfr.Key()) {
|
if bytes.Equal(key, tfr.Key()) {
|
||||||
@ -72,9 +72,8 @@ func (r *UpsideDownCouchTermFieldReader) Next() (*index.TermFieldDoc, error) {
|
|||||||
Norm: float64(tfr.norm),
|
Norm: float64(tfr.norm),
|
||||||
Vectors: r.index.termFieldVectorsFromTermVectors(tfr.vectors),
|
Vectors: r.index.termFieldVectorsFromTermVectors(tfr.vectors),
|
||||||
}, nil
|
}, nil
|
||||||
} else {
|
|
||||||
return nil, nil
|
|
||||||
}
|
}
|
||||||
|
return nil, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func (r *UpsideDownCouchTermFieldReader) Advance(docId string) (*index.TermFieldDoc, error) {
|
func (r *UpsideDownCouchTermFieldReader) Advance(docId string) (*index.TermFieldDoc, error) {
|
||||||
@ -97,9 +96,8 @@ func (r *UpsideDownCouchTermFieldReader) Advance(docId string) (*index.TermField
|
|||||||
Norm: float64(tfr.norm),
|
Norm: float64(tfr.norm),
|
||||||
Vectors: r.index.termFieldVectorsFromTermVectors(tfr.vectors),
|
Vectors: r.index.termFieldVectorsFromTermVectors(tfr.vectors),
|
||||||
}, nil
|
}, nil
|
||||||
} else {
|
|
||||||
return nil, nil
|
|
||||||
}
|
}
|
||||||
|
return nil, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func (r *UpsideDownCouchTermFieldReader) Close() {
|
func (r *UpsideDownCouchTermFieldReader) Close() {
|
||||||
@ -145,9 +143,8 @@ func (r *UpsideDownCouchDocIdReader) Next() (string, error) {
|
|||||||
}
|
}
|
||||||
r.iterator.Next()
|
r.iterator.Next()
|
||||||
return string(br.doc), nil
|
return string(br.doc), nil
|
||||||
} else {
|
|
||||||
return "", nil
|
|
||||||
}
|
}
|
||||||
|
return "", nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func (r *UpsideDownCouchDocIdReader) Advance(docId string) (string, error) {
|
func (r *UpsideDownCouchDocIdReader) Advance(docId string) (string, error) {
|
||||||
@ -166,9 +163,8 @@ func (r *UpsideDownCouchDocIdReader) Advance(docId string) (string, error) {
|
|||||||
}
|
}
|
||||||
r.iterator.Next()
|
r.iterator.Next()
|
||||||
return string(br.doc), nil
|
return string(br.doc), nil
|
||||||
} else {
|
|
||||||
return "", nil
|
|
||||||
}
|
}
|
||||||
|
return "", nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func (r *UpsideDownCouchDocIdReader) Close() {
|
func (r *UpsideDownCouchDocIdReader) Close() {
|
||||||
|
@ -30,14 +30,14 @@ func TestIndexReader(t *testing.T) {
|
|||||||
}
|
}
|
||||||
defer idx.Close()
|
defer idx.Close()
|
||||||
|
|
||||||
var expectedCount uint64 = 0
|
var expectedCount uint64
|
||||||
doc := document.NewDocument("1")
|
doc := document.NewDocument("1")
|
||||||
doc.AddField(document.NewTextField("name", []uint64{}, []byte("test")))
|
doc.AddField(document.NewTextField("name", []uint64{}, []byte("test")))
|
||||||
err = idx.Update(doc)
|
err = idx.Update(doc)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
t.Errorf("Error updating index: %v", err)
|
t.Errorf("Error updating index: %v", err)
|
||||||
}
|
}
|
||||||
expectedCount += 1
|
expectedCount++
|
||||||
|
|
||||||
doc = document.NewDocument("2")
|
doc = document.NewDocument("2")
|
||||||
doc.AddField(document.NewTextFieldWithAnalyzer("name", []uint64{}, []byte("test test test"), testAnalyzer))
|
doc.AddField(document.NewTextFieldWithAnalyzer("name", []uint64{}, []byte("test test test"), testAnalyzer))
|
||||||
@ -46,7 +46,7 @@ func TestIndexReader(t *testing.T) {
|
|||||||
if err != nil {
|
if err != nil {
|
||||||
t.Errorf("Error updating index: %v", err)
|
t.Errorf("Error updating index: %v", err)
|
||||||
}
|
}
|
||||||
expectedCount += 1
|
expectedCount++
|
||||||
|
|
||||||
// first look for a term that doesnt exist
|
// first look for a term that doesnt exist
|
||||||
reader, err := idx.TermFieldReader([]byte("nope"), "name")
|
reader, err := idx.TermFieldReader([]byte("nope"), "name")
|
||||||
@ -78,7 +78,7 @@ func TestIndexReader(t *testing.T) {
|
|||||||
if err != nil {
|
if err != nil {
|
||||||
t.Errorf("unexpected error reading next")
|
t.Errorf("unexpected error reading next")
|
||||||
}
|
}
|
||||||
actualCount += 1
|
actualCount++
|
||||||
}
|
}
|
||||||
if actualCount != count {
|
if actualCount != count {
|
||||||
t.Errorf("count was 2, but only saw %d", actualCount)
|
t.Errorf("count was 2, but only saw %d", actualCount)
|
||||||
@ -172,14 +172,14 @@ func TestIndexDocIdReader(t *testing.T) {
|
|||||||
}
|
}
|
||||||
defer idx.Close()
|
defer idx.Close()
|
||||||
|
|
||||||
var expectedCount uint64 = 0
|
var expectedCount uint64
|
||||||
doc := document.NewDocument("1")
|
doc := document.NewDocument("1")
|
||||||
doc.AddField(document.NewTextField("name", []uint64{}, []byte("test")))
|
doc.AddField(document.NewTextField("name", []uint64{}, []byte("test")))
|
||||||
err = idx.Update(doc)
|
err = idx.Update(doc)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
t.Errorf("Error updating index: %v", err)
|
t.Errorf("Error updating index: %v", err)
|
||||||
}
|
}
|
||||||
expectedCount += 1
|
expectedCount++
|
||||||
|
|
||||||
doc = document.NewDocument("2")
|
doc = document.NewDocument("2")
|
||||||
doc.AddField(document.NewTextField("name", []uint64{}, []byte("test test test")))
|
doc.AddField(document.NewTextField("name", []uint64{}, []byte("test test test")))
|
||||||
@ -188,7 +188,7 @@ func TestIndexDocIdReader(t *testing.T) {
|
|||||||
if err != nil {
|
if err != nil {
|
||||||
t.Errorf("Error updating index: %v", err)
|
t.Errorf("Error updating index: %v", err)
|
||||||
}
|
}
|
||||||
expectedCount += 1
|
expectedCount++
|
||||||
|
|
||||||
// first get all doc ids
|
// first get all doc ids
|
||||||
reader, err := idx.DocIdReader("", "")
|
reader, err := idx.DocIdReader("", "")
|
||||||
|
@ -65,7 +65,7 @@ func (p PrefixCoded) Int64() (int64, error) {
|
|||||||
if err != nil {
|
if err != nil {
|
||||||
return 0, err
|
return 0, err
|
||||||
}
|
}
|
||||||
var sortableBits int64 = 0
|
var sortableBits int64
|
||||||
for _, inbyte := range p[1:] {
|
for _, inbyte := range p[1:] {
|
||||||
sortableBits <<= 7
|
sortableBits <<= 7
|
||||||
sortableBits |= int64(inbyte)
|
sortableBits |= int64(inbyte)
|
||||||
|
@ -178,7 +178,7 @@ func (c *Cache) DefineHighlighter(name string, config map[string]interface{}) (h
|
|||||||
|
|
||||||
func PrintRegistry() {
|
func PrintRegistry() {
|
||||||
sorted := make(sort.StringSlice, 0, len(charFilters))
|
sorted := make(sort.StringSlice, 0, len(charFilters))
|
||||||
for name, _ := range charFilters {
|
for name := range charFilters {
|
||||||
sorted = append(sorted, name)
|
sorted = append(sorted, name)
|
||||||
}
|
}
|
||||||
sorted.Sort()
|
sorted.Sort()
|
||||||
@ -189,7 +189,7 @@ func PrintRegistry() {
|
|||||||
fmt.Println()
|
fmt.Println()
|
||||||
|
|
||||||
sorted = make(sort.StringSlice, 0, len(tokenizers))
|
sorted = make(sort.StringSlice, 0, len(tokenizers))
|
||||||
for name, _ := range tokenizers {
|
for name := range tokenizers {
|
||||||
sorted = append(sorted, name)
|
sorted = append(sorted, name)
|
||||||
}
|
}
|
||||||
sorted.Sort()
|
sorted.Sort()
|
||||||
@ -200,7 +200,7 @@ func PrintRegistry() {
|
|||||||
fmt.Println()
|
fmt.Println()
|
||||||
|
|
||||||
sorted = make(sort.StringSlice, 0, len(tokenMaps))
|
sorted = make(sort.StringSlice, 0, len(tokenMaps))
|
||||||
for name, _ := range tokenMaps {
|
for name := range tokenMaps {
|
||||||
sorted = append(sorted, name)
|
sorted = append(sorted, name)
|
||||||
}
|
}
|
||||||
sorted.Sort()
|
sorted.Sort()
|
||||||
@ -211,7 +211,7 @@ func PrintRegistry() {
|
|||||||
fmt.Println()
|
fmt.Println()
|
||||||
|
|
||||||
sorted = make(sort.StringSlice, 0, len(tokenFilters))
|
sorted = make(sort.StringSlice, 0, len(tokenFilters))
|
||||||
for name, _ := range tokenFilters {
|
for name := range tokenFilters {
|
||||||
sorted = append(sorted, name)
|
sorted = append(sorted, name)
|
||||||
}
|
}
|
||||||
sorted.Sort()
|
sorted.Sort()
|
||||||
@ -222,7 +222,7 @@ func PrintRegistry() {
|
|||||||
fmt.Println()
|
fmt.Println()
|
||||||
|
|
||||||
sorted = make(sort.StringSlice, 0, len(analyzers))
|
sorted = make(sort.StringSlice, 0, len(analyzers))
|
||||||
for name, _ := range analyzers {
|
for name := range analyzers {
|
||||||
sorted = append(sorted, name)
|
sorted = append(sorted, name)
|
||||||
}
|
}
|
||||||
sorted.Sort()
|
sorted.Sort()
|
||||||
@ -233,7 +233,7 @@ func PrintRegistry() {
|
|||||||
fmt.Println()
|
fmt.Println()
|
||||||
|
|
||||||
sorted = make(sort.StringSlice, 0, len(dateTimeParsers))
|
sorted = make(sort.StringSlice, 0, len(dateTimeParsers))
|
||||||
for name, _ := range dateTimeParsers {
|
for name := range dateTimeParsers {
|
||||||
sorted = append(sorted, name)
|
sorted = append(sorted, name)
|
||||||
}
|
}
|
||||||
sorted.Sort()
|
sorted.Sort()
|
||||||
@ -244,7 +244,7 @@ func PrintRegistry() {
|
|||||||
fmt.Println()
|
fmt.Println()
|
||||||
|
|
||||||
sorted = make(sort.StringSlice, 0, len(stores))
|
sorted = make(sort.StringSlice, 0, len(stores))
|
||||||
for name, _ := range stores {
|
for name := range stores {
|
||||||
sorted = append(sorted, name)
|
sorted = append(sorted, name)
|
||||||
}
|
}
|
||||||
sorted.Sort()
|
sorted.Sort()
|
||||||
@ -255,7 +255,7 @@ func PrintRegistry() {
|
|||||||
fmt.Println()
|
fmt.Println()
|
||||||
|
|
||||||
sorted = make(sort.StringSlice, 0, len(byteArrayConverters))
|
sorted = make(sort.StringSlice, 0, len(byteArrayConverters))
|
||||||
for name, _ := range byteArrayConverters {
|
for name := range byteArrayConverters {
|
||||||
sorted = append(sorted, name)
|
sorted = append(sorted, name)
|
||||||
}
|
}
|
||||||
sorted.Sort()
|
sorted.Sort()
|
||||||
@ -266,7 +266,7 @@ func PrintRegistry() {
|
|||||||
fmt.Println()
|
fmt.Println()
|
||||||
|
|
||||||
sorted = make(sort.StringSlice, 0, len(fragmentFormatters))
|
sorted = make(sort.StringSlice, 0, len(fragmentFormatters))
|
||||||
for name, _ := range fragmentFormatters {
|
for name := range fragmentFormatters {
|
||||||
sorted = append(sorted, name)
|
sorted = append(sorted, name)
|
||||||
}
|
}
|
||||||
sorted.Sort()
|
sorted.Sort()
|
||||||
@ -277,7 +277,7 @@ func PrintRegistry() {
|
|||||||
fmt.Println()
|
fmt.Println()
|
||||||
|
|
||||||
sorted = make(sort.StringSlice, 0, len(fragmenters))
|
sorted = make(sort.StringSlice, 0, len(fragmenters))
|
||||||
for name, _ := range fragmenters {
|
for name := range fragmenters {
|
||||||
sorted = append(sorted, name)
|
sorted = append(sorted, name)
|
||||||
}
|
}
|
||||||
sorted.Sort()
|
sorted.Sort()
|
||||||
@ -288,7 +288,7 @@ func PrintRegistry() {
|
|||||||
fmt.Println()
|
fmt.Println()
|
||||||
|
|
||||||
sorted = make(sort.StringSlice, 0, len(highlighters))
|
sorted = make(sort.StringSlice, 0, len(highlighters))
|
||||||
for name, _ := range highlighters {
|
for name := range highlighters {
|
||||||
sorted = append(sorted, name)
|
sorted = append(sorted, name)
|
||||||
}
|
}
|
||||||
sorted.Sort()
|
sorted.Sort()
|
||||||
|
@ -74,7 +74,7 @@ func (tksc *TopScoreCollector) Collect(searcher search.Searcher) error {
|
|||||||
|
|
||||||
func (tksc *TopScoreCollector) collectSingle(dm *search.DocumentMatch) {
|
func (tksc *TopScoreCollector) collectSingle(dm *search.DocumentMatch) {
|
||||||
// increment total hits
|
// increment total hits
|
||||||
tksc.total += 1
|
tksc.total++
|
||||||
|
|
||||||
// update max score
|
// update max score
|
||||||
if dm.Score > tksc.maxScore {
|
if dm.Score > tksc.maxScore {
|
||||||
@ -127,7 +127,6 @@ func (tksc *TopScoreCollector) SetFacetsBuilder(facetsBuilder *search.FacetsBuil
|
|||||||
func (tksc *TopScoreCollector) FacetResults() search.FacetResults {
|
func (tksc *TopScoreCollector) FacetResults() search.FacetResults {
|
||||||
if tksc.facetsBuilder != nil {
|
if tksc.facetsBuilder != nil {
|
||||||
return tksc.facetsBuilder.Results()
|
return tksc.facetsBuilder.Results()
|
||||||
} else {
|
|
||||||
return search.FacetResults{}
|
|
||||||
}
|
}
|
||||||
|
return search.FacetResults{}
|
||||||
}
|
}
|
||||||
|
@ -17,8 +17,8 @@ import (
|
|||||||
|
|
||||||
const Name = "html"
|
const Name = "html"
|
||||||
|
|
||||||
const defaultHtmlHighlightBefore = "<b>"
|
const defaultHTMLHighlightBefore = "<b>"
|
||||||
const defaultHtmlHighlightAfter = "</b>"
|
const defaultHTMLHighlightAfter = "</b>"
|
||||||
|
|
||||||
type HTMLFragmentFormatter struct {
|
type HTMLFragmentFormatter struct {
|
||||||
before string
|
before string
|
||||||
@ -61,12 +61,12 @@ func (a *HTMLFragmentFormatter) Format(f *highlight.Fragment, tlm search.TermLoc
|
|||||||
}
|
}
|
||||||
|
|
||||||
func Constructor(config map[string]interface{}, cache *registry.Cache) (highlight.FragmentFormatter, error) {
|
func Constructor(config map[string]interface{}, cache *registry.Cache) (highlight.FragmentFormatter, error) {
|
||||||
before := defaultHtmlHighlightBefore
|
before := defaultHTMLHighlightBefore
|
||||||
beforeVal, ok := config["before"].(string)
|
beforeVal, ok := config["before"].(string)
|
||||||
if ok {
|
if ok {
|
||||||
before = beforeVal
|
before = beforeVal
|
||||||
}
|
}
|
||||||
after := defaultHtmlHighlightAfter
|
after := defaultHTMLHighlightAfter
|
||||||
afterVal, ok := config["after"].(string)
|
afterVal, ok := config["after"].(string)
|
||||||
if ok {
|
if ok {
|
||||||
after = afterVal
|
after = afterVal
|
||||||
|
@ -41,9 +41,9 @@ func TestHTMLFragmentFormatter1(t *testing.T) {
|
|||||||
},
|
},
|
||||||
}
|
}
|
||||||
|
|
||||||
emHtmlFormatter := NewHTMLFragmentFormatter("<b>", "</b>")
|
emHTMLFormatter := NewHTMLFragmentFormatter("<b>", "</b>")
|
||||||
for _, test := range tests {
|
for _, test := range tests {
|
||||||
result := emHtmlFormatter.Format(test.fragment, test.tlm)
|
result := emHTMLFormatter.Format(test.fragment, test.tlm)
|
||||||
if result != test.output {
|
if result != test.output {
|
||||||
t.Errorf("expected `%s`, got `%s`", test.output, result)
|
t.Errorf("expected `%s`, got `%s`", test.output, result)
|
||||||
}
|
}
|
||||||
@ -75,9 +75,9 @@ func TestHTMLFragmentFormatter2(t *testing.T) {
|
|||||||
},
|
},
|
||||||
}
|
}
|
||||||
|
|
||||||
emHtmlFormatter := NewHTMLFragmentFormatter("<em>", "</em>")
|
emHTMLFormatter := NewHTMLFragmentFormatter("<em>", "</em>")
|
||||||
for _, test := range tests {
|
for _, test := range tests {
|
||||||
result := emHtmlFormatter.Format(test.fragment, test.tlm)
|
result := emHTMLFormatter.Format(test.fragment, test.tlm)
|
||||||
if result != test.output {
|
if result != test.output {
|
||||||
t.Errorf("expected `%s`, got `%s`", test.output, result)
|
t.Errorf("expected `%s`, got `%s`", test.output, result)
|
||||||
}
|
}
|
||||||
|
@ -140,7 +140,7 @@ func (s *SimpleHighlighter) BestFragmentsInField(dm *search.DocumentMatch, doc *
|
|||||||
return formattedFragments
|
return formattedFragments
|
||||||
}
|
}
|
||||||
|
|
||||||
// A PriorityQueue implements heap.Interface and holds Items.
|
// FragmentQueue implements heap.Interface and holds Items.
|
||||||
type FragmentQueue []*highlight.Fragment
|
type FragmentQueue []*highlight.Fragment
|
||||||
|
|
||||||
func (fq FragmentQueue) Len() int { return len(fq) }
|
func (fq FragmentQueue) Len() int { return len(fq) }
|
||||||
|
@ -265,7 +265,7 @@ func (s *BooleanSearcher) Advance(ID string) (*search.DocumentMatch, error) {
|
|||||||
func (s *BooleanSearcher) Count() uint64 {
|
func (s *BooleanSearcher) Count() uint64 {
|
||||||
|
|
||||||
// for now return a worst case
|
// for now return a worst case
|
||||||
var sum uint64 = 0
|
var sum uint64
|
||||||
if s.mustSearcher != nil {
|
if s.mustSearcher != nil {
|
||||||
sum += s.mustSearcher.Count()
|
sum += s.mustSearcher.Count()
|
||||||
}
|
}
|
||||||
|
@ -171,7 +171,7 @@ func (s *ConjunctionSearcher) Advance(ID string) (*search.DocumentMatch, error)
|
|||||||
|
|
||||||
func (s *ConjunctionSearcher) Count() uint64 {
|
func (s *ConjunctionSearcher) Count() uint64 {
|
||||||
// for now return a worst case
|
// for now return a worst case
|
||||||
var sum uint64 = 0
|
var sum uint64
|
||||||
for _, searcher := range s.searchers {
|
for _, searcher := range s.searchers {
|
||||||
sum += searcher.Count()
|
sum += searcher.Count()
|
||||||
}
|
}
|
||||||
|
@ -167,7 +167,7 @@ func (s *DisjunctionSearcher) Advance(ID string) (*search.DocumentMatch, error)
|
|||||||
|
|
||||||
func (s *DisjunctionSearcher) Count() uint64 {
|
func (s *DisjunctionSearcher) Count() uint64 {
|
||||||
// for now return a worst case
|
// for now return a worst case
|
||||||
var sum uint64 = 0
|
var sum uint64
|
||||||
for _, searcher := range s.searchers {
|
for _, searcher := range s.searchers {
|
||||||
sum += searcher.Count()
|
sum += searcher.Count()
|
||||||
}
|
}
|
||||||
|
@ -48,11 +48,11 @@ func NewNumericRangeSearcher(index index.Index, min *float64, max *float64, incl
|
|||||||
// find all the ranges
|
// find all the ranges
|
||||||
minInt64 := numeric_util.Float64ToInt64(*min)
|
minInt64 := numeric_util.Float64ToInt64(*min)
|
||||||
if !*inclusiveMin && minInt64 != math.MaxInt64 {
|
if !*inclusiveMin && minInt64 != math.MaxInt64 {
|
||||||
minInt64 += 1
|
minInt64++
|
||||||
}
|
}
|
||||||
maxInt64 := numeric_util.Float64ToInt64(*max)
|
maxInt64 := numeric_util.Float64ToInt64(*max)
|
||||||
if !*inclusiveMax && maxInt64 != math.MinInt64 {
|
if !*inclusiveMax && maxInt64 != math.MinInt64 {
|
||||||
maxInt64 -= 1
|
maxInt64--
|
||||||
}
|
}
|
||||||
// FIXME hard-coded precion, should match field declaration
|
// FIXME hard-coded precion, should match field declaration
|
||||||
termRanges := splitInt64Range(minInt64, maxInt64, 4)
|
termRanges := splitInt64Range(minInt64, maxInt64, 4)
|
||||||
|
@ -134,7 +134,7 @@ func (s *PhraseSearcher) Next() (*search.DocumentMatch, error) {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
// if we got here all the terms matched
|
// if we got here all the terms matched
|
||||||
freq += 1
|
freq++
|
||||||
search.MergeTermLocationMaps(rvtlm, crvtlm)
|
search.MergeTermLocationMaps(rvtlm, crvtlm)
|
||||||
rvftlm[field] = rvtlm
|
rvftlm[field] = rvtlm
|
||||||
}
|
}
|
||||||
@ -168,7 +168,7 @@ func (s *PhraseSearcher) Advance(ID string) (*search.DocumentMatch, error) {
|
|||||||
|
|
||||||
func (s *PhraseSearcher) Count() uint64 {
|
func (s *PhraseSearcher) Count() uint64 {
|
||||||
// for now return a worst case
|
// for now return a worst case
|
||||||
var sum uint64 = 0
|
var sum uint64
|
||||||
sum += s.mustSearcher.Count()
|
sum += s.mustSearcher.Count()
|
||||||
return sum
|
return sum
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user