Skip to content

Commit e6daa7a

Browse files
authored
feat: add readBatch span (#492)
* feat: add readBatch span we've observed large 'Stream' traces with a small semaphore or processor usage. To improve clarity also trace readBatch since it was observed causing slow requests in some instances * Update processor.go
1 parent 0ca8fce commit e6daa7a

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

input/elasticapm/processor.go

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -179,6 +179,8 @@ func (p *Processor) readBatch(
179179
reader *streamReader,
180180
result *Result,
181181
) (int, error) {
182+
_, sp := p.tracer.Start(ctx, "readBatch")
183+
defer sp.End()
182184

183185
// input events are decoded and appended to the batch
184186
origLen := len(*batch)

0 commit comments

Comments
 (0)