(e PipelineElement, m firstStageElement)
| 85 | } |
| 86 | |
| 87 | func newRootExprWithMetrics(e PipelineElement, m firstStageElement) *RootExpr { |
| 88 | p, ok := e.(Pipeline) |
| 89 | if !ok { |
| 90 | p = newPipeline(e) |
| 91 | } |
| 92 | |
| 93 | return &RootExpr{ |
| 94 | Pipeline: p, |
| 95 | MetricsPipeline: m, |
| 96 | } |
| 97 | } |
| 98 | |
| 99 | func newRootExprWithMetricsTwoStage(e PipelineElement, m1 firstStageElement, m2 secondStageElement) *RootExpr { |
| 100 | p, ok := e.(Pipeline) |