@@ -21,6 +21,7 @@ import (
21
21
"k8s.io/client-go/rest"
22
22
"k8s.io/client-go/tools/clientcmd"
23
23
ctrl "sigs.k8s.io/controller-runtime"
24
+ "sigs.k8s.io/controller-runtime/pkg/manager"
24
25
25
26
"github.com/gitpod-io/gitpod/common-go/log"
26
27
"github.com/gitpod-io/gitpod/ws-daemon/api"
@@ -151,16 +152,17 @@ func NewDaemon(config Config, reg prometheus.Registerer) (*Daemon, error) {
151
152
return nil
152
153
}))
153
154
154
- mgr , err := ctrl .NewManager (restCfg , ctrl.Options {
155
- Scheme : scheme ,
156
- Port : 9443 ,
157
- Namespace : config .Runtime .KubernetesNamespace ,
158
- })
159
- if err != nil {
160
- return nil , err
161
- }
162
-
155
+ var mgr manager.Manager
163
156
if config .WorkspaceController .Enabled {
157
+ mgr , err := ctrl .NewManager (restCfg , ctrl.Options {
158
+ Scheme : scheme ,
159
+ Port : 9443 ,
160
+ Namespace : config .Runtime .KubernetesNamespace ,
161
+ })
162
+ if err != nil {
163
+ return nil , err
164
+ }
165
+
164
166
log .Info ("enabling workspace CRD controller" )
165
167
166
168
contentCfg := config .Content
@@ -262,12 +264,15 @@ func (d *Daemon) Start() error {
262
264
263
265
var ctx context.Context
264
266
ctx , d .cancel = context .WithCancel (context .Background ())
265
- go func () {
266
- err := d .mgr .Start (ctx )
267
- if err != nil {
268
- log .WithError (err ).Fatal ("cannot start controller" )
269
- }
270
- }()
267
+
268
+ if d .Config .WorkspaceController .Enabled {
269
+ go func () {
270
+ err := d .mgr .Start (ctx )
271
+ if err != nil {
272
+ log .WithError (err ).Fatal ("cannot start controller" )
273
+ }
274
+ }()
275
+ }
271
276
272
277
return nil
273
278
}
0 commit comments