@@ -29,12 +29,12 @@ import (
2929 "sigs.k8s.io/multicluster-runtime/pkg/multicluster"
3030 mcsingle "sigs.k8s.io/multicluster-runtime/providers/single"
3131
32+ computev1alpha "go.datum.net/compute/api/v1alpha"
33+ "go.datum.net/compute/internal/config"
34+ "go.datum.net/compute/internal/controller"
35+ computewebhook "go.datum.net/compute/internal/webhook"
36+ computev1alphawebhooks "go.datum.net/compute/internal/webhook/v1alpha"
3237 networkingv1alpha "go.datum.net/network-services-operator/api/v1alpha"
33- computev1alpha "go.datum.net/workload-operator/api/v1alpha"
34- "go.datum.net/workload-operator/internal/config"
35- "go.datum.net/workload-operator/internal/controller"
36- computewebhook "go.datum.net/workload-operator/internal/webhook"
37- computev1alphawebhooks "go.datum.net/workload-operator/internal/webhook/v1alpha"
3838 multiclusterproviders "go.miloapis.com/milo/pkg/multicluster-runtime"
3939 milomulticluster "go.miloapis.com/milo/pkg/multicluster-runtime/milo"
4040 // +kubebuilder:scaffold:imports
@@ -87,7 +87,7 @@ func main() {
8787
8888 ctrl .SetLogger (zap .New (zap .UseFlagOptions (& opts )))
8989
90- setupLog .Info ("starting workload-operator " ,
90+ setupLog .Info ("starting compute " ,
9191 "version" , version ,
9292 "gitCommit" , gitCommit ,
9393 "gitTreeState" , gitTreeState ,
@@ -136,12 +136,17 @@ func main() {
136136
137137 metricsServerOptions := serverConfig .MetricsServer .Options (ctx , deploymentClusterClient )
138138
139- webhookServer := webhook .NewServer (
140- serverConfig .WebhookServer .Options (ctx , deploymentClusterClient ),
141- )
139+ var webhookServer webhook.Server
140+ if serverConfig .WebhookServer != nil {
141+ webhookServer = webhook .NewServer (
142+ serverConfig .WebhookServer .Options (ctx , deploymentClusterClient ),
143+ )
142144
143- if serverConfig .Discovery .Mode != multiclusterproviders .ProviderSingle {
144- webhookServer = computewebhook .NewClusterAwareWebhookServer (webhookServer )
145+ if serverConfig .Discovery .Mode != multiclusterproviders .ProviderSingle {
146+ webhookServer = computewebhook .NewClusterAwareWebhookServer (webhookServer )
147+ }
148+ } else {
149+ setupLog .Info ("webhookServer not configured; admission webhook server disabled" )
145150 }
146151
147152 mgr , err := mcmanager .New (cfg , provider , ctrl.Options {
@@ -186,9 +191,11 @@ func main() {
186191 os .Exit (1 )
187192 }
188193
189- if err = computev1alphawebhooks .SetupWorkloadWebhookWithManager (mgr ); err != nil {
190- setupLog .Error (err , "unable to create webhook" , "webhook" , "Workload" )
191- os .Exit (1 )
194+ if serverConfig .WebhookServer != nil {
195+ if err = computev1alphawebhooks .SetupWorkloadWebhookWithManager (mgr ); err != nil {
196+ setupLog .Error (err , "unable to create webhook" , "webhook" , "Workload" )
197+ os .Exit (1 )
198+ }
192199 }
193200
194201 // +kubebuilder:scaffold:builder
0 commit comments