Add appends one or more stages to the pipeline.
(stages ...Stage)
| 99 | |
| 100 | // Add appends one or more stages to the pipeline. |
| 101 | func (p *Pipeline) Add(stages ...Stage) { |
| 102 | if p.hasStarted() { |
| 103 | panic("attempt to modify a pipeline that has already started") |
| 104 | } |
| 105 | |
| 106 | p.stages = append(p.stages, stages...) |
| 107 | } |
| 108 | |
| 109 | // AddWithIgnoredError appends one or more stages that are ignoring |
| 110 | // the passed in error to the pipeline. |
nothing calls this directly
no test coverage detected