Method Do

pkg/querier/tripperware/queryrange/results_cache.go:224–291

(ctx context.Context, r tripperware.Request)

}

func (s resultsCache) Do(ctx context.Context, r tripperware.Request) (tripperware.Response, error) {
	tenantIDs, err := users.TenantIDs(ctx)
	respWithStats := r.GetStats() != "" && s.cacheQueryableSamplesStats
	if err != nil {
		return nil, httpgrpc.Errorf(http.StatusBadRequest, "%s", err.Error())
	}

	// If cache_queryable_samples_stats is enabled we always need request the status upstream
	if s.cacheQueryableSamplesStats {
		r = r.WithStats("all")
	} else {
		r = r.WithStats("")
	}

	if s.shouldCache != nil && !s.shouldCache(r) {
		level.Debug(util_log.WithContext(ctx, s.logger)).Log("msg", "should not cache", "start", r.GetStart(), "spanID", jaegerSpanID(ctx))
		return s.next.Do(ctx, r)
	}

	key := s.splitter.GenerateCacheKey(ctx, users.JoinTenantIDs(tenantIDs), r)

	var (
		extents  []tripperware.Extent
		response tripperware.Response
	)

	maxCacheFreshness := validation.MaxDurationPerTenant(tenantIDs, s.limits.MaxCacheFreshness)
	maxCacheTime := int64(model.Now().Add(-maxCacheFreshness))
	if r.GetStart() > maxCacheTime {
		level.Debug(util_log.WithContext(ctx, s.logger)).Log("msg", "cache miss", "start", r.GetStart(), "spanID", jaegerSpanID(ctx))
		return s.next.Do(ctx, r)
	}

	cached, ok := s.get(ctx, key)
	if ok {
		response, extents, err = s.handleHit(ctx, r, cached, maxCacheTime)
	} else {
		response, extents, err = s.handleMiss(ctx, r, maxCacheTime)
	}

	if err == nil && len(extents) > 0 {
		extents, err := s.filterRecentExtents(r, maxCacheFreshness, extents)
		if err != nil {
			return nil, err
		}
		// Make sure we only cache old response format for backward compatibility.
		// TODO: expose a flag to switch to write new format.
		for i, ext := range extents {
			resp, err := extentToResponse(ext)
			if err != nil {
				return nil, err
			}
			// Convert response in extent to old format.
			resp = convertFromTripperwarePrometheusResponse(resp)
			any, err := types.MarshalAny(resp)
			if err != nil {
				return nil, err
			}