(context.Context)
| 1250 | } |
| 1251 | |
| 1252 | func (i *spansetIterator) Next(context.Context) (*traceql.Spanset, error) { |
| 1253 | res, err := i.iter.Next() |
| 1254 | if err != nil { |
| 1255 | return nil, err |
| 1256 | } |
| 1257 | if res == nil { |
| 1258 | return nil, nil |
| 1259 | } |
| 1260 | |
| 1261 | // The spanset is in the OtherEntries |
| 1262 | iface := res.OtherValueFromKey(otherEntrySpansetKey) |
| 1263 | if iface == nil { |
| 1264 | return nil, fmt.Errorf("engine assumption broken: spanset not found in other entries in spansetIterator") |
| 1265 | } |
| 1266 | ss, ok := iface.(*traceql.Spanset) |
| 1267 | if !ok { |
| 1268 | return nil, fmt.Errorf("engine assumption broken: spanset is not of type *traceql.Spanset in spansetIterator") |
| 1269 | } |
| 1270 | |
| 1271 | return ss, nil |
| 1272 | } |
| 1273 | |
| 1274 | func (i *spansetIterator) Close() { |
| 1275 | i.iter.Close() |
nothing calls this directly
no test coverage detected