in pkg/telemetry/telemetry.go [312:329]
func (t *Telemetry) collectAllRecords() []*xray.TelemetryRecord {
records := make([]*xray.TelemetryRecord, bufferSize)
records = records[:0]
var record *xray.TelemetryRecord
done := false
for !done {
select {
case record = <-t.recordChan:
recordLen := len(records)
if recordLen < bufferSize {
records = append(records, record)
}
default:
done = true
}
}
return records
}