Method Do

pkg/querier/tripperware/instantquery/limits.go:37–61

(ctx context.Context, r tripperware.Request)

}

func (l limitsMiddleware) Do(ctx context.Context, r tripperware.Request) (tripperware.Response, error) {
	log, ctx := spanlogger.New(ctx, "limits")
	defer log.Finish()

	tenantIDs, err := users.TenantIDs(ctx)
	if err != nil {
		return nil, httpgrpc.Errorf(http.StatusBadRequest, "%s", err.Error())
	}

	// Enforce the max query length.
	if maxQueryLength := validation.SmallestPositiveNonZeroDurationPerTenant(tenantIDs, l.MaxQueryLength); maxQueryLength > 0 {
		expr, err := cortexparser.ParseExpr(r.GetQuery())
		if err != nil {
			return nil, httpgrpc.Errorf(http.StatusBadRequest, "%s", err.Error())
		}

		// Enforce query length across all selectors in the query.
		length := promql.FindNonOverlapQueryLength(expr, 0, 0, l.lookbackDelta)
		if length > maxQueryLength {
			return nil, httpgrpc.Errorf(http.StatusBadRequest, validation.ErrQueryTooLong, length, maxQueryLength)
		}
	}

	return l.next.Do(ctx, r)
}