storage

Documentation

Index

• type Index
  • func NewIndex(dir string, indexMapping *mapping.IndexMappingImpl, logger *zap.Logger) (*Index, error)
  • func (i *Index) BulkDelete(ids []string) (int, error)
  • func (i *Index) BulkIndex(docs []map[string]interface{}) (int, error)
  • func (i *Index) Close() error
  • func (i *Index) Delete(id string) error
  • func (i *Index) Get(id string) (map[string]interface{}, error)
  • func (i *Index) Index(id string, fields map[string]interface{}) error
  • func (i *Index) Mapping() *mapping.IndexMappingImpl
  • func (i *Index) Search(searchRequest *bleve.SearchRequest) (*bleve.SearchResult, error)
  • func (i *Index) SnapshotItems() <-chan *protobuf.Document
  • func (i *Index) Stats() map[string]interface{}

Types

type Index

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

func NewIndex

func NewIndex(dir string, indexMapping *mapping.IndexMappingImpl, logger *zap.Logger) (*Index, error)

func (*Index) BulkDelete

func (i *Index) BulkDelete(ids []string) (int, error)

func (*Index) BulkIndex

func (i *Index) BulkIndex(docs []map[string]interface{}) (int, error)

func (*Index) Close

func (i *Index) Close() error

func (*Index) Delete

func (i *Index) Delete(id string) error

func (*Index) Get

func (i *Index) Get(id string) (map[string]interface{}, error)

func (*Index) Index

func (i *Index) Index(id string, fields map[string]interface{}) error

func (*Index) Mapping

func (i *Index) Mapping() *mapping.IndexMappingImpl

func (*Index) Search

func (i *Index) Search(searchRequest *bleve.SearchRequest) (*bleve.SearchResult, error)

func (*Index) SnapshotItems

func (i *Index) SnapshotItems() <-chan *protobuf.Document

func (*Index) Stats

func (i *Index) Stats() map[string]interface{}