inverted

Documentation

Overview

Package inverted implements an inverted index repository.

Package inverted implements a inverted index repository.

Package inverted implements a inverted index repository.

Index

• Variables
• func BuildLocalQuery(criteria *modelv1.Criteria, schema logical.Schema, entityDict map[string]int, ...) (index.Query, [][]*modelv1.TagValue, bool, error)
• func NewStore(opts StoreOpts) (index.SeriesStore, error)
• type GlobalIndexError
  • func (g GlobalIndexError) Error() string
• type Metrics
  • func NewMetrics(factory *observability.Factory, labelNames ...string) *Metrics
  • func (m *Metrics) DeleteAll(labelValues ...string)
• type StoreOpts

Variables

var Analyzers map[databasev1.IndexRule_Analyzer]*analysis.Analyzer

Analyzers is a map that associates each IndexRule_Analyzer type with a corresponding Analyzer.

Functions

func BuildLocalQuery

func BuildLocalQuery(criteria *modelv1.Criteria, schema logical.Schema, entityDict map[string]int,
	entity []*modelv1.TagValue,
) (index.Query, [][]*modelv1.TagValue, bool, error)

BuildLocalQuery returns blugeQuery for local indices.

func NewStore

func NewStore(opts StoreOpts) (index.SeriesStore, error)

NewStore create a new inverted index repository.

Types

type GlobalIndexError

type GlobalIndexError struct {
	IndexRule *databasev1.IndexRule
	Expr      logical.LiteralExpr
}

GlobalIndexError represents a index rule is "global". The local filter can't handle it.

func (GlobalIndexError) Error

func (g GlobalIndexError) Error() string

type Metrics

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

Metrics is the metrics for the inverted index.

func NewMetrics

func NewMetrics(factory *observability.Factory, labelNames ...string) *Metrics

NewMetrics creates a new metrics for the inverted index.

func (*Metrics) DeleteAll

func (m *Metrics) DeleteAll(labelValues ...string)

DeleteAll deletes all metrics with the given label values.

type StoreOpts

type StoreOpts struct {
	Logger       *logger.Logger
	Metrics      *Metrics
	Path         string
	BatchWaitSec int64
}

StoreOpts wraps options to create an inverted index repository.