common

Documentation

Index

• func AllSteps() []pipeline.PipelineStep
• func Bootstrap(params Params) error
• type Params
• type PickChildCRDPredicate
  • func (PickChildCRDPredicate) Update(e event.UpdateEvent) bool
• type RemoteChaosPredicate
  • func (RemoteChaosPredicate) Create(e event.CreateEvent) bool
  • func (RemoteChaosPredicate) Delete(e event.DeleteEvent) bool
  • func (RemoteChaosPredicate) Generic(e event.GenericEvent) bool
  • func (RemoteChaosPredicate) Update(e event.UpdateEvent) bool
• type StatusRecordEventsChangePredicate
  • func (StatusRecordEventsChangePredicate) Update(e event.UpdateEvent) bool

Functions

func AllSteps

func AllSteps() []pipeline.PipelineStep

func Bootstrap

func Bootstrap(params Params) error

Types

type Params

type Params struct {
	fx.In

	Mgr             ctrl.Manager
	Client          client.Client
	Logger          logr.Logger
	Selector        *selector.Selector
	RecorderBuilder *recorder.RecorderBuilder
	Impls           []*chaosimpltypes.ChaosImplPair `group:"impl"`
	Reader          client.Reader                   `name:"no-cache"`
	Steps           []pipeline.PipelineStep
}

type PickChildCRDPredicate

type PickChildCRDPredicate struct {
	predicate.Funcs
}

PickChildCRDPredicate allows events to trigger the Reconcile of Chaos CRD, for example: Reconcile of IOChaos could be triggered by changes on PodIOChaos. For now, we have PodHttpChaos/PodIOChaos/PodNetworkChaos which require to follow this pattern.

func (PickChildCRDPredicate) Update

func (PickChildCRDPredicate) Update(e event.UpdateEvent) bool

Update implements UpdateEvent filter for child CRD.

type RemoteChaosPredicate

type RemoteChaosPredicate struct {
	predicate.Funcs
}

func (RemoteChaosPredicate) Create

func (RemoteChaosPredicate) Create(e event.CreateEvent) bool

func (RemoteChaosPredicate) Delete

func (RemoteChaosPredicate) Delete(e event.DeleteEvent) bool

func (RemoteChaosPredicate) Generic

func (RemoteChaosPredicate) Generic(e event.GenericEvent) bool

func (RemoteChaosPredicate) Update

func (RemoteChaosPredicate) Update(e event.UpdateEvent) bool

type StatusRecordEventsChangePredicate

type StatusRecordEventsChangePredicate struct {
	predicate.Funcs
}

StatusRecordEventsChangePredicate skip the update event, when we Only update object.status.experiment.records[].events

func (StatusRecordEventsChangePredicate) Update

func (StatusRecordEventsChangePredicate) Update(e event.UpdateEvent) bool

Update implements UpdateEvent filter for update to filter the events which we Only update object.status.experiment.records[].events