querysharding

package

v0.35.0 Latest Latest Go to latest Published: May 2, 2024 License: Apache-2.0 Imports: 4 Imported by: 4

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

This section is empty.

This section is empty.

type Analyzer interface {
	Analyze(string) (QueryAnalysis, error)
}

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

func NewQueryAnalyzer() *CachedQueryAnalyzer

NewQueryAnalyzer creates a new QueryAnalyzer.

func (a *CachedQueryAnalyzer) Analyze(query string) (QueryAnalysis, error)

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

func (q *QueryAnalysis) IsShardable() bool

func (q *QueryAnalysis) ShardBy() bool

func (q *QueryAnalysis) ShardingLabels() []string

type QueryAnalyzer struct{}

QueryAnalyzer is an analyzer which determines whether a PromQL Query is shardable and using which labels.

func (a *QueryAnalyzer) Analyze(query string) (QueryAnalysis, error)

Analyze uses the following algorithm:

if a query has functions which cannot be sharded such as absent or absent_over_time, then treat the query as non shardable.
if a query has functions `label_join` or `label_replace`, calculate the shard labels based on grouping labels.
Walk the query and find the least common labelset used in grouping expressions. If non-empty, treat the query as shardable by those labels.
otherwise, treat the query as non-shardable.

The le label is excluded from sharding.