Versions in this module Expand all Collapse all v0 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