(context.Context)
| 1427 | } |
| 1428 | |
| 1429 | func (i *spansetIterator) Next(context.Context) (*traceql.Spanset, error) { |
| 1430 | res, err := i.iter.Next() |
| 1431 | if err != nil { |
| 1432 | return nil, err |
| 1433 | } |
| 1434 | if res == nil { |
| 1435 | return nil, nil |
| 1436 | } |
| 1437 | |
| 1438 | // The spanset is in the OtherEntries |
| 1439 | iface := res.OtherValueFromKey(otherEntrySpansetKey) |
| 1440 | if iface == nil { |
| 1441 | return nil, fmt.Errorf("engine assumption broken: spanset not found in other entries in spansetIterator") |
| 1442 | } |
| 1443 | ss, ok := iface.(*traceql.Spanset) |
| 1444 | if !ok { |
| 1445 | return nil, fmt.Errorf("engine assumption broken: spanset is not of type *traceql.Spanset in spansetIterator") |
| 1446 | } |
| 1447 | |
| 1448 | return ss, nil |
| 1449 | } |
| 1450 | |
| 1451 | func (i *spansetIterator) Close() { |
| 1452 | i.iter.Close() |
nothing calls this directly
no test coverage detected