MCPcopy
hub / github.com/grafana/tempo / callback

Function callback

tempodb/encoding/vparquet4/block_search.go:476–495  ·  view source on GitHub ↗
(cb common.TagValuesCallbackV2, v parquet.Value)

Source from the content-addressed store, hash-verified

474}
475
476func callback(cb common.TagValuesCallbackV2, v parquet.Value) (stop bool) {
477 switch v.Kind() {
478
479 case parquet.Boolean:
480 return cb(traceql.NewStaticBool(v.Boolean()))
481
482 case parquet.Int32, parquet.Int64:
483 return cb(traceql.NewStaticInt(int(v.Int64())))
484
485 case parquet.Float, parquet.Double:
486 return cb(traceql.NewStaticFloat(v.Double()))
487
488 case parquet.ByteArray, parquet.FixedLenByteArray:
489 return cb(traceql.NewStaticString(v.String()))
490
491 default:
492 // Skip nils or unsupported type
493 return false
494 }
495}
496
497func rowGroupsFromFile(pf *parquet.File, opts common.SearchOptions) []parquet.RowGroup {
498 rgs := pf.RowGroups()

Callers 5

forEachMethod · 0.70
KeepColumnChunkMethod · 0.70
KeepValueMethod · 0.70
searchKeyValuesFunction · 0.70

Calls 6

NewStaticBoolFunction · 0.92
NewStaticIntFunction · 0.92
NewStaticFloatFunction · 0.92
NewStaticStringFunction · 0.92
KindMethod · 0.80
StringMethod · 0.45

Tested by

no test coverage detected