|
6 | 6 | "fmt"
|
7 | 7 | "math"
|
8 | 8 | "net/http"
|
| 9 | + "runtime/pprof" |
9 | 10 | "slices"
|
10 | 11 | "sort"
|
11 | 12 | "strconv"
|
@@ -548,18 +549,22 @@ func (d *Distributor) Push(ctx context.Context, req *logproto.PushRequest) (*log
|
548 | 549 | }
|
549 | 550 | }
|
550 | 551 | if shouldDiscoverLevels {
|
551 |
| - logLevel, ok := fieldDetector.extractLogLevel(lbs, structuredMetadata, entry) |
552 |
| - if ok { |
553 |
| - entry.StructuredMetadata = append(entry.StructuredMetadata, logLevel) |
554 |
| - } |
| 552 | + pprof.Do(ctx, pprof.Labels("action", "discover_log_level"), func(ctx context.Context) { |
| 553 | + logLevel, ok := fieldDetector.extractLogLevel(lbs, structuredMetadata, entry) |
| 554 | + if ok { |
| 555 | + entry.StructuredMetadata = append(entry.StructuredMetadata, logLevel) |
| 556 | + } |
| 557 | + }) |
555 | 558 | }
|
556 | 559 | if shouldDiscoverGenericFields {
|
557 |
| - for field, hints := range fieldDetector.validationContext.discoverGenericFields { |
558 |
| - extracted, ok := fieldDetector.extractGenericField(field, hints, lbs, structuredMetadata, entry) |
559 |
| - if ok { |
560 |
| - entry.StructuredMetadata = append(entry.StructuredMetadata, extracted) |
| 560 | + pprof.Do(ctx, pprof.Labels("action", "discover_generic_fields"), func(ctx context.Context) { |
| 561 | + for field, hints := range fieldDetector.validationContext.discoverGenericFields { |
| 562 | + extracted, ok := fieldDetector.extractGenericField(field, hints, lbs, structuredMetadata, entry) |
| 563 | + if ok { |
| 564 | + entry.StructuredMetadata = append(entry.StructuredMetadata, extracted) |
| 565 | + } |
561 | 566 | }
|
562 |
| - } |
| 567 | + }) |
563 | 568 | }
|
564 | 569 | stream.Entries[n] = entry
|
565 | 570 |
|
|
0 commit comments