Skip to content

Commit c2f2842

Browse files
authored
chore(dca): Config component migration in webhook and config (#32247)
1 parent 2ad528f commit c2f2842

File tree

7 files changed

+91
-85
lines changed

7 files changed

+91
-85
lines changed

pkg/clusteragent/admission/controllers/webhook/config.go

Lines changed: 10 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,7 @@ import (
1313
"fmt"
1414
"strings"
1515

16-
pkgconfigsetup "github.com/DataDog/datadog-agent/pkg/config/setup"
16+
"github.com/DataDog/datadog-agent/comp/core/config"
1717
"github.com/DataDog/datadog-agent/pkg/util/kubernetes/apiserver/common"
1818
)
1919

@@ -36,21 +36,21 @@ type Config struct {
3636
}
3737

3838
// NewConfig creates a webhook controller configuration
39-
func NewConfig(admissionV1Enabled, namespaceSelectorEnabled, matchConditionsSupported bool) Config {
39+
func NewConfig(admissionV1Enabled, namespaceSelectorEnabled, matchConditionsSupported bool, datadogConfig config.Component) Config {
4040
return Config{
41-
webhookName: pkgconfigsetup.Datadog().GetString("admission_controller.webhook_name"),
42-
secretName: pkgconfigsetup.Datadog().GetString("admission_controller.certificate.secret_name"),
43-
validationEnabled: pkgconfigsetup.Datadog().GetBool("admission_controller.validation.enabled"),
44-
mutationEnabled: pkgconfigsetup.Datadog().GetBool("admission_controller.mutation.enabled"),
41+
webhookName: datadogConfig.GetString("admission_controller.webhook_name"),
42+
secretName: datadogConfig.GetString("admission_controller.certificate.secret_name"),
43+
validationEnabled: datadogConfig.GetBool("admission_controller.validation.enabled"),
44+
mutationEnabled: datadogConfig.GetBool("admission_controller.mutation.enabled"),
4545
namespace: common.GetResourcesNamespace(),
4646
admissionV1Enabled: admissionV1Enabled,
4747
namespaceSelectorEnabled: namespaceSelectorEnabled,
4848
matchConditionsSupported: matchConditionsSupported,
49-
svcName: pkgconfigsetup.Datadog().GetString("admission_controller.service_name"),
49+
svcName: datadogConfig.GetString("admission_controller.service_name"),
5050
svcPort: int32(443),
51-
timeout: pkgconfigsetup.Datadog().GetInt32("admission_controller.timeout_seconds"),
52-
failurePolicy: pkgconfigsetup.Datadog().GetString("admission_controller.failure_policy"),
53-
reinvocationPolicy: pkgconfigsetup.Datadog().GetString("admission_controller.reinvocation_policy"),
51+
timeout: datadogConfig.GetInt32("admission_controller.timeout_seconds"),
52+
failurePolicy: datadogConfig.GetString("admission_controller.failure_policy"),
53+
reinvocationPolicy: datadogConfig.GetString("admission_controller.reinvocation_policy"),
5454
}
5555
}
5656

pkg/clusteragent/admission/controllers/webhook/controller_base.go

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -35,7 +35,6 @@ import (
3535
"github.com/DataDog/datadog-agent/pkg/clusteragent/admission/mutate/tagsfromlabels"
3636
"github.com/DataDog/datadog-agent/pkg/clusteragent/admission/validate/kubernetesadmissionevents"
3737
"github.com/DataDog/datadog-agent/pkg/clusteragent/autoscaling/workload"
38-
pkgconfigsetup "github.com/DataDog/datadog-agent/pkg/config/setup"
3938
"github.com/DataDog/datadog-agent/pkg/util/log"
4039
)
4140

@@ -125,7 +124,7 @@ func (c *controllerBase) generateWebhooks(wmeta workloadmeta.Component, pa workl
125124
configWebhook.NewWebhook(wmeta, injectionFilter, datadogConfig),
126125
tagsfromlabels.NewWebhook(wmeta, datadogConfig, injectionFilter),
127126
agentsidecar.NewWebhook(datadogConfig),
128-
autoscaling.NewWebhook(pa),
127+
autoscaling.NewWebhook(pa, datadogConfig),
129128
}
130129
webhooks = append(webhooks, mutatingWebhooks...)
131130

@@ -137,7 +136,7 @@ func (c *controllerBase) generateWebhooks(wmeta workloadmeta.Component, pa workl
137136
log.Errorf("failed to register APM Instrumentation webhook: %v", err)
138137
}
139138

140-
isCWSInstrumentationEnabled := pkgconfigsetup.Datadog().GetBool("admission_controller.cws_instrumentation.enabled")
139+
isCWSInstrumentationEnabled := datadogConfig.GetBool("admission_controller.cws_instrumentation.enabled")
141140
if isCWSInstrumentationEnabled {
142141
cws, err := cwsinstrumentation.NewCWSInstrumentation(wmeta, datadogConfig)
143142
if err == nil {

pkg/clusteragent/admission/controllers/webhook/controller_base_test.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -36,7 +36,7 @@ func TestNewController(t *testing.T) {
3636
factory.Admissionregistration(),
3737
func() bool { return true },
3838
make(chan struct{}),
39-
v1Cfg,
39+
getV1Cfg(t),
4040
wmeta,
4141
nil,
4242
datadogConfig,
@@ -53,7 +53,7 @@ func TestNewController(t *testing.T) {
5353
factory.Admissionregistration(),
5454
func() bool { return true },
5555
make(chan struct{}),
56-
v1beta1Cfg,
56+
getV1beta1Cfg(t),
5757
wmeta,
5858
nil,
5959
datadogConfig,

0 commit comments

Comments
 (0)