Skip to content

Commit 4145868

Browse files
author
Evsyukov Denis
committed
refactor: simplify string formatting and update webhook configuration references
1 parent 71494a8 commit 4145868

File tree

8 files changed

+35
-35
lines changed

8 files changed

+35
-35
lines changed

pkg/config/config.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -106,15 +106,15 @@ func (c *Config) List() []map[string]string {
106106
func (c *Config) String() string {
107107
b := new(strings.Builder)
108108
// Header
109-
b.WriteString(fmt.Sprintf("%-30s %-20s %-20s %-40s\n", "NAME", "VALUE", "EXPIRE AT", "DESCRIPTION"))
109+
fmt.Fprintf(b, "%-30s %-20s %-20s %-40s\n", "NAME", "VALUE", "EXPIRE AT", "DESCRIPTION")
110110

111111
params := c.List()
112112
for _, param := range params {
113113
description := param["description"]
114114
if param["lastError"] != "" {
115115
description = "Error: " + param["lastError"]
116116
}
117-
b.WriteString(fmt.Sprintf("%-30s %-20s %-20s %-40s\n", param["name"], param["value"], param["expireAt"], description))
117+
fmt.Fprintf(b, "%-30s %-20s %-20s %-40s\n", param["name"], param["value"], param["expireAt"], description)
118118
}
119119

120120
return b.String()

pkg/debug/debug-cmd.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -44,7 +44,7 @@ func DefineDebugCommands(kpApp *kingpin.Application) {
4444
var err error
4545
refreshInterval, err = time.ParseDuration(watchInterval)
4646
if err != nil {
47-
output.WriteString(fmt.Sprintf("could not parse watch refresh interval: %s, default 1s applied\n", err))
47+
fmt.Fprintf(output, "could not parse watch refresh interval: %s, default 1s applied\n", err)
4848
refreshInterval = time.Second
4949
}
5050
}

pkg/hook/config/config_v1.go

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -463,8 +463,8 @@ func convertValidating(cfgV1 KubernetesAdmissionConfigV1) (htypes.ValidatingConf
463463
cfg.Webhook = &admission.ValidatingWebhookConfig{
464464
ValidatingWebhook: webhook,
465465
}
466-
cfg.Webhook.Metadata.LogLabels = map[string]string{}
467-
cfg.Webhook.Metadata.MetricLabels = map[string]string{}
466+
cfg.Webhook.LogLabels = map[string]string{}
467+
cfg.Webhook.MetricLabels = map[string]string{}
468468

469469
return cfg, nil
470470
}
@@ -511,8 +511,8 @@ func convertMutating(cfgV1 KubernetesAdmissionConfigV1) (htypes.MutatingConfig,
511511
cfg.Webhook = &admission.MutatingWebhookConfig{
512512
MutatingWebhook: webhook,
513513
}
514-
cfg.Webhook.Metadata.LogLabels = map[string]string{}
515-
cfg.Webhook.Metadata.MetricLabels = map[string]string{}
514+
cfg.Webhook.LogLabels = map[string]string{}
515+
cfg.Webhook.MetricLabels = map[string]string{}
516516

517517
return cfg, nil
518518
}

pkg/hook/controller/admission_bindings_controller.go

Lines changed: 14 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -61,27 +61,27 @@ func (c *AdmissionBindingsController) EnableValidatingBindings() {
6161
}
6262

6363
for _, config := range c.ValidatingBindings {
64-
if config.Webhook.Metadata.ConfigurationId == "" && confId == "" {
64+
if config.Webhook.ConfigurationId == "" && confId == "" {
6565
continue
6666
}
67-
if config.Webhook.Metadata.ConfigurationId != "" && confId == "" {
68-
confId = config.Webhook.Metadata.ConfigurationId
67+
if config.Webhook.ConfigurationId != "" && confId == "" {
68+
confId = config.Webhook.ConfigurationId
6969
continue
7070
}
71-
if config.Webhook.Metadata.ConfigurationId != confId {
71+
if config.Webhook.ConfigurationId != confId {
7272
log.Error("Possible bug!!! kubernetesValidating has non-unique configurationIds",
73-
slog.String("configurationID", config.Webhook.Metadata.ConfigurationId),
73+
slog.String("configurationID", config.Webhook.ConfigurationId),
7474
slog.String("confID", confId))
7575
}
7676
}
7777
c.ConfigurationId = confId
7878

7979
for _, config := range c.ValidatingBindings {
80-
c.AdmissionLinks[config.Webhook.Metadata.WebhookId] = &AdmissionBindingToWebhookLink{
80+
c.AdmissionLinks[config.Webhook.WebhookId] = &AdmissionBindingToWebhookLink{
8181
BindingType: htypes.KubernetesValidating,
8282
BindingName: config.BindingName,
8383
ConfigurationId: c.ConfigurationId,
84-
WebhookId: config.Webhook.Metadata.WebhookId,
84+
WebhookId: config.Webhook.WebhookId,
8585
IncludeSnapshots: config.IncludeSnapshotsFrom,
8686
Group: config.Group,
8787
}
@@ -97,27 +97,27 @@ func (c *AdmissionBindingsController) EnableMutatingBindings() {
9797
}
9898

9999
for _, config := range c.MutatingBindings {
100-
if config.Webhook.Metadata.ConfigurationId == "" && confId == "" {
100+
if config.Webhook.ConfigurationId == "" && confId == "" {
101101
continue
102102
}
103-
if config.Webhook.Metadata.ConfigurationId != "" && confId == "" {
104-
confId = config.Webhook.Metadata.ConfigurationId
103+
if config.Webhook.ConfigurationId != "" && confId == "" {
104+
confId = config.Webhook.ConfigurationId
105105
continue
106106
}
107-
if config.Webhook.Metadata.ConfigurationId != confId {
107+
if config.Webhook.ConfigurationId != confId {
108108
log.Error("Possible bug!!! kubernetesMutating has non-unique configurationIds",
109-
slog.String("configurationID", config.Webhook.Metadata.ConfigurationId),
109+
slog.String("configurationID", config.Webhook.ConfigurationId),
110110
slog.String("confID", confId))
111111
}
112112
}
113113
c.ConfigurationId = confId
114114

115115
for _, config := range c.MutatingBindings {
116-
c.AdmissionLinks[config.Webhook.Metadata.WebhookId] = &AdmissionBindingToWebhookLink{
116+
c.AdmissionLinks[config.Webhook.WebhookId] = &AdmissionBindingToWebhookLink{
117117
BindingType: htypes.KubernetesMutating,
118118
BindingName: config.BindingName,
119119
ConfigurationId: c.ConfigurationId,
120-
WebhookId: config.Webhook.Metadata.WebhookId,
120+
WebhookId: config.Webhook.WebhookId,
121121
IncludeSnapshots: config.IncludeSnapshotsFrom,
122122
Group: config.Group,
123123
}

pkg/hook/hook_manager.go

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -179,17 +179,17 @@ func (hm *Manager) loadHook(hookPath string) (*Hook, error) {
179179
}
180180

181181
for _, validatingCfg := range hook.GetConfig().KubernetesValidating {
182-
validatingCfg.Webhook.Metadata.LogLabels["hook"] = hook.Name
183-
validatingCfg.Webhook.Metadata.MetricLabels = map[string]string{
182+
validatingCfg.Webhook.LogLabels["hook"] = hook.Name
183+
validatingCfg.Webhook.MetricLabels = map[string]string{
184184
"hook": hook.Name,
185185
"binding": validatingCfg.BindingName,
186186
}
187187
validatingCfg.Webhook.UpdateIds("", validatingCfg.BindingName)
188188
}
189189

190190
for _, mutatingCfg := range hook.GetConfig().KubernetesMutating {
191-
mutatingCfg.Webhook.Metadata.LogLabels["hook"] = hook.Name
192-
mutatingCfg.Webhook.Metadata.MetricLabels = map[string]string{
191+
mutatingCfg.Webhook.LogLabels["hook"] = hook.Name
192+
mutatingCfg.Webhook.MetricLabels = map[string]string{
193193
"hook": hook.Name,
194194
"binding": mutatingCfg.BindingName,
195195
}

pkg/webhook/admission/config.go

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -55,17 +55,17 @@ func (c *MutatingWebhookConfig) SetClientConfig(cc v1.WebhookClientConfig) {
5555

5656
// UpdateIds use confId and webhookId to set a ConfigurationId prefix and a WebhookId.
5757
func (c *ValidatingWebhookConfig) UpdateIds(confID, webhookID string) {
58-
c.Metadata.ConfigurationId = confID
58+
c.ConfigurationId = confID
5959
if confID == "" {
60-
c.Metadata.ConfigurationId = DefaultConfigurationId
60+
c.ConfigurationId = DefaultConfigurationId
6161
}
62-
c.Metadata.WebhookId = string_helper.SafeURLString(webhookID)
62+
c.WebhookId = string_helper.SafeURLString(webhookID)
6363
}
6464

6565
func (c *MutatingWebhookConfig) UpdateIds(confID, webhookID string) {
66-
c.Metadata.ConfigurationId = confID
66+
c.ConfigurationId = confID
6767
if confID == "" {
68-
c.Metadata.ConfigurationId = DefaultConfigurationId
68+
c.ConfigurationId = DefaultConfigurationId
6969
}
70-
c.Metadata.WebhookId = string_helper.SafeURLString(webhookID)
70+
c.WebhookId = string_helper.SafeURLString(webhookID)
7171
}

pkg/webhook/admission/manager.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -77,7 +77,7 @@ func (m *WebhookManager) Init() error {
7777
}
7878

7979
func (m *WebhookManager) AddValidatingWebhook(config *ValidatingWebhookConfig) {
80-
confId := config.Metadata.ConfigurationId
80+
confId := config.ConfigurationId
8181
if confId == "" {
8282
confId = m.DefaultConfigurationId
8383
}
@@ -99,7 +99,7 @@ func (m *WebhookManager) AddValidatingWebhook(config *ValidatingWebhookConfig) {
9999
}
100100

101101
func (m *WebhookManager) AddMutatingWebhook(config *MutatingWebhookConfig) {
102-
confId := config.Metadata.ConfigurationId
102+
confId := config.ConfigurationId
103103
if confId == "" {
104104
confId = m.DefaultConfigurationId
105105
}

pkg/webhook/admission/resource.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -33,7 +33,7 @@ func NewValidatingWebhookResource(opts WebhookResourceOptions) *ValidatingWebhoo
3333
}
3434

3535
func (w *ValidatingWebhookResource) Set(whc *ValidatingWebhookConfig) {
36-
w.hooks[whc.Metadata.WebhookId] = whc
36+
w.hooks[whc.WebhookId] = whc
3737
}
3838

3939
func (w *ValidatingWebhookResource) Get(id string) *ValidatingWebhookConfig {
@@ -134,7 +134,7 @@ func NewMutatingWebhookResource(opts WebhookResourceOptions) *MutatingWebhookRes
134134
}
135135

136136
func (w *MutatingWebhookResource) Set(whc *MutatingWebhookConfig) {
137-
w.hooks[whc.Metadata.WebhookId] = whc
137+
w.hooks[whc.WebhookId] = whc
138138
}
139139

140140
func (w *MutatingWebhookResource) Get(id string) *MutatingWebhookConfig {

0 commit comments

Comments
 (0)