pipeline

README

Pipeline Controller

In early implementation of controllers in v2.0, all common controllers are registered respectively and may be executed by different order, which result in bugs like #2449. So we introduce a pipeline controller to register them and execute them in a fixed order.

Documentation

Index

• type Pipeline
  • func NewPipeline(ctx *PipelineContext) *Pipeline
  • func (p *Pipeline) AddSteps(steps ...PipelineStep)
  • func (p *Pipeline) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
• type PipelineContext
• type PipelineStep

Types

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