queryengine

Documentation

Index

• type GraviolaQueryEngine
  • func NewGraviolaQueryEngine(logger *slog.Logger, metricRegistry *prometheus.Registry, ...) *GraviolaQueryEngine
  • func (gravQueryEng *GraviolaQueryEngine) NewInstantQuery(ctx context.Context, queriable storage.Queryable, opts promql.QueryOpts, ...) (promql.Query, error)
  • func (gravQueryEng *GraviolaQueryEngine) NewRangeQuery(ctx context.Context, queriable storage.Queryable, opts promql.QueryOpts, ...) (promql.Query, error)
  • func (gravQueryEng *GraviolaQueryEngine) SetQueryLogger(_ promql.QueryLogger)

Types

type GraviolaQueryEngine

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

This is a thin wrapper of Prometheus query engine, used to make it easier to debug and add telemetry. A query engine breaks the query into smaller pieces and send those pieces to the storage.

func NewGraviolaQueryEngine

func NewGraviolaQueryEngine(
	logger *slog.Logger, metricRegistry *prometheus.Registry, conf config.GraviolaConfig,
) *GraviolaQueryEngine

func (*GraviolaQueryEngine) NewInstantQuery

func (gravQueryEng *GraviolaQueryEngine) NewInstantQuery(
	ctx context.Context, queriable storage.Queryable, opts promql.QueryOpts, qs string, ts time.Time,
) (promql.Query, error)

QueryEngine

func (*GraviolaQueryEngine) NewRangeQuery

func (gravQueryEng *GraviolaQueryEngine) NewRangeQuery(
	ctx context.Context, queriable storage.Queryable, opts promql.QueryOpts, qs string, start, end time.Time,
	interval time.Duration,
) (promql.Query, error)

QueryEngine

func (*GraviolaQueryEngine) SetQueryLogger

func (gravQueryEng *GraviolaQueryEngine) SetQueryLogger(_ promql.QueryLogger)

QueryEngine