index

package
v0.0.15 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 19, 2020 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	MaxNumIndex = 50000
)
View Source 
const SEP = "\007"

Variables

This section is empty.

Functions

This section is empty.

Types

type DocIdKey 

type DocIdKey struct {
	// contains filtered or unexported fields
}

func DocId 

func DocId(key document.DocId) *DocIdKey

func (*DocIdKey) PartitionKey 

func (i *DocIdKey) PartitionKey() int64

func (*DocIdKey) Value 

func (i *DocIdKey) Value() interface{}

type Index 

type Index interface {
	Add(docInfo *document.DocInfo) error
	UpdateIds(fieldName string, ids []document.DocId)
	Delete(fieldName string)
	Del(docInfo *document.DocInfo)

	GetName() string
	GetInvertedIndex() InvertedIndex
	GetStorageIndex() StorageIndex
	GetDataType(fieldName string) document.FieldType

	GetId(id document.DocId) (document.DocId, error)
	GetInnerId(id document.DocId) (document.DocId, error)

	Dump(filename string) error
	Load(filename string) error

	GetIndexInfo() *IndexInfo
	GetValueById(id document.DocId) *IndexDebugInfo
	DebugInfo() *debug.Debug
}

func NewIndex 

func NewIndex(name string) Index

func NewIndexImpl added in v0.0.5 

func NewIndexImpl(name string) Index

type IndexDebugInfo added in v0.0.14 

type IndexDebugInfo struct {
	InvertIndex  map[string][]string
	StorageIndex map[string][]string
}

type IndexInfo added in v0.0.11 

type IndexInfo struct {
	DocSize           int `json:"doc_size"`
	InvertedIndexSize int `json:"inverted_index_szie"`
	StorageIndex      int `json:"storage_index_size"`
}

type Indexer 

type Indexer struct {
	// contains filtered or unexported fields
}

func (*Indexer) Add 

func (i *Indexer) Add(doc *document.DocInfo) error

func (*Indexer) DebugInfo 

func (i *Indexer) DebugInfo() *debug.Debug

func (*Indexer) Del 

func (i *Indexer) Del(doc *document.DocInfo)

func (*Indexer) Delete 

func (i *Indexer) Delete(fieldName string)

func (*Indexer) Dump 

func (i *Indexer) Dump(filename string) error

func (*Indexer) GetBitMap 

func (i *Indexer) GetBitMap() *concurrent_map.ConcurrentMap

func (*Indexer) GetCampaignMap 

func (i *Indexer) GetCampaignMap() *concurrent_map.ConcurrentMap

func (*Indexer) GetDataType 

func (i *Indexer) GetDataType(fieldName string) document.FieldType

func (*Indexer) GetId added in v0.0.5 

func (i *Indexer) GetId(id document.DocId) (document.DocId, error)

func (*Indexer) GetIndexInfo added in v0.0.11 

func (i *Indexer) GetIndexInfo() *IndexInfo

func (*Indexer) GetInnerId added in v0.0.9 

func (i *Indexer) GetInnerId(id document.DocId) (document.DocId, error)

func (*Indexer) GetInvertedIndex 

func (i *Indexer) GetInvertedIndex() InvertedIndex

func (*Indexer) GetName 

func (i *Indexer) GetName() string

func (*Indexer) GetStorageIndex 

func (i *Indexer) GetStorageIndex() StorageIndex

func (*Indexer) GetValueById 

func (i *Indexer) GetValueById(id document.DocId) *IndexDebugInfo

func (*Indexer) Load 

func (i *Indexer) Load(filename string) error

func (*Indexer) SetDebug 

func (i *Indexer) SetDebug(level int)

func (*Indexer) StringBuilder 

func (i *Indexer) StringBuilder(cap int, value ...interface{}) string

func (*Indexer) Update 

func (i *Indexer) Update(filename string) error

func (*Indexer) UpdateIds 

func (i *Indexer) UpdateIds(fieldName string, ids []document.DocId)

func (*Indexer) WarnStatus 

func (i *Indexer) WarnStatus(name string, value interface{}, err string)

type IndexerV2 added in v0.0.4 

type IndexerV2 struct {
	// contains filtered or unexported fields
}

func NewIndexV2 added in v0.0.4 

func NewIndexV2(name string) (i *IndexerV2)

func (*IndexerV2) Add added in v0.0.4 

func (i *IndexerV2) Add(doc *document.DocInfo) error

func (*IndexerV2) DebugInfo added in v0.0.4 

func (i *IndexerV2) DebugInfo() *debug.Debug

func (*IndexerV2) Del added in v0.0.4 

