index

package

Go to main page

Versions in this module

v0

v0.7.0

Feb 27, 2018

v0.6.0

Jan 5, 2018

Changes in this version

type AnalysisResult

+ Analyzed []analysis.TokenFrequencies

+ Document *document.Document

+ Length []int

+ type DocumentFieldTermVisitor func(field string, term []byte)

type IndexReader

+ DocumentVisitFieldTerms func(id IndexInternalID, fields []string, visitor DocumentFieldTermVisitor) error

v0.5.0

Sep 28, 2016

Changes in this version

type IndexReader

+ DocIDReaderAll func() (DocIDReader, error)

+ DumpAll func() chan interface{}

+ DumpDoc func(id string) chan interface{}

+ DumpFields func() chan interface{}

+ ExternalID func(id IndexInternalID) (string, error)

+ InternalID func(id string) (IndexInternalID, error)

v0.4.0

Sep 12, 2016

Changes in this version

type FieldTerms

+ func (f FieldTerms) FieldsNotYetCached(fields []string) []string

+ func (f FieldTerms) Merge(other FieldTerms)

+ type IndexInternalID []byte

+ func (id IndexInternalID) Compare(other IndexInternalID) int

+ func (id IndexInternalID) Equals(other IndexInternalID) bool

type IndexReader

+ DocIDReaderOnly func(ids []string) (DocIDReader, error)

+ FinalizeDocID func(id IndexInternalID) (string, error)

type TermFieldDoc

+ func (tfd *TermFieldDoc) Reset() *TermFieldDoc

v0.3.0

Jun 16, 2016

v0.2.0

Apr 8, 2016

v0.1.0

Apr 8, 2016

Changes in this version

+ var ErrorUnknownStorageType = fmt.Errorf("unknown storage type")

+ func AnalysisWorker(q AnalysisQueue)

+ type AnalysisQueue struct

+ func NewAnalysisQueue(numWorkers int) *AnalysisQueue

+ func (q *AnalysisQueue) Close()

+ func (q *AnalysisQueue) Queue(work *AnalysisWork)

+ type AnalysisResult struct

+ DocID string

+ Rows []IndexRow

+ type AnalysisWork struct

+ func NewAnalysisWork(i Index, d *document.Document, rc chan *AnalysisResult) *AnalysisWork

+ type AsyncIndex interface

+ Wait func(timeout time.Duration) error

+ type Batch struct

+ IndexOps map[string]*document.Document

+ InternalOps map[string][]byte

+ func NewBatch() *Batch

+ func (b *Batch) Delete(id string)

+ func (b *Batch) DeleteInternal(key []byte)

+ func (b *Batch) Reset()

+ func (b *Batch) SetInternal(key, val []byte)

+ func (b *Batch) String() string

+ func (b *Batch) Update(doc *document.Document)

+ type DictEntry struct

+ Count uint64

+ Term string

+ type DocIDReader interface

+ Advance func(ID string) (string, error)

+ Close func() error

+ Next func() (string, error)

+ type FieldCache struct

+ func NewFieldCache() *FieldCache

+ func (f *FieldCache) AddExisting(field string, index uint16)

+ func (f *FieldCache) FieldIndexed(index uint16) string

+ func (f *FieldCache) FieldNamed(field string, createIfMissing bool) (uint16, bool)

+ type FieldDict interface

+ Close func() error

+ Next func() (*DictEntry, error)

+ type FieldTerms map[string][]string

+ type Index interface

+ Advanced func() (store.KVStore, error)

+ Analyze func(d *document.Document) *AnalysisResult

+ Batch func(batch *Batch) error

+ Close func() error

+ Delete func(id string) error

+ DeleteInternal func(key []byte) error

+ DocCount func() (uint64, error)

+ DumpAll func() chan interface{}

+ DumpDoc func(id string) chan interface{}

+ DumpFields func() chan interface{}

+ Open func() error

+ Reader func() (IndexReader, error)

+ SetInternal func(key, val []byte) error

+ Stats func() json.Marshaler

+ StatsMap func() map[string]interface{}

+ Update func(doc *document.Document) error

+ type IndexReader interface

+ Close func() error

+ DocCount func() uint64

+ DocIDReader func(start, end string) (DocIDReader, error)

+ Document func(id string) (*document.Document, error)

+ DocumentFieldTerms func(id string) (FieldTerms, error)

+ FieldDict func(field string) (FieldDict, error)

+ FieldDictPrefix func(field string, termPrefix []byte) (FieldDict, error)

+ FieldDictRange func(field string, startTerm []byte, endTerm []byte) (FieldDict, error)

+ Fields func() ([]string, error)

+ GetInternal func(key []byte) ([]byte, error)

+ TermFieldReader func(term []byte, field string) (TermFieldReader, error)

+ type IndexRow interface

+ Key func() []byte

+ KeySize func() int

+ KeyTo func([]byte) (int, error)

+ Value func() []byte

+ ValueSize func() int

+ ValueTo func([]byte) (int, error)

+ type TermFieldDoc struct

+ Freq uint64

+ ID string

+ Norm float64

+ Term string

+ Vectors []*TermFieldVector

+ type TermFieldReader interface

+ Advance func(ID string) (*TermFieldDoc, error)

+ Close func() error

+ Count func() uint64

+ Next func() (*TermFieldDoc, error)

+ type TermFieldVector struct

+ ArrayPositions []uint64

+ End uint64

+ Field string

+ Pos uint64

+ Start uint64

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL