@@ -21,8 +21,10 @@ import (
21
21
"fmt"
22
22
"os"
23
23
24
+ corev1 "k8s.io/api/core/v1"
24
25
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
25
26
"k8s.io/apimachinery/pkg/runtime"
27
+
26
28
_ "k8s.io/client-go/plugin/pkg/client/auth/gcp"
27
29
ctrl "sigs.k8s.io/controller-runtime"
28
30
api "sigs.k8s.io/controller-runtime/examples/crd/pkg"
@@ -56,6 +58,25 @@ func (r *reconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Resu
56
58
return ctrl.Result {}, err
57
59
}
58
60
61
+ cm := & corev1.ConfigMap {
62
+ TypeMeta : metav1.TypeMeta {
63
+ APIVersion : "v1" ,
64
+ Kind : "ConfigMap" ,
65
+ },
66
+ ObjectMeta : metav1.ObjectMeta {
67
+ Name : "test-cm" ,
68
+ Namespace : "default" ,
69
+ ClusterName : req .ClusterName ,
70
+ },
71
+ Data : map [string ]string {
72
+ "test-key" : "test-value" ,
73
+ },
74
+ }
75
+ if err := r .Create (ctx , cm ); err != nil {
76
+ log .Error (err , "unable to create configmap" )
77
+ return ctrl.Result {}, err
78
+ }
79
+
59
80
return ctrl.Result {}, nil
60
81
}
61
82
@@ -78,6 +99,11 @@ func main() {
78
99
setupLog .Error (err , "unable to add scheme" )
79
100
os .Exit (1 )
80
101
}
102
+ err = corev1 .AddToScheme (mgr .GetScheme ())
103
+ if err != nil {
104
+ setupLog .Error (err , "unable to add scheme" )
105
+ os .Exit (1 )
106
+ }
81
107
82
108
err = ctrl .NewControllerManagedBy (mgr ).
83
109
For (& api.ChaosPod {}).
0 commit comments