func (i *IndexerV2) Del(doc *document.DocInfo)

func (*IndexerV2) Delete added in v0.0.4 

func (i *IndexerV2) Delete(fieldName string)

func (*IndexerV2) Dump added in v0.0.4 

func (i *IndexerV2) Dump(filename string) error

func (*IndexerV2) GetCampaignMap added in v0.0.4 

func (i *IndexerV2) GetCampaignMap() *concurrent_map.ConcurrentMap

func (*IndexerV2) GetDataType added in v0.0.4 

func (i *IndexerV2) GetDataType(fieldName string) document.FieldType

func (*IndexerV2) GetId added in v0.0.5 

func (i *IndexerV2) GetId(id document.DocId) (document.DocId, error)

func (*IndexerV2) GetIndexInfo added in v0.0.11 

func (i *IndexerV2) GetIndexInfo() *IndexInfo

func (*IndexerV2) GetInnerId added in v0.0.9 

func (i *IndexerV2) GetInnerId(id document.DocId) (document.DocId, error)

func (*IndexerV2) GetInvertedIndex added in v0.0.4 

func (i *IndexerV2) GetInvertedIndex() InvertedIndex

func (*IndexerV2) GetName added in v0.0.4 

func (i *IndexerV2) GetName() string

func (*IndexerV2) GetStorageIndex added in v0.0.4 

func (i *IndexerV2) GetStorageIndex() StorageIndex

func (*IndexerV2) GetValueById added in v0.0.4 

func (i *IndexerV2) GetValueById(id document.DocId) *IndexDebugInfo

func (*IndexerV2) Load added in v0.0.4 

func (i *IndexerV2) Load(filename string) error

func (*IndexerV2) MergeIndex added in v0.0.6 

func (i *IndexerV2) MergeIndex(target *IndexerV2) error

func (*IndexerV2) SetDebug added in v0.0.4 

func (i *IndexerV2) SetDebug(level int)

func (*IndexerV2) Update added in v0.0.4 

func (i *IndexerV2) Update(filename string) error

func (*IndexerV2) UpdateIds added in v0.0.4 

func (i *IndexerV2) UpdateIds(fieldName string, ids []document.DocId)

func (*IndexerV2) WarnStatus added in v0.0.4 

func (i *IndexerV2) WarnStatus(name string, value interface{}, err string)

type InvertedIndex 

type InvertedIndex interface {
	Add(fieldName string, id document.DocId) error
	Del(fieldName string, id document.DocId) bool
	Update(fieldName string, ids []document.DocId)
	Delete(fieldName string)
	Iterator(name, value string) datastruct.Iterator
	Range(func(key, value interface{}) bool)
	Count() int
	GetValueById(id document.DocId) map[string][]string
	SetDebug(level int)
	DebugInfo() *debug.Debug
}

type InvertedIndexer 

type InvertedIndexer struct {
	// contains filtered or unexported fields
}

func NewInvertedIndexer 

func NewInvertedIndexer() *InvertedIndexer

func (*InvertedIndexer) Add 

func (i *InvertedIndexer) Add(fieldName string, id document.DocId) (err error)

func (*InvertedIndexer) Count 

func (i *InvertedIndexer) Count() (count int)

func (*InvertedIndexer) DebugInfo 

func (i *InvertedIndexer) DebugInfo() *debug.Debug

func (*InvertedIndexer) Del 

func (i *InvertedIndexer) Del(fieldName string, id document.DocId) (ok bool)

func (*InvertedIndexer) Delete 

func (i *InvertedIndexer) Delete(fieldName string)

func (*InvertedIndexer) GetValueById 

func (i *InvertedIndexer) GetValueById(id document.DocId) map[string][]string

func (*InvertedIndexer) Iterator 

func (i *InvertedIndexer) Iterator(name, value string) datastruct.Iterator

func (*InvertedIndexer) Range added in v0.0.4 

func (i *InvertedIndexer) Range(f func(key, value interface{}) bool)

func (*InvertedIndexer) SetDebug 

func (i *InvertedIndexer) SetDebug(level int)

func (*InvertedIndexer) Update 

func (i *InvertedIndexer) Update(fieldName string, ids []document.DocId)

type InvertedIndexerV2 added in v0.0.4 

type InvertedIndexerV2 struct {
	// contains filtered or unexported fields
}

func NewInvertedIndexV2 added in v0.0.4 

func NewInvertedIndexV2() *InvertedIndexerV2

func (*InvertedIndexerV2) Add added in v0.0.4 

func (i *InvertedIndexerV2) Add(fieldName string, id document.DocId) (err error)

func (*InvertedIndexerV2) Count added in v0.0.4 

func (i *InvertedIndexerV2) Count() (count int)

func (*InvertedIndexerV2) DebugInfo added in v0.0.4 

func (i *InvertedIndexerV2) DebugInfo() *debug.Debug

func (*InvertedIndexerV2) Del added in v0.0.4 

func (i *InvertedIndexerV2) Del(fieldName string, id document.DocId) (ok bool)

func (*InvertedIndexerV2) Delete added in v0.0.4 

func (i *InvertedIndexerV2) Delete(fieldName string)

func (*InvertedIndexerV2) GetValueById added in v0.0.4 

func (i *InvertedIndexerV2) GetValueById(id document.DocId) map[string][]string

func (*InvertedIndexerV2) Iterator added in v0.0.4 

func (i *InvertedIndexerV2) Iterator(name, value string) datastruct.Iterator

func (*InvertedIndexerV2) Range added in v0.0.14 

func (i *InvertedIndexerV2) Range(f func(key, value interface{}) bool)

func (*InvertedIndexerV2) SetDebug added in v0.0.4 

func (i *InvertedIndexerV2) SetDebug(level int)

func (*InvertedIndexerV2) Update added in v0.0.4 

func (i *InvertedIndexerV2) Update(fieldName string, ids []document.DocId)

type StorageIndex 

type StorageIndex interface {
	Get(filedName string, id document.DocId) interface{}
	Add(fieldName string, id document.DocId, value interface{}) error
	Del(fieldName string, id document.DocId) bool
	Iterator(fieldName string) datastruct.Iterator
	Count() int
	Range(func(key, value interface{}) bool)
	GetValueById(id document.DocId) map[string][]string
	SetDebug(level int)
	DebugInfo() *debug.Debug
}

type StorageIndexer 

type StorageIndexer struct {
	// contains filtered or unexported fields
}

func NewStorageIndexer 

func NewStorageIndexer() *StorageIndexer

func NewStorageIndexerV2 added in v0.0.14 

func NewStorageIndexerV2() *StorageIndexer

func (*StorageIndexer) Add 

func (s *StorageIndexer) Add(fieldName string, id document.DocId, value interface{}) (err error)

func (*StorageIndexer) Count 

func (s *StorageIndexer) Count() (count int)

func (*StorageIndexer) DebugInfo 

func (s *StorageIndexer) DebugInfo() *debug.Debug

func (*StorageIndexer) Del 

func (s *StorageIndexer) Del(fieldName string, id document.DocId) (ok bool)

func (*StorageIndexer) Get 

func (s *StorageIndexer) Get(fieldName string, id document.DocId) interface{}

func (*StorageIndexer) GetValueById 

func (s *StorageIndexer) GetValueById(id document.DocId) map[string][]string

func (*StorageIndexer) Iterator 

func (s *StorageIndexer) Iterator(fieldName string) datastruct.Iterator

func (*StorageIndexer) Range added in v0.0.4 

func (s *StorageIndexer) Range(f func(key, value interface{}) bool)

func (*StorageIndexer) SetDebug 

func (s *StorageIndexer) SetDebug(level int)

type StorageIndexerV2 added in v0.0.14 

type StorageIndexerV2 struct {
	// contains filtered or unexported fields
}

func (*StorageIndexerV2) Add added in v0.0.14 

func (s *StorageIndexerV2) Add(fieldName string, id document.DocId, value interface{}) (err error)

func (*StorageIndexerV2) Count added in v0.0.14 

func (s *StorageIndexerV2) Count() (count int)

func (*StorageIndexerV2) DebugInfo added in v0.0.14 

func (s *StorageIndexerV2) DebugInfo() *debug.Debug

func (*StorageIndexerV2) Del added in v0.0.14 

func (s *StorageIndexerV2) Del(fieldName string, id document.DocId) (ok bool)

func (*StorageIndexerV2) Get added in v0.0.14 

func (s *StorageIndexerV2) Get(fieldName string, id document.DocId) interface{}

func (*StorageIndexerV2) GetValueById added in v0.0.15 

func (s *StorageIndexerV2) GetValueById(id document.DocId) map[string][]string

func (*StorageIndexerV2) Iterator added in v0.0.14 

func (s *StorageIndexerV2) Iterator(fieldName string) datastruct.Iterator

func (*StorageIndexerV2) Range added in v0.0.14 

func (s *StorageIndexerV2) Range(f func(key, value interface{}) bool)

func (*StorageIndexerV2) SetDebug added in v0.0.14 

func (s *StorageIndexerV2) SetDebug(level int)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.