bleve

Documentation

Overview

Package bleve implements the search engine using a Bleve indexer.

Index

• Variables
• type Batch
  • func NewBatch(options BatchOptions) *Batch
  • func (b *Batch) Delete(uuid string)
  • func (b *Batch) Flush(index bleve.Index) error
  • func (b *Batch) Index(i *tree.IndexableNode)
  • func (b *Batch) LoadIndexableNode(indexNode *tree.IndexableNode, excludes map[string]struct{}) error
  • func (b *Batch) NamespacesProvider() *meta.NamespacesProvider
  • func (b *Batch) Size() int
• type BatchOptions
• type BleveServer
  • func NewBleveEngine(indexContent bool, configs map[string]interface{}) (*BleveServer, error)
  • func (s *BleveServer) ClearIndex(ctx context.Context) error
  • func (s *BleveServer) Close() error
  • func (s *BleveServer) DeleteNode(c context.Context, n *tree.Node) error
  • func (s *BleveServer) IndexNode(c context.Context, n *tree.Node, reloadCore bool, excludes map[string]struct{}) error
  • func (s *BleveServer) SearchNodes(c context.Context, queryObject *tree.Query, from int32, size int32, ...) error

Variables

var (
	BleveIndexPath = ""
	BatchSize      = 2000
)

Types

type Batch

type Batch struct {
	sync.Mutex
	// contains filtered or unexported fields
}

Batch avoids overflowing bleve index by batching indexation events (index/delete)

func NewBatch

func NewBatch(options BatchOptions) *Batch

func (*Batch) Delete

func (b *Batch) Delete(uuid string)

func (*Batch) Flush

func (b *Batch) Flush(index bleve.Index) error

func (*Batch) Index

func (b *Batch) Index(i *tree.IndexableNode)

func (*Batch) LoadIndexableNode

func (b *Batch) LoadIndexableNode(indexNode *tree.IndexableNode, excludes map[string]struct{}) error

func (*Batch) NamespacesProvider

func (b *Batch) NamespacesProvider() *meta.NamespacesProvider

func (*Batch) Size

func (b *Batch) Size() int

type BatchOptions

type BatchOptions struct {
	IndexContent bool
}

type BleveServer

type BleveServer struct {
	Router       views.Handler
	Engine       bleve.Index
	IndexContent bool
	// contains filtered or unexported fields
}

func NewBleveEngine

func NewBleveEngine(indexContent bool, configs map[string]interface{}) (*BleveServer, error)

func (*BleveServer) ClearIndex

func (s *BleveServer) ClearIndex(ctx context.Context) error

func (*BleveServer) Close

func (s *BleveServer) Close() error

func (*BleveServer) DeleteNode

func (s *BleveServer) DeleteNode(c context.Context, n *tree.Node) error

func (*BleveServer) IndexNode

func (s *BleveServer) IndexNode(c context.Context, n *tree.Node, reloadCore bool, excludes map[string]struct{}) error

func (*BleveServer) SearchNodes

func (s *BleveServer) SearchNodes(c context.Context, queryObject *tree.Query, from int32, size int32, resultChan chan *tree.Node, doneChan chan bool) error