Method rewritePipeline

pkg/traceql/ast_rewriter.go:122–161

(p Pipeline)

}

func (f *fieldExpressionRewriter) rewritePipeline(p Pipeline) (Pipeline, int) {
	var rwCount int

	elements := make([]PipelineElement, 0, len(p.Elements))
	for _, elem := range p.Elements {
		switch elem := elem.(type) {
		case *SpansetFilter:
			if elem == nil {
				continue
			}
			fe, n := f.rewriteFieldExpression(elem.Expression)
			elements = append(elements, newSpansetFilter(fe))
			rwCount += n
		case ScalarFilter:
			lhs, n := f.rewriteScalarExpression(elem.LHS)
			rwCount += n
			rhs, n := f.rewriteScalarExpression(elem.RHS)
			rwCount += n
			elements = append(elements, newScalarFilter(elem.Op, lhs, rhs))
		case GroupOperation:
			fe, n := f.rewriteFieldExpression(elem.Expression)
			rwCount += n
			elements = append(elements, newGroupOperation(fe))
		case SpansetOperation:
			lhs, n := f.rewriteSpansetExpression(elem.LHS)
			rwCount += n
			rhs, n := f.rewriteSpansetExpression(elem.RHS)
			rwCount += n
			elements = append(elements, newSpansetOperation(elem.Op, lhs, rhs))
		case Pipeline:
			fe, n := f.rewritePipeline(elem)
			rwCount += n
			elements = append(elements, fe)
		default:
			elements = append(elements, elem)
		}
	}

	return newPipeline(elements...), rwCount
}

func (f *fieldExpressionRewriter) rewriteSpansetExpression(se SpansetExpression) (SpansetExpression, int) {
	switch se := se.(type) {