querier

Documentation

Index

• func NewEngine(distributor Querier, chunkStore ChunkStore) *promql.Engine
• type ChunkStore
• type DummyAlertmanagerRetriever
  • func (r DummyAlertmanagerRetriever) Alertmanagers() []*url.URL
• type DummyTargetRetriever
  • func (r DummyTargetRetriever) Targets() []*scrape.Target
• type MergeQueryable
  • func NewQueryable(distributor Querier, chunkStore ChunkStore, mo bool) MergeQueryable
  • func (q MergeQueryable) Querier(ctx context.Context, mint, maxt int64) (storage.Querier, error)
  • func (q MergeQueryable) RemoteReadHandler(w http.ResponseWriter, r *http.Request)
• type Querier

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.