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 | |