es

Documentation

Index

• type ElasticSearchIndexer
  • func NewElasticSearchIndexer(esNodes []string, syncUpdates bool) (*ElasticSearchIndexer, error)
  • func (i *ElasticSearchIndexer) FindByID(linkID uuid.UUID) (*index.Document, error)
  • func (i *ElasticSearchIndexer) Index(doc *index.Document) error
  • func (i *ElasticSearchIndexer) Search(q index.Query) (index.Iterator, error)
  • func (i *ElasticSearchIndexer) UpdateScore(linkID uuid.UUID, score float64) error

Types

type ElasticSearchIndexer

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

ElasticSearchIndexer is an Indexer implementation that uses an elastic search instance to catalogue and search documents.

func NewElasticSearchIndexer

func NewElasticSearchIndexer(esNodes []string, syncUpdates bool) (*ElasticSearchIndexer, error)

NewElasticSearchIndexer creates a text indexer that uses an in-memory bleve instance for indexing documents.

func (*ElasticSearchIndexer) FindByID

func (i *ElasticSearchIndexer) FindByID(linkID uuid.UUID) (*index.Document, error)

FindByID looks up a document by its link ID.

func (*ElasticSearchIndexer) Index

func (i *ElasticSearchIndexer) Index(doc *index.Document) error

Index inserts a new document to the index or updates the index entry for and existing document.

func (*ElasticSearchIndexer) Search

func (i *ElasticSearchIndexer) Search(q index.Query) (index.Iterator, error)

Search the index for a particular query and return back a result iterator.

func (*ElasticSearchIndexer) UpdateScore

func (i *ElasticSearchIndexer) UpdateScore(linkID uuid.UUID, score float64) error

UpdateScore updates the PageRank score for a document with the specified link ID. If no such document exists, a placeholder document with the provided score will be created.