Log fetched bucket index timestamps

Adds logging of bucket index timestamps after they're fetched, in queriers and store gateways.

pkg/querier/blocks_finder_bucket_index.go

@@ -11,6 +11,7 @@ import (
 	"time"
 
 	"github.com/go-kit/log"
+	"github.com/go-kit/log/level"
 	"github.com/grafana/dskit/services"
 	"github.com/oklog/ulid"
 	"github.com/pkg/errors"
@@ -40,6 +41,7 @@ type BucketIndexBlocksFinder struct {
 
 	cfg    BucketIndexBlocksFinderConfig
 	loader *bucketindex.Loader
+	logger log.Logger
 }
 
 func NewBucketIndexBlocksFinder(cfg BucketIndexBlocksFinderConfig, bkt objstore.Bucket, cfgProvider bucket.TenantConfigProvider, logger log.Logger, reg prometheus.Registerer) *BucketIndexBlocksFinder {
@@ -49,6 +51,7 @@ func NewBucketIndexBlocksFinder(cfg BucketIndexBlocksFinderConfig, bkt objstore.
 		cfg:     cfg,
 		loader:  loader,
 		Service: loader,
+		logger:  logger,
 	}
 }
 
@@ -77,6 +80,8 @@ func (f *BucketIndexBlocksFinder) GetBlocks(ctx context.Context, userID string,
 		return nil, newBucketIndexTooOldError(idx.GetUpdatedAt(), f.cfg.MaxStalePeriod)
 	}
 
+	level.Info(f.logger).Log("msg", "fetched bucket index", "userID", userID, "updatedAt", idx.UpdatedAt)
+
 	matchingBlocks := map[ulid.ULID]*bucketindex.Block{}
 
 	// Filter blocks containing samples within the range.

pkg/storegateway/bucket_index_metadata_fetcher.go

@@ -94,6 +94,8 @@ func (f *BucketIndexMetadataFetcher) Fetch(ctx context.Context) (metas map[ulid.
 		return nil, nil, errors.Wrapf(err, "read bucket index")
 	}
 
+	level.Info(f.logger).Log("msg", "fetched bucket index", "userID", f.userID, "updatedAt", idx.UpdatedAt)
+
 	// Build block metas out of the index.
 	metas = make(map[ulid.ULID]*block.Meta, len(idx.Blocks))
 	for _, b := range idx.Blocks {