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 + const ByteSeparator + const DefaultDictUpdateThreshold + const DefaultGarbageThreshold + const DefaultMaxDocsPerPass + const IDFieldName + const Name + const Version + var DefaultDictUpdateSleep = 1 * time.Second + var DefaultGarbageSleep = 15 * time.Second + var DictionaryKeyPrefix = []byte + var ErrInvalidLengthFirestormRows = fmt.Errorf("proto: negative length found during unmarshaling") + var FieldKeyPrefix = []byte + var IncompatibleVersion = fmt.Errorf("incompatible version, %d is supported", Version) + var InternalKeyPrefix = []byte + var StoredKeyPrefix = []byte + var TermFreqKeyPrefix = []byte + var UnsafeBatchUseDetected = fmt.Errorf("bleve.Batch is NOT thread-safe, modification after execution detected") + var VersionKey = []byte + func DictionaryRowKey(field uint16, term []byte) []byte + func NewFirestorm(storeName string, storeConfig map[string]interface{}, ...) (index.Index, error) + func SetLog(l *log.Logger) + func StoredIteratorStartDocID(docID []byte) []byte + func StoredPrefixDocIDNum(docID []byte, docNum uint64) []byte + func TermFreqIteratorStart(field uint16, term []byte) []byte + func TermFreqPrefixFieldTermDocId(field uint16, term []byte, docID []byte) []byte + type Compensator struct + func NewCompensator() *Compensator + func (c *Compensator) GarbageCollect(docNums []uint64) + func (c *Compensator) GarbageCount() uint64 + func (c *Compensator) Migrate(docID []byte, docNum uint64, oldDocNums []uint64) + func (c *Compensator) Mutate(docID []byte, docNum uint64) + func (c *Compensator) MutateBatch(inflightItems []*InFlightItem, lastDocNum uint64) + func (c *Compensator) Snapshot() *Snapshot + type DictUpdater struct + func NewDictUpdater(f *Firestorm) *DictUpdater + func (d *DictUpdater) Notify(term string, usage int64) + func (d *DictUpdater) NotifyBatch(termUsages map[string]int64) + func (d *DictUpdater) Start() + func (d *DictUpdater) Stop() + type DictionaryRow struct + func NewDictionaryRow(field uint16, term []byte, count uint64) *DictionaryRow + func NewDictionaryRowK(key []byte) (*DictionaryRow, error) + func NewDictionaryRowKV(key, value []byte) (*DictionaryRow, error) + func (dr *DictionaryRow) Count() uint64 + func (dr *DictionaryRow) Key() []byte + func (dr *DictionaryRow) KeySize() int + func (dr *DictionaryRow) KeyTo(buf []byte) (int, error) + func (dr *DictionaryRow) SetCount(count uint64) + func (dr *DictionaryRow) Value() []byte + func (dr *DictionaryRow) ValueSize() int + func (dr *DictionaryRow) ValueTo(buf []byte) (int, error) + type DictionaryValue struct + Count *uint64 + XXX_unrecognized []byte + func (*DictionaryValue) ProtoMessage() + func (m *DictionaryValue) GetCount() uint64 + func (m *DictionaryValue) Marshal() (data []byte, err error) + func (m *DictionaryValue) MarshalTo(data []byte) (n int, err error) + func (m *DictionaryValue) Reset() + func (m *DictionaryValue) Size() (n int) + func (m *DictionaryValue) String() string + func (m *DictionaryValue) Unmarshal(data []byte) error + type DocNumberList []uint64 + func (l DocNumberList) HighestValid(maxRead uint64) uint64 + func (l DocNumberList) Len() int + func (l DocNumberList) Less(i, j int) bool + func (l DocNumberList) Swap(i, j int) + type FieldRow struct + func NewFieldRow(i uint16, name string) *FieldRow + func NewFieldRowKV(key, value []byte) (*FieldRow, error) + func (fr *FieldRow) Index() uint16 + func (fr *FieldRow) Key() []byte + func (fr *FieldRow) KeySize() int + func (fr *FieldRow) KeyTo(buf []byte) (int, error) + func (fr *FieldRow) Name() string + func (fr *FieldRow) String() string + func (fr *FieldRow) Value() []byte + func (fr *FieldRow) ValueSize() int + func (fr *FieldRow) ValueTo(buf []byte) (int, error) + type FieldValue struct + Name *string + XXX_unrecognized []byte + func (*FieldValue) ProtoMessage() + func (m *FieldValue) GetName() string + func (m *FieldValue) Marshal() (data []byte, err error) + func (m *FieldValue) MarshalTo(data []byte) (n int, err error) + func (m *FieldValue) Reset() + func (m *FieldValue) Size() (n int) + func (m *FieldValue) String() string + func (m *FieldValue) Unmarshal(data []byte) error + type Firestorm struct + func (f *Firestorm) Advanced() (store.KVStore, error) + func (f *Firestorm) Analyze(d *document.Document) *index.AnalysisResult + func (f *Firestorm) Batch(batch *index.Batch) (err error) + func (f *Firestorm) Close() error + func (f *Firestorm) Delete(id string) error + func (f *Firestorm) DeleteInternal(key []byte) (err error) + func (f *Firestorm) DocCount() (uint64, error) + func (f *Firestorm) DumpAll() chan interface{} + func (f *Firestorm) DumpDoc(docID string) chan interface{} + func (f *Firestorm) DumpFields() chan interface{} + func (f *Firestorm) Open() (err error) + func (f *Firestorm) Reader() (index.IndexReader, error) + func (f *Firestorm) SetInternal(key, val []byte) (err error) + func (f *Firestorm) Stats() json.Marshaler + func (f *Firestorm) StatsMap() map[string]interface{} + func (f *Firestorm) Update(doc *document.Document) (err error) + func (f *Firestorm) Wait(timeout time.Duration) error + type GarbageCollector struct + func NewGarbageCollector(f *Firestorm) *GarbageCollector + func (gc *GarbageCollector) NextBatch(n int) []uint64 + func (gc *GarbageCollector) Notify(docNum uint64, docId []byte) + func (gc *GarbageCollector) Start() + func (gc *GarbageCollector) Stop() + type InFlightItem struct + type InternalRow struct + func NewInternalRow(key, val []byte) *InternalRow + func NewInternalRowKV(key, value []byte) (*InternalRow, error) + func (ir *InternalRow) Key() []byte + func (ir *InternalRow) KeySize() int + func (ir *InternalRow) KeyTo(buf []byte) (int, error) + func (ir *InternalRow) String() string + func (ir *InternalRow) Value() []byte + func (ir *InternalRow) ValueSize() int + func (ir *InternalRow) ValueTo(buf []byte) (int, error) + type KVVisitor func(key, val []byte) (bool, error) + type Lookuper struct + func NewLookuper(f *Firestorm) *Lookuper + func (l *Lookuper) NotifyBatch(items []*InFlightItem) + func (l *Lookuper) Start() + func (l *Lookuper) Stop() + type Snapshot struct + func (s *Snapshot) Valid(docID []byte, docNum uint64) bool + func (s *Snapshot) Which(docID []byte, docNumList DocNumberList) uint64 + type StoredRow struct + func NewStoredRow(docID []byte, docNum uint64, field uint16, arrayPositions []uint64, ...) *StoredRow + func NewStoredRowKV(key, value []byte) (*StoredRow, error) + func (sr *StoredRow) DocID() []byte + func (sr *StoredRow) DocNum() uint64 + func (sr *StoredRow) Key() []byte + func (sr *StoredRow) KeySize() int + func (sr *StoredRow) KeyTo(buf []byte) (int, error) + func (sr *StoredRow) ParseKey(key []byte) error + func (sr *StoredRow) String() string + func (sr *StoredRow) Value() []byte + func (sr *StoredRow) ValueSize() int + func (sr *StoredRow) ValueTo(buf []byte) (int, error) + type StoredValue struct + Raw []byte + XXX_unrecognized []byte + func (*StoredValue) ProtoMessage() + func (m *StoredValue) GetRaw() []byte + func (m *StoredValue) Marshal() (data []byte, err error) + func (m *StoredValue) MarshalTo(data []byte) (n int, err error) + func (m *StoredValue) Reset() + func (m *StoredValue) Size() (n int) + func (m *StoredValue) String() string + func (m *StoredValue) Unmarshal(data []byte) error + type TermFreqRow struct + func InitTermFreqRow(tfr *TermFreqRow, field uint16, term []byte, docID []byte, docNum uint64, ...) *TermFreqRow + func NewTermFreqRow(field uint16, term []byte, docID []byte, docNum uint64, freq uint64, ...) *TermFreqRow + func NewTermFreqRowKV(key, value []byte) (*TermFreqRow, error) + func (tfr *TermFreqRow) DictionaryRowKey() []byte + func (tfr *TermFreqRow) DictionaryRowKeySize() int + func (tfr *TermFreqRow) DictionaryRowKeyTo(buf []byte) (int, error) + func (tfr *TermFreqRow) DocID() []byte + func (tfr *TermFreqRow) DocNum() uint64 + func (tfr *TermFreqRow) Field() uint16 + func (tfr *TermFreqRow) Freq() uint64 + func (tfr *TermFreqRow) Key() []byte + func (tfr *TermFreqRow) KeySize() int + func (tfr *TermFreqRow) KeyTo(buf []byte) (int, error) + func (tfr *TermFreqRow) Norm() float32 + func (tfr *TermFreqRow) ParseKey(key []byte) error + func (tfr *TermFreqRow) String() string + func (tfr *TermFreqRow) Term() []byte + func (tfr *TermFreqRow) Value() []byte + func (tfr *TermFreqRow) ValueSize() int + func (tfr *TermFreqRow) ValueTo(buf []byte) (int, error) + func (tfr *TermFreqRow) Vectors() []*TermVector + type TermFreqValue struct + Freq *uint64 + Norm *float32 + Vectors []*TermVector + XXX_unrecognized []byte + func (*TermFreqValue) ProtoMessage() + func (m *TermFreqValue) GetFreq() uint64 + func (m *TermFreqValue) GetNorm() float32 + func (m *TermFreqValue) GetVectors() []*TermVector + func (m *TermFreqValue) Marshal() (data []byte, err error) + func (m *TermFreqValue) MarshalTo(data []byte) (n int, err error) + func (m *TermFreqValue) Reset() + func (m *TermFreqValue) Size() (n int) + func (m *TermFreqValue) String() string + func (m *TermFreqValue) Unmarshal(data []byte) error + type TermVector struct + ArrayPositions []uint64 + End *uint64 + Field *uint32 + Pos *uint64 + Start *uint64 + XXX_unrecognized []byte + func NewTermVector(field uint16, pos uint64, start uint64, end uint64, arrayPos []uint64) *TermVector + func (*TermVector) ProtoMessage() + func (m *TermVector) GetArrayPositions() []uint64 + func (m *TermVector) GetEnd() uint64 + func (m *TermVector) GetField() uint32 + func (m *TermVector) GetPos() uint64 + func (m *TermVector) GetStart() uint64 + func (m *TermVector) Marshal() (data []byte, err error) + func (m *TermVector) MarshalTo(data []byte) (n int, err error) + func (m *TermVector) Reset() + func (m *TermVector) Size() (n int) + func (m *TermVector) String() string + func (m *TermVector) Unmarshal(data []byte) error + type VersionRow struct + func NewVersionRow(version uint64) *VersionRow + func NewVersionRowV(val []byte) (*VersionRow, error) + func (vr *VersionRow) Key() []byte + func (vr *VersionRow) KeySize() int + func (vr *VersionRow) KeyTo(buf []byte) (int, error) + func (vr *VersionRow) Value() []byte + func (vr *VersionRow) ValueSize() int + func (vr *VersionRow) ValueTo(buf []byte) (int, error) + func (vr *VersionRow) Version() uint64 + type VersionValue struct + Version *uint64 + XXX_unrecognized []byte + func (*VersionValue) ProtoMessage() + func (m *VersionValue) GetVersion() uint64 + func (m *VersionValue) Marshal() (data []byte, err error) + func (m *VersionValue) MarshalTo(data []byte) (n int, err error) + func (m *VersionValue) Reset() + func (m *VersionValue) Size() (n int) + func (m *VersionValue) String() string + func (m *VersionValue) Unmarshal(data []byte) error
Go to main page