func AllSteps() []pipeline.PipelineStep
func Bootstrap(params Params) error
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 }
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.
type PickChildCRDPredicate struct { predicate.Funcs }
func (PickChildCRDPredicate) Update(e event.UpdateEvent) bool
Update implements UpdateEvent filter for child CRD.
type RemoteChaosPredicate struct { predicate.Funcs }
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
StatusRecordEventsChangePredicate skip the update event, when we Only update object.status.experiment.records[].events
type StatusRecordEventsChangePredicate struct { predicate.Funcs }
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
Name | Synopsis |
---|---|
.. | |
condition | |
desiredphase | |
finalizers | |
pipeline | |
records |