inverted

package
v0.8.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 2, 2025 License: Apache-2.0 Imports: 38 Imported by: 0

Documentation

Overview

Package inverted implements an inverted index repository.

Package inverted implements a inverted index repository.

Package inverted implements a inverted index repository.

Index

Constants

This section is empty.

Variables

View Source
var Analyzers map[string]*analysis.Analyzer

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

Functions

func BuildIndexModeQuery added in v0.8.0

func BuildIndexModeQuery(measureName string, criteria *modelv1.Criteria, schema logical.Schema) (index.Query, error)

BuildIndexModeQuery returns blugeQuery for index mode.

func BuildPropertyQuery added in v0.8.0

func BuildPropertyQuery(req *propertyv1.QueryRequest, groupField, idField string) (index.Query, error)

BuildPropertyQuery returns blugeQuery for property query.

func BuildQuery added in v0.8.0

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

BuildQuery returns blugeQuery for local indices.

func NewStore

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

NewStore create a new inverted index repository.

Types

type GlobalIndexError added in v0.7.0

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 added in v0.7.0

func (g GlobalIndexError) Error() string

type Metrics added in v0.7.0

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

Metrics is the metrics for the inverted index.

func NewMetrics added in v0.7.0

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

NewMetrics creates a new metrics for the inverted index.

func (*Metrics) DeleteAll added in v0.7.0

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
	CacheMaxBytes int
}

StoreOpts wraps options to create an inverted index repository.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL