type Pipeline struct {
// contains filtered or unexported fields
}
func NewPipeline(ctx *PipelineContext) *Pipeline
func (p *Pipeline) AddSteps(steps ...PipelineStep)
func (p *Pipeline) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
Reconcile the steps
type PipelineContext struct { Object *types.Object Mgr ctrl.Manager Client client.Client client.Reader Logger logr.Logger RecorderBuilder *recorder.RecorderBuilder Impl chaosimpltypes.ChaosImpl Selector *selector.Selector }
type PipelineStep func(ctx *PipelineContext) reconcile.Reconciler