Skip to content

Commit

Permalink
Update validatingwebhookconfiguration
Browse files Browse the repository at this point in the history
  • Loading branch information
CatherineF-dev committed Jan 2, 2024
1 parent f2fe924 commit 53dab94
Show file tree
Hide file tree
Showing 3 changed files with 22 additions and 11 deletions.
2 changes: 1 addition & 1 deletion internal/store/builder.go
Original file line number Diff line number Diff line change
Expand Up @@ -470,7 +470,7 @@ func (b *Builder) buildCsrStores() []cache.Store {
}

func (b *Builder) buildValidatingWebhookConfigurationStores() []cache.Store {
return b.buildStoresFunc(validatingWebhookConfigurationMetricFamilies, &admissionregistrationv1.ValidatingWebhookConfiguration{}, createValidatingWebhookConfigurationListWatch, b.useAPIServerCache)
return b.buildStoresFunc(validatingWebhookConfigurationMetricFamilies(), &admissionregistrationv1.ValidatingWebhookConfiguration{}, createValidatingWebhookConfigurationListWatch, b.useAPIServerCache)
}

func (b *Builder) buildVolumeAttachmentStores() []cache.Store {
Expand Down
27 changes: 19 additions & 8 deletions internal/store/validatingwebhookconfiguration.go
Original file line number Diff line number Diff line change
Expand Up @@ -33,22 +33,28 @@ import (

var (
descValidatingWebhookConfigurationDefaultLabels = []string{"namespace", "validatingwebhookconfiguration"}
)

validatingWebhookConfigurationMetricFamilies = []generator.FamilyGenerator{
func validatingWebhookConfigurationMetricFamilies() []generator.FamilyGenerator {
return []generator.FamilyGenerator{
*generator.NewFamilyGeneratorWithStability(
"kube_validatingwebhookconfiguration_info",
"Information about the ValidatingWebhookConfiguration.",
metric.Gauge,
basemetrics.ALPHA,
"",
wrapValidatingWebhookConfigurationFunc(func(vwc *admissionregistrationv1.ValidatingWebhookConfiguration) *metric.Family {
return &metric.Family{
Metrics: []*metric.Metric{
{
Value: 1,
},
ms := []*metric.Metric{
{
Value: 1,
},
}

metric.SetLabelKeys(ms, []string{})

return &metric.Family{
Metrics: ms,
}
}),
),
*generator.NewFamilyGeneratorWithStability(
Expand All @@ -65,6 +71,9 @@ var (
Value: float64(vwc.CreationTimestamp.Unix()),
})
}

metric.SetLabelKeys(ms, []string{})

return &metric.Family{
Metrics: ms,
}
Expand Down Expand Up @@ -98,18 +107,20 @@ var (
}

ms = append(ms, &metric.Metric{
LabelKeys: []string{"webhook_name", "service_name", "service_namespace"},
LabelValues: []string{webhook.Name, serviceName, serviceNamespace},
Value: 1,
})
}

metric.SetLabelKeys(ms, []string{"webhook_name", "service_name", "service_namespace"})

return &metric.Family{
Metrics: ms,
}
}),
),
}
)
}

func createValidatingWebhookConfigurationListWatch(kubeClient clientset.Interface, _ string, _ string) cache.ListerWatcher {
return &cache.ListWatch{
Expand Down
4 changes: 2 additions & 2 deletions internal/store/validatingwebhookconfiguration_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -103,8 +103,8 @@ func TestValidatingWebhookConfigurationStore(t *testing.T) {
},
}
for i, c := range cases {
c.Func = generator.ComposeMetricGenFuncs(validatingWebhookConfigurationMetricFamilies)
c.Headers = generator.ExtractMetricFamilyHeaders(validatingWebhookConfigurationMetricFamilies)
c.Func = generator.ComposeMetricGenFuncs(validatingWebhookConfigurationMetricFamilies())
c.Headers = generator.ExtractMetricFamilyHeaders(validatingWebhookConfigurationMetricFamilies())
if err := c.run(); err != nil {
t.Errorf("unexpected collecting result in %vth run:\n%s", i, err)
}
Expand Down

0 comments on commit 53dab94

Please sign in to comment.