[ES-1365579] check if tracing is enabled for obj store lib

Signed-off-by: Yi Jin <[email protected]>

Author: jnyi

cmd/thanos/compact.go

@@ -326,6 +326,7 @@ func runCompact(
 
 	ctx, cancel := context.WithCancel(context.Background())
 	ctx = tracing.ContextWithTracer(ctx, tracer)
+	ctx = objstoretracing.ContextWithTracer(ctx, tracer) // objstore tracing uses a different tracer key in context.
 
 	defer func() {
 		if rerr != nil {

pkg/block/fetcher.go

@@ -223,13 +223,16 @@ type RecursiveLister struct {
 }
 
 func NewRecursiveLister(logger log.Logger, bkt objstore.InstrumentedBucketReader) *RecursiveLister {
+	level.Info(logger).Log("msg", "Using recursive block lister")
 	return &RecursiveLister{
 		logger: logger,
 		bkt:    bkt,
 	}
 }
 
 func (f *RecursiveLister) GetActiveAndPartialBlockIDs(ctx context.Context, ch chan<- ulid.ULID) (partialBlocks map[ulid.ULID]bool, err error) {
+	level.Info(f.logger).Log("msg", "recursive block lister started")
+	start := time.Now()
 	partialBlocks = make(map[ulid.ULID]bool)
 	err = f.bkt.Iter(ctx, "", func(name string) error {
 		parts := strings.Split(name, "/")
@@ -253,6 +256,7 @@ func (f *RecursiveLister) GetActiveAndPartialBlockIDs(ctx context.Context, ch ch
 		}
 		return nil
 	}, objstore.WithRecursiveIter())
+	level.Info(f.logger).Log("msg", "recursive block lister ended", "duration", time.Since(start))
 	return partialBlocks, err
 }
 
@@ -264,13 +268,17 @@ type ConcurrentLister struct {
 }
 
 func NewConcurrentLister(logger log.Logger, bkt objstore.InstrumentedBucketReader) *ConcurrentLister {
+	level.Info(logger).Log("msg", "Using concurrent block lister")
 	return &ConcurrentLister{
 		logger: logger,
 		bkt:    bkt,
 	}
 }
 
 func (f *ConcurrentLister) GetActiveAndPartialBlockIDs(ctx context.Context, ch chan<- ulid.ULID) (partialBlocks map[ulid.ULID]bool, err error) {
+	level.Info(f.logger).Log("msg", "concurrent block lister started")
+	start := time.Now()
+	defer level.Info(f.logger).Log("msg", "concurrent block lister end", "duration", time.Since(start))
 	const concurrency = 64
 
 	partialBlocks = make(map[ulid.ULID]bool)
@@ -519,7 +527,7 @@ func (f *BaseFetcher) fetchMetadata(ctx context.Context) (interface{}, error) {
 		ch  = make(chan ulid.ULID, f.concurrency)
 		mtx sync.Mutex
 	)
-	level.Debug(f.logger).Log("msg", "fetching meta data", "concurrency", f.concurrency, "cache_dir", f.cacheDir)
+	level.Info(f.logger).Log("msg", "fetching meta data", "concurrency", f.concurrency, "cache_dir", f.cacheDir)
 	for i := 0; i < f.concurrency; i++ {
 		eg.Go(func() error {
 			numBlocks := 0