...
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16 package condition
17
18 import (
19 "sigs.k8s.io/controller-runtime/pkg/reconcile"
20
21 "github.com/chaos-mesh/chaos-mesh/controllers/common/pipeline"
22 "github.com/chaos-mesh/chaos-mesh/controllers/config"
23 )
24
25 func Step(ctx *pipeline.PipelineContext) reconcile.Reconciler {
26 setupLog := ctx.Logger.WithName("setup-condition")
27 name := ctx.Object.Name + "-condition"
28 if !config.ShouldSpawnController(name) {
29 return nil
30 }
31
32 setupLog.Info("setting up controller", "name", name)
33
34 return &Reconciler{
35 Object: ctx.Object.Object,
36 Client: ctx.Client,
37 Recorder: ctx.Mgr.GetEventRecorderFor("condition"),
38 Log: ctx.Logger.WithName("condition"),
39 }
40 }
41