Function buildQueryFunc

pkg/ruler/compat.go:412–434

(
	engine promql.QueryEngine,
	client *frontendClient,
	q storage.Queryable,
	overrides RulesLimits,
	userID string,
	cfg Config,
	metrics *RuleEvalMetrics,
	logger log.Logger,
)

}

func buildQueryFunc(
	engine promql.QueryEngine,
	client *frontendClient,
	q storage.Queryable,
	overrides RulesLimits,
	userID string,
	cfg Config,
	metrics *RuleEvalMetrics,
	logger log.Logger,
) rules.QueryFunc {
	baseQueryFunc := engineQueryFunc(engine, client, q, overrides, userID, cfg.LookbackDelta)

	// apply metric middleware
	totalQueries := metrics.TotalQueriesVec.WithLabelValues(userID)
	failedQueries := metrics.FailedQueriesVec.WithLabelValues(userID)
	metricsFunc := metricsQueryFunc(baseQueryFunc, totalQueries, failedQueries)

	// apply statistic middleware
	if cfg.EnableQueryStats {
		return recordAndReportRuleQueryMetrics(metricsFunc, userID, metrics, logger)
	}
	return metricsFunc
}

type QueryableError struct {
	err error