querier

package
v0.0.0-...-90d47c1 Latest Latest
Warning

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

Go to latest
Published: Feb 28, 2018 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewEngine

func NewEngine(distributor Querier, chunkStore ChunkStore) *promql.Engine

NewEngine creates a new promql.Engine for cortex.

Types

type ChunkStore

type ChunkStore interface {
	Get(ctx context.Context, from, through model.Time, matchers ...*labels.Matcher) (model.Matrix, error)
}

ChunkStore is the interface we need to get chunks

type DummyAlertmanagerRetriever

type DummyAlertmanagerRetriever struct{}

DummyAlertmanagerRetriever implements AlertmanagerRetriever.

func (DummyAlertmanagerRetriever) Alertmanagers

func (r DummyAlertmanagerRetriever) Alertmanagers() []*url.URL

Alertmanagers implements AlertmanagerRetriever.

type DummyTargetRetriever

type DummyTargetRetriever struct{}

DummyTargetRetriever implements TargetRetriever.

func (DummyTargetRetriever) Targets

func (r DummyTargetRetriever) Targets() []*scrape.Target

Targets implements TargetRetriever.

type MergeQueryable

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

A MergeQueryable is a storage.Queryable that produces a storage.Querier which merges results from multiple underlying Queriers.

func NewQueryable

func NewQueryable(distributor Querier, chunkStore ChunkStore, mo bool) MergeQueryable

NewQueryable creates a new Queryable for cortex.

func (MergeQueryable) Querier

func (q MergeQueryable) Querier(ctx context.Context, mint, maxt int64) (storage.Querier, error)

Querier implements storage.Queryable.

func (MergeQueryable) RemoteReadHandler

func (q MergeQueryable) RemoteReadHandler(w http.ResponseWriter, r *http.Request)

RemoteReadHandler handles Prometheus remote read requests.

type Querier

type Querier interface {
	Query(ctx context.Context, from, to model.Time, matchers ...*labels.Matcher) (model.Matrix, error)
	MetricsForLabelMatchers(ctx context.Context, from, through model.Time, matchers ...*labels.Matcher) ([]metric.Metric, error)
	LabelValuesForLabelName(context.Context, model.LabelName) (model.LabelValues, error)
}

A Querier allows querying an underlying storage for time series samples or metadata.

Jump to

Keyboard shortcuts

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