commons

Documentation

Overview

Package commons implements the search engine

Index

• Variables
• func NewBatch(ctx context.Context, nsProvider *meta.NsProvider, options BatchOptions, ...) indexer.Batch
• type BatchOptions
• type LocalBatch
  • func (b *LocalBatch) Flush(ctx context.Context, batchOpts ...indexer.BatchOption) error
  • func (b *LocalBatch) LoadIndexableNode(indexNode *tree.IndexableNode, excludes map[string]struct{}) error
• type QueryCodecProvider
• type Server
  • func NewServer(ctx context.Context, idx indexer.Indexer, provider QueryCodecProvider, ...) *Server
  • func (s *Server) ClearIndex(ctx context.Context) error
  • func (s *Server) Close(ctx context.Context) error
  • func (s *Server) DeleteNode(c context.Context, n *tree.Node) error
  • func (s *Server) Flush(ctx context.Context) error
  • func (s *Server) IndexNode(c context.Context, n *tree.Node, reloadCore bool) error
  • func (s *Server) SearchNodes(ctx context.Context, queryObject *tree.Query, from int32, size int32, ...) error

Variables

var (
	BatchPoolInit sync.Once
)

var (
	BatchSize = 2000
)

Functions

func NewBatch

func NewBatch(ctx context.Context, nsProvider *meta.NsProvider, options BatchOptions, inputOpts ...indexer.BatchOption) indexer.Batch

Types

type BatchOptions

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

type LocalBatch

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

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

func (*LocalBatch) Flush

func (b *LocalBatch) Flush(ctx context.Context, batchOpts ...indexer.BatchOption) error

func (*LocalBatch) LoadIndexableNode

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

type QueryCodecProvider

type QueryCodecProvider func(values configx.Values, metaProvider *meta.NsProvider) indexer.IndexCodex

type Server

type Server struct {
	indexer.Indexer
	// contains filtered or unexported fields
}

func NewServer

func NewServer(ctx context.Context, idx indexer.Indexer, provider QueryCodecProvider, batchOptions ...indexer.BatchOption) *Server

func (*Server) ClearIndex

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

func (*Server) Close

func (s *Server) Close(ctx context.Context) error

func (*Server) DeleteNode

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

func (*Server) Flush

func (s *Server) Flush(ctx context.Context) error

func (*Server) IndexNode

func (s *Server) IndexNode(c context.Context, n *tree.Node, reloadCore bool) error

func (*Server) SearchNodes

func (s *Server) SearchNodes(ctx context.Context, queryObject *tree.Query, from int32, size int32, sortField string, sortDesc bool, resultChan chan *tree.Node, facets chan *tree.SearchFacet, doneChan chan bool) error