Versions in this module Expand all Collapse all v2 v2.2.10 Jul 6, 2022 v2.2.9 Jul 5, 2022 Changes in this version + const ByteSeparator + const DictionaryRowMaxValueSize + const Name + const RowBufferSize + const Version + var ErrInvalidLengthUpsidedown = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrorUnknownStorageType = fmt.Errorf("unknown storage type") + var IncompatibleVersion = fmt.Errorf("incompatible version, %d is supported", Version) + var VersionKey = []byte + func GetRowBuffer() []byte + func NewUpsideDownCouch(storeName string, storeConfig map[string]interface{}, ...) (index.Index, error) + func PutRowBuffer(buf []byte) + type AnalysisResult struct + DocID string + Rows []IndexRow + type BackIndexRow struct + func NewBackIndexRow(docID []byte, entries []*BackIndexTermsEntry, ...) *BackIndexRow + func NewBackIndexRowKV(key, value []byte) (*BackIndexRow, error) + func (br *BackIndexRow) AllStoredKeys() [][]byte + func (br *BackIndexRow) AllTermKeys() [][]byte + func (br *BackIndexRow) Key() []byte + func (br *BackIndexRow) KeySize() int + func (br *BackIndexRow) KeyTo(buf []byte) (int, error) + func (br *BackIndexRow) String() string + func (br *BackIndexRow) Value() []byte + func (br *BackIndexRow) ValueSize() int + func (br *BackIndexRow) ValueTo(buf []byte) (int, error) + type BackIndexRowValue struct + StoredEntries []*BackIndexStoreEntry + TermsEntries []*BackIndexTermsEntry + XXX_unrecognized []byte + func (*BackIndexRowValue) ProtoMessage() + func (m *BackIndexRowValue) GetStoredEntries() []*BackIndexStoreEntry + func (m *BackIndexRowValue) GetTermsEntries() []*BackIndexTermsEntry + func (m *BackIndexRowValue) Marshal() (data []byte, err error) + func (m *BackIndexRowValue) MarshalTo(data []byte) (n int, err error) + func (m *BackIndexRowValue) Reset() + func (m *BackIndexRowValue) Size() (n int) + func (m *BackIndexRowValue) String() string + func (m *BackIndexRowValue) Unmarshal(data []byte) error + type BackIndexStoreEntry struct + ArrayPositions []uint64 + Field *uint32 + XXX_unrecognized []byte + func (*BackIndexStoreEntry) ProtoMessage() + func (m *BackIndexStoreEntry) GetArrayPositions() []uint64 + func (m *BackIndexStoreEntry) GetField() uint32 + func (m *BackIndexStoreEntry) Marshal() (data []byte, err error) + func (m *BackIndexStoreEntry) MarshalTo(data []byte) (n int, err error) + func (m *BackIndexStoreEntry) Reset() + func (m *BackIndexStoreEntry) Size() (n int) + func (m *BackIndexStoreEntry) String() string + func (m *BackIndexStoreEntry) Unmarshal(data []byte) error + type BackIndexTermsEntry struct + Field *uint32 + Terms []string + XXX_unrecognized []byte + func (*BackIndexTermsEntry) ProtoMessage() + func (m *BackIndexTermsEntry) GetField() uint32 + func (m *BackIndexTermsEntry) GetTerms() []string + func (m *BackIndexTermsEntry) Marshal() (data []byte, err error) + func (m *BackIndexTermsEntry) MarshalTo(data []byte) (n int, err error) + func (m *BackIndexTermsEntry) Reset() + func (m *BackIndexTermsEntry) Size() (n int) + func (m *BackIndexTermsEntry) String() string + func (m *BackIndexTermsEntry) Unmarshal(data []byte) error + type DictionaryRow struct + func NewDictionaryRow(term []byte, field uint16, count uint64) *DictionaryRow + func NewDictionaryRowK(key []byte) (*DictionaryRow, error) + func NewDictionaryRowKV(key, value []byte) (*DictionaryRow, error) + func (dr *DictionaryRow) Key() []byte + func (dr *DictionaryRow) KeySize() int + func (dr *DictionaryRow) KeyTo(buf []byte) (int, error) + func (dr *DictionaryRow) String() string + func (dr *DictionaryRow) Value() []byte + func (dr *DictionaryRow) ValueSize() int + func (dr *DictionaryRow) ValueTo(buf []byte) (int, error) + type DocValueReader struct + func (dvr *DocValueReader) VisitDocValues(id index.IndexInternalID, visitor index.DocValueVisitor) error + type FieldCache struct + func NewFieldCache() *FieldCache + func (f *FieldCache) AddExisting(field string, index uint16) + func (f *FieldCache) FieldIndexed(index uint16) (field string) + func (f *FieldCache) FieldNamed(field string, createIfMissing bool) (uint16, bool) + type FieldRow struct + func NewFieldRow(index uint16, name string) *FieldRow + func NewFieldRowKV(key, value []byte) (*FieldRow, error) + func (f *FieldRow) Key() []byte + func (f *FieldRow) KeySize() int + func (f *FieldRow) KeyTo(buf []byte) (int, error) + func (f *FieldRow) String() string + func (f *FieldRow) Value() []byte + func (f *FieldRow) ValueSize() int + func (f *FieldRow) ValueTo(buf []byte) (int, error) + type IndexReader struct + func (i *IndexReader) Close() error + func (i *IndexReader) DocCount() (uint64, error) + func (i *IndexReader) DocIDReaderAll() (index.DocIDReader, error) + func (i *IndexReader) DocIDReaderOnly(ids []string) (index.DocIDReader, error) + func (i *IndexReader) DocValueReader(fields []string) (index.DocValueReader, error) + func (i *IndexReader) Document(id string) (doc index.Document, err error) + func (i *IndexReader) DumpAll() chan interface{} + func (i *IndexReader) DumpDoc(id string) chan interface{} + func (i *IndexReader) DumpFields() chan interface{} + func (i *IndexReader) ExternalID(id index.IndexInternalID) (string, error) + func (i *IndexReader) FieldDict(fieldName string) (index.FieldDict, error) + func (i *IndexReader) FieldDictPrefix(fieldName string, termPrefix []byte) (index.FieldDict, error) + func (i *IndexReader) FieldDictRange(fieldName string, startTerm []byte, endTerm []byte) (index.FieldDict, error) + func (i *IndexReader) Fields() (fields []string, err error) + func (i *IndexReader) GetInternal(key []byte) ([]byte, error) + func (i *IndexReader) InternalID(id string) (index.IndexInternalID, error) + func (i *IndexReader) TermFieldReader(term []byte, fieldName string, ...) (index.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 InternalRow struct + func NewInternalRow(key, val []byte) *InternalRow + func NewInternalRowKV(key, value []byte) (*InternalRow, error) + func (i *InternalRow) Key() []byte + func (i *InternalRow) KeySize() int + func (i *InternalRow) KeyTo(buf []byte) (int, error) + func (i *InternalRow) String() string + func (i *InternalRow) Value() []byte + func (i *InternalRow) ValueSize() int + func (i *InternalRow) ValueTo(buf []byte) (int, error) + type StoredRow struct + func NewStoredRow(docID []byte, field uint16, arrayPositions []uint64, typ byte, value []byte) *StoredRow + func NewStoredRowK(key []byte) (*StoredRow, error) + func NewStoredRowKV(key, value []byte) (*StoredRow, error) + func (s *StoredRow) Key() []byte + func (s *StoredRow) KeySize() int + func (s *StoredRow) KeyTo(buf []byte) (int, error) + func (s *StoredRow) ScanPrefixForDoc() []byte + func (s *StoredRow) String() string + func (s *StoredRow) Value() []byte + func (s *StoredRow) ValueSize() int + func (s *StoredRow) ValueTo(buf []byte) (int, error) + type TermFrequencyRow struct + func InitTermFrequencyRow(tfr *TermFrequencyRow, term []byte, field uint16, docID []byte, freq uint64, ...) *TermFrequencyRow + func NewTermFrequencyRow(term []byte, field uint16, docID []byte, freq uint64, norm float32) *TermFrequencyRow + func NewTermFrequencyRowK(key []byte) (*TermFrequencyRow, error) + func NewTermFrequencyRowKV(key, value []byte) (*TermFrequencyRow, error) + func NewTermFrequencyRowWithTermVectors(term []byte, field uint16, docID []byte, freq uint64, norm float32, ...) *TermFrequencyRow + func (tfr *TermFrequencyRow) DictionaryRowKey() []byte + func (tfr *TermFrequencyRow) DictionaryRowKeySize() int + func (tfr *TermFrequencyRow) DictionaryRowKeyTo(buf []byte) (int, error) + func (tfr *TermFrequencyRow) Freq() uint64 + func (tfr *TermFrequencyRow) Key() []byte + func (tfr *TermFrequencyRow) KeyAppendTo(buf []byte) ([]byte, error) + func (tfr *TermFrequencyRow) KeySize() int + func (tfr *TermFrequencyRow) KeyTo(buf []byte) (int, error) + func (tfr *TermFrequencyRow) ScanPrefixForField() []byte + func (tfr *TermFrequencyRow) ScanPrefixForFieldTerm() []byte + func (tfr *TermFrequencyRow) ScanPrefixForFieldTermPrefix() []byte + func (tfr *TermFrequencyRow) Size() int + func (tfr *TermFrequencyRow) String() string + func (tfr *TermFrequencyRow) Term() []byte + func (tfr *TermFrequencyRow) Value() []byte + func (tfr *TermFrequencyRow) ValueSize() int + func (tfr *TermFrequencyRow) ValueTo(buf []byte) (int, error) + type TermVector struct + func (tv *TermVector) Size() int + func (tv *TermVector) String() string + type UpsideDownCouch struct + func (udc *UpsideDownCouch) Advanced() (store.KVStore, error) + func (udc *UpsideDownCouch) Analyze(d index.Document) *AnalysisResult + func (udc *UpsideDownCouch) Batch(batch *index.Batch) (err error) + func (udc *UpsideDownCouch) Close() error + func (udc *UpsideDownCouch) Delete(id string) (err error) + func (udc *UpsideDownCouch) DeleteInternal(key []byte) (err error) + func (udc *UpsideDownCouch) Open() (err error) + func (udc *UpsideDownCouch) Reader() (index.IndexReader, error) + func (udc *UpsideDownCouch) SetInternal(key, val []byte) (err error) + func (udc *UpsideDownCouch) Stats() json.Marshaler + func (udc *UpsideDownCouch) StatsMap() map[string]interface{} + func (udc *UpsideDownCouch) Update(doc index.Document) (err error) + func (udc *UpsideDownCouch) UpdateWithAnalysis(doc index.Document, result *AnalysisResult, backIndexRow *BackIndexRow) (err error) + type UpsideDownCouchDocIDReader struct + func (r *UpsideDownCouchDocIDReader) Advance(docID index.IndexInternalID) (index.IndexInternalID, error) + func (r *UpsideDownCouchDocIDReader) Close() error + func (r *UpsideDownCouchDocIDReader) Next() (index.IndexInternalID, error) + func (r *UpsideDownCouchDocIDReader) Size() int + type UpsideDownCouchFieldDict struct + func (r *UpsideDownCouchFieldDict) Close() error + func (r *UpsideDownCouchFieldDict) Next() (*index.DictEntry, error) + type UpsideDownCouchRow interface + Key func() []byte + KeySize func() int + KeyTo func([]byte) (int, error) + Value func() []byte + ValueSize func() int + ValueTo func([]byte) (int, error) + func ParseFromKeyValue(key, value []byte) (UpsideDownCouchRow, error) + type UpsideDownCouchRowStream chan UpsideDownCouchRow + type UpsideDownCouchTermFieldReader struct + func (r *UpsideDownCouchTermFieldReader) Advance(docID index.IndexInternalID, preAlloced *index.TermFieldDoc) (rv *index.TermFieldDoc, err error) + func (r *UpsideDownCouchTermFieldReader) Close() error + func (r *UpsideDownCouchTermFieldReader) Count() uint64 + func (r *UpsideDownCouchTermFieldReader) Next(preAlloced *index.TermFieldDoc) (*index.TermFieldDoc, error) + func (r *UpsideDownCouchTermFieldReader) Size() int + type VersionRow struct + func NewVersionRow(version uint8) *VersionRow + func NewVersionRowKV(key, value []byte) (*VersionRow, error) + func (v *VersionRow) Key() []byte + func (v *VersionRow) KeySize() int + func (v *VersionRow) KeyTo(buf []byte) (int, error) + func (v *VersionRow) String() string + func (v *VersionRow) Value() []byte + func (v *VersionRow) ValueSize() int + func (v *VersionRow) ValueTo(buf []byte) (int, error) Other modules containing this package github.com/linbaozhong/bleve