func()

in pkg/processor/processor.go [142:155]

• 12 lines of code
• 3 McCabe index (conditional complexity)

func (p *Processor) receiveTraceSegment(ts *tracesegment.TraceSegment, batch []*tracesegment.TraceSegment) []*tracesegment.TraceSegment {
	atomic.AddUint64(&p.count, 1)
	batch = append(batch, ts)

	if len(batch) >= p.batchSize {
		log.Debug("processor: sending complete batch")
		batch = p.sendBatchAsync(batch)
	} else if p.pool.CurrentBuffersLen() == 0 {
		log.Debug("processor: sending partial batch due to load on buffer pool")
		batch = p.sendBatchAsync(batch)
	}

	return batch
}