Include additional detail when searching for traces

CHANGELOG.md

@@ -7,6 +7,7 @@
 * [ENHANCEMENT] Add support to tempo workloads to `overrides` from single configmap in microservice mode. [#896](https://github.com/grafana/tempo/pull/896) (@kavirajk)
 * [ENHANCEMENT] Make `overrides_config` block name consistent with Loki and Cortex in microservice mode. [#906](https://github.com/grafana/tempo/pull/906) (@kavirajk)
 * [ENHANCEMENT] Make `overrides_config` mount name static `tempo-overrides` in the tempo workloads in microservice mode. [#906](https://github.com/grafana/tempo/pull/914) (@kavirajk)
+* [ENHANCEMENT] Include additional detail when searching for traces [#916](https://github.com/grafana/tempo/pull/916) (@zalegrala)
 
 
 ## v1.1.0-rc.0 / 2021-08-11

modules/querier/querier.go

@@ -219,6 +219,7 @@ func (q *Querier) FindTraceByID(ctx context.Context, req *tempopb.TraceByIDReque
 			traceCountTotal++
 
 			span.LogFields(ot_log.String("msg", "combined trace protos from store"),
+				ot_log.Bool("found", completeTrace != nil),
 				ot_log.Int("combinedSpans", spanCountTotal),
 				ot_log.Int("combinedTraces", traceCountTotal))
 		}

tempodb/tempodb.go

@@ -291,15 +291,19 @@ func (rw *readerWriter) Find(ctx context.Context, tenantID string, id common.ID,
 	blocklist := rw.blocklist.Metas(tenantID)
 	compactedBlocklist := rw.blocklist.CompactedMetas(tenantID)
 	copiedBlocklist := make([]interface{}, 0, len(blocklist))
+	blocksSearched := 0
+	compactedBlocksSearched := 0
 
 	for _, b := range blocklist {
 		if includeBlock(b, id, blockStartBytes, blockEndBytes) {
 			copiedBlocklist = append(copiedBlocklist, b)
+			blocksSearched++
 		}
 	}
 	for _, c := range compactedBlocklist {
 		if includeCompactedBlock(c, id, blockStartBytes, blockEndBytes, rw.cfg.BlocklistPoll) {
 			copiedBlocklist = append(copiedBlocklist, &c.BlockMeta)
+			compactedBlocksSearched++
 		}
 	}
 	if len(copiedBlocklist) == 0 {
@@ -325,7 +329,12 @@ func (rw *readerWriter) Find(ctx context.Context, tenantID string, id common.ID,
 			ot_log.String("msg", "searching for trace in block"),
 			ot_log.String("blockID", meta.BlockID.String()),
 			ot_log.Bool("found", foundObject != nil),
-			ot_log.Int("bytes", len(foundObject)))
+			ot_log.Int("bytes", len(foundObject)),
+			ot_log.Int("live blocks", len(blocklist)),
+			ot_log.Int("live blocks searched", blocksSearched),
+			ot_log.Int("compacted blocks", len(compactedBlocklist)),
+			ot_log.Int("compacted blocks searched", compactedBlocksSearched),
+		)
 
 		return foundObject, meta.DataEncoding, nil
 	})