Package pipeline

type Pipeline ¶

type Pipeline struct {
    // contains filtered or unexported fields
}

func NewPipeline ¶

func NewPipeline(ctx *PipelineContext) *Pipeline

func (*Pipeline) AddSteps ¶

func (p *Pipeline) AddSteps(steps ...PipelineStep)

func (*Pipeline) Reconcile ¶

func (p *Pipeline) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

Reconcile the steps

type PipelineContext ¶

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 ¶

type PipelineStep func(ctx *PipelineContext) reconcile.Reconciler