bluge

Documentation

Overview

Package bluge organizes codes of the indexing library bluge

Index

• func ParseAggsFilterRangeQuery(rangeQuery *indexlib.RangeQuery) (search.Aggregation, error)
• func ParseRangeQuery(rangeQuery *indexlib.RangeQuery) (bluge.Query, error)
• type BlugeReader
  • func MergeReader(config *indexlib.Config, segments []string, readers []indexlib.Reader) (*BlugeReader, error)
  • func NewBlugeReader(config *indexlib.Config, segments []string, readers []*bluge.Reader, ...) *BlugeReader
  • func (b *BlugeReader) Close()
  • func (b *BlugeReader) Count() int
  • func (b *BlugeReader) OpenReader() error
  • func (b *BlugeReader) Search(ctx context.Context, query indexlib.QueryRequest, limit, from int) (*indexlib.QueryResponse, error)
• type BlugeWriter
  • func NewBlugeWriter(config *indexlib.Config, mappings protocol.Mappings, index string, ...) *BlugeWriter
  • func (b *BlugeWriter) Batch(docs map[string]protocol.Document) error
  • func (b *BlugeWriter) Close()
  • func (b *BlugeWriter) Insert(docID string, doc protocol.Document) error
  • func (b *BlugeWriter) OpenWriter() error
  • func (b *BlugeWriter) Reader() (indexlib.Reader, error)
• type DocHeap
  • func (h *DocHeap) Len() int
  • func (h *DocHeap) Less(i, j int) bool
  • func (h *DocHeap) Pop() any
  • func (h *DocHeap) Push(x any)
  • func (h *DocHeap) Swap(i, j int)
• type ReaderResult

Functions

func ParseAggsFilterRangeQuery

func ParseAggsFilterRangeQuery(rangeQuery *indexlib.RangeQuery) (search.Aggregation, error)

func ParseRangeQuery

func ParseRangeQuery(rangeQuery *indexlib.RangeQuery) (bluge.Query, error)

Types

type BlugeReader

type BlugeReader struct {
	*indexlib.Config
	Segments []string
	Readers  []*bluge.Reader
	// contains filtered or unexported fields
}

func MergeReader

func MergeReader(
	config *indexlib.Config,
	segments []string,
	readers []indexlib.Reader,
) (*BlugeReader, error)

MergeReader multiple readers into one BlugeReader. The readers(or their underlying readers) must be type of BlugeReader.

func NewBlugeReader

func NewBlugeReader(
	config *indexlib.Config,
	segments []string,
	readers []*bluge.Reader,
	closeHook func(*BlugeReader),
) *BlugeReader

func (*BlugeReader) Close

func (b *BlugeReader) Close()

func (*BlugeReader) Count

func (b *BlugeReader) Count() int

func (*BlugeReader) OpenReader

func (b *BlugeReader) OpenReader() error

func (*BlugeReader) Search

func (b *BlugeReader) Search(
	ctx context.Context,
	query indexlib.QueryRequest,
	limit, from int,
) (*indexlib.QueryResponse, error)

type BlugeWriter

type BlugeWriter struct {
	*indexlib.Config
	Mappings protocol.Mappings
	Index    string
	Segment  string
	Writer   *bluge.Writer
}

func NewBlugeWriter

func NewBlugeWriter(
	config *indexlib.Config,
	mappings protocol.Mappings,
	index string,
	segment string,
) *BlugeWriter

func (*BlugeWriter) Batch

func (b *BlugeWriter) Batch(
	docs map[string]protocol.Document,
) error

func (*BlugeWriter) Close

func (b *BlugeWriter) Close()

func (*BlugeWriter) Insert

func (b *BlugeWriter) Insert(
	docID string,
	doc protocol.Document,
) error

func (*BlugeWriter) OpenWriter

func (b *BlugeWriter) OpenWriter() error

func (*BlugeWriter) Reader

func (b *BlugeWriter) Reader() (indexlib.Reader, error)

type DocHeap

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

An DocHeap is a min-heap of search.DocumentMatch.

func (*DocHeap) Len

func (h *DocHeap) Len() int

func (*DocHeap) Less

func (h *DocHeap) Less(i, j int) bool

func (*DocHeap) Pop

func (h *DocHeap) Pop() any

func (*DocHeap) Push

func (h *DocHeap) Push(x any)

func (*DocHeap) Swap

func (h *DocHeap) Swap(i, j int)

type ReaderResult

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