(context.Context)
| 1488 | } |
| 1489 | |
| 1490 | func (i *spansetIterator) Next(context.Context) (*traceql.Spanset, error) { |
| 1491 | res, err := i.iter.Next() |
| 1492 | if err != nil { |
| 1493 | return nil, err |
| 1494 | } |
| 1495 | if res == nil { |
| 1496 | return nil, nil |
| 1497 | } |
| 1498 | |
| 1499 | // The spanset is in the OtherEntries |
| 1500 | iface := res.OtherValueFromKey(otherEntrySpansetKey) |
| 1501 | if iface == nil { |
| 1502 | return nil, fmt.Errorf("engine assumption broken: spanset not found in other entries in spansetIterator") |
| 1503 | } |
| 1504 | ss, ok := iface.(*traceql.Spanset) |
| 1505 | if !ok { |
| 1506 | return nil, fmt.Errorf("engine assumption broken: spanset is not of type *traceql.Spanset in spansetIterator") |
| 1507 | } |
| 1508 | |
| 1509 | return ss, nil |
| 1510 | } |
| 1511 | |
| 1512 | func (i *spansetIterator) Close() { |
| 1513 | i.iter.Close() |
nothing calls this directly
no test coverage detected