Skip to content

Commit

Permalink
switch mutatingwebhookconfiguration to v1
Browse files Browse the repository at this point in the history
  • Loading branch information
qw1mb0 committed May 16, 2020
1 parent d249c1d commit 59e0e0c
Show file tree
Hide file tree
Showing 6 changed files with 27 additions and 24 deletions.
6 changes: 3 additions & 3 deletions internal/store/builder.go
Original file line number Diff line number Diff line change
Expand Up @@ -24,7 +24,7 @@ import (

"github.com/pkg/errors"
"github.com/prometheus/client_golang/prometheus"
admissionregistration "k8s.io/api/admissionregistration/v1"
admissionregistrationv1 "k8s.io/api/admissionregistration/v1"
appsv1 "k8s.io/api/apps/v1"
autoscaling "k8s.io/api/autoscaling/v2beta1"
batchv1 "k8s.io/api/batch/v1"
Expand Down Expand Up @@ -241,7 +241,7 @@ func (b *Builder) buildLimitRangeStore() cache.Store {
}

func (b *Builder) buildMutatingWebhookConfigurationStore() cache.Store {
return b.buildStoreFunc(mutatingWebhookConfigurationMetricFamilies, &admissionregistration.MutatingWebhookConfiguration{}, createMutatingWebhookConfigurationListWatch)
return b.buildStoreFunc(mutatingWebhookConfigurationMetricFamilies, &admissionregistrationv1.MutatingWebhookConfiguration{}, createMutatingWebhookConfigurationListWatch)
}

func (b *Builder) buildNamespaceStore() cache.Store {
Expand Down Expand Up @@ -305,7 +305,7 @@ func (b *Builder) buildCsrStore() cache.Store {
}

func (b *Builder) buildValidatingWebhookConfigurationStore() cache.Store {
return b.buildStoreFunc(validatingWebhookConfigurationMetricFamilies, &admissionregistration.ValidatingWebhookConfiguration{}, createValidatingWebhookConfigurationListWatch)
return b.buildStoreFunc(validatingWebhookConfigurationMetricFamilies, &admissionregistrationv1.ValidatingWebhookConfiguration{}, createValidatingWebhookConfigurationListWatch)
}

func (b *Builder) buildVolumeAttachmentStore() cache.Store {
Expand Down
16 changes: 8 additions & 8 deletions internal/store/mutatingwebhookconfiguration.go
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@ limitations under the License.
package store

import (
admissionregistration "k8s.io/api/admissionregistration/v1beta1"
admissionregistrationv1 "k8s.io/api/admissionregistration/v1"
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
"k8s.io/apimachinery/pkg/runtime"
"k8s.io/apimachinery/pkg/watch"
Expand All @@ -37,7 +37,7 @@ var (
Name: "kube_mutatingwebhookconfiguration_info",
Type: metric.Gauge,
Help: "Information about the MutatingWebhookConfiguration.",
GenerateFunc: wrapMutatingWebhookConfigurationFunc(func(mwc *admissionregistration.MutatingWebhookConfiguration) *metric.Family {
GenerateFunc: wrapMutatingWebhookConfigurationFunc(func(mwc *admissionregistrationv1.MutatingWebhookConfiguration) *metric.Family {
return &metric.Family{
Metrics: []*metric.Metric{
{
Expand All @@ -51,7 +51,7 @@ var (
Name: "kube_mutatingwebhookconfiguration_created",
Type: metric.Gauge,
Help: "Unix creation timestamp.",
GenerateFunc: wrapMutatingWebhookConfigurationFunc(func(mwc *admissionregistration.MutatingWebhookConfiguration) *metric.Family {
GenerateFunc: wrapMutatingWebhookConfigurationFunc(func(mwc *admissionregistrationv1.MutatingWebhookConfiguration) *metric.Family {
ms := []*metric.Metric{}

if !mwc.CreationTimestamp.IsZero() {
Expand All @@ -68,7 +68,7 @@ var (
Name: "kube_mutatingwebhookconfiguration_metadata_resource_version",
Type: metric.Gauge,
Help: "Resource version representing a specific version of the MutatingWebhookConfiguration.",
GenerateFunc: wrapMutatingWebhookConfigurationFunc(func(mwc *admissionregistration.MutatingWebhookConfiguration) *metric.Family {
GenerateFunc: wrapMutatingWebhookConfigurationFunc(func(mwc *admissionregistrationv1.MutatingWebhookConfiguration) *metric.Family {
return &metric.Family{
Metrics: resourceVersionMetric(mwc.ObjectMeta.ResourceVersion),
}
Expand All @@ -80,17 +80,17 @@ var (
func createMutatingWebhookConfigurationListWatch(kubeClient clientset.Interface, ns string) cache.ListerWatcher {
return &cache.ListWatch{
ListFunc: func(opts metav1.ListOptions) (runtime.Object, error) {
return kubeClient.AdmissionregistrationV1beta1().MutatingWebhookConfigurations().List(opts)
return kubeClient.AdmissionregistrationV1().MutatingWebhookConfigurations().List(opts)
},
WatchFunc: func(opts metav1.ListOptions) (watch.Interface, error) {
return kubeClient.AdmissionregistrationV1beta1().MutatingWebhookConfigurations().Watch(opts)
return kubeClient.AdmissionregistrationV1().MutatingWebhookConfigurations().Watch(opts)
},
}
}

func wrapMutatingWebhookConfigurationFunc(f func(*admissionregistration.MutatingWebhookConfiguration) *metric.Family) func(interface{}) *metric.Family {
func wrapMutatingWebhookConfigurationFunc(f func(*admissionregistrationv1.MutatingWebhookConfiguration) *metric.Family) func(interface{}) *metric.Family {
return func(obj interface{}) *metric.Family {
mutatingWebhookConfiguration := obj.(*admissionregistration.MutatingWebhookConfiguration)
mutatingWebhookConfiguration := obj.(*admissionregistrationv1.MutatingWebhookConfiguration)

metricFamily := f(mutatingWebhookConfiguration)

Expand Down
6 changes: 3 additions & 3 deletions internal/store/mutatingwebhookconfiguration_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -19,7 +19,7 @@ package store
import (
"testing"

admissionregistration "k8s.io/api/admissionregistration/v1beta1"
admissionregistrationv1 "k8s.io/api/admissionregistration/v1"
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"

generator "k8s.io/kube-state-metrics/pkg/metric_generator"
Expand All @@ -31,7 +31,7 @@ func TestMutatingWebhookConfigurationStore(t *testing.T) {

cases := []generateMetricsTestCase{
{
Obj: &admissionregistration.MutatingWebhookConfiguration{
Obj: &admissionregistrationv1.MutatingWebhookConfiguration{
ObjectMeta: metav1.ObjectMeta{
Name: "mutatingwebhookconfiguration1",
Namespace: "ns1",
Expand All @@ -49,7 +49,7 @@ func TestMutatingWebhookConfigurationStore(t *testing.T) {
MetricNames: []string{"kube_mutatingwebhookconfiguration_info", "kube_mutatingwebhookconfiguration_metadata_resource_version"},
},
{
Obj: &admissionregistration.MutatingWebhookConfiguration{
Obj: &admissionregistrationv1.MutatingWebhookConfiguration{
ObjectMeta: metav1.ObjectMeta{
Name: "mutatingwebhookconfiguration2",
Namespace: "ns2",
Expand Down
12 changes: 6 additions & 6 deletions internal/store/validatingwebhookconfiguration.go
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@ limitations under the License.
package store

import (
admissionregistration "k8s.io/api/admissionregistration/v1"
admissionregistrationv1 "k8s.io/api/admissionregistration/v1"
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
"k8s.io/apimachinery/pkg/runtime"
"k8s.io/apimachinery/pkg/watch"
Expand All @@ -37,7 +37,7 @@ var (
Name: "kube_validatingwebhookconfiguration_info",
Type: metric.Gauge,
Help: "Information about the ValidatingWebhookConfiguration.",
GenerateFunc: wrapValidatingWebhookConfigurationFunc(func(vwc *admissionregistration.ValidatingWebhookConfiguration) *metric.Family {
GenerateFunc: wrapValidatingWebhookConfigurationFunc(func(vwc *admissionregistrationv1.ValidatingWebhookConfiguration) *metric.Family {
return &metric.Family{
Metrics: []*metric.Metric{
{
Expand All @@ -51,7 +51,7 @@ var (
Name: "kube_validatingwebhookconfiguration_created",
Type: metric.Gauge,
Help: "Unix creation timestamp.",
GenerateFunc: wrapValidatingWebhookConfigurationFunc(func(vwc *admissionregistration.ValidatingWebhookConfiguration) *metric.Family {
GenerateFunc: wrapValidatingWebhookConfigurationFunc(func(vwc *admissionregistrationv1.ValidatingWebhookConfiguration) *metric.Family {
ms := []*metric.Metric{}

if !vwc.CreationTimestamp.IsZero() {
Expand All @@ -68,7 +68,7 @@ var (
Name: "kube_validatingwebhookconfiguration_metadata_resource_version",
Type: metric.Gauge,
Help: "Resource version representing a specific version of the ValidatingWebhookConfiguration.",
GenerateFunc: wrapValidatingWebhookConfigurationFunc(func(vwc *admissionregistration.ValidatingWebhookConfiguration) *metric.Family {
GenerateFunc: wrapValidatingWebhookConfigurationFunc(func(vwc *admissionregistrationv1.ValidatingWebhookConfiguration) *metric.Family {
return &metric.Family{
Metrics: resourceVersionMetric(vwc.ObjectMeta.ResourceVersion),
}
Expand All @@ -88,9 +88,9 @@ func createValidatingWebhookConfigurationListWatch(kubeClient clientset.Interfac
}
}

func wrapValidatingWebhookConfigurationFunc(f func(*admissionregistration.ValidatingWebhookConfiguration) *metric.Family) func(interface{}) *metric.Family {
func wrapValidatingWebhookConfigurationFunc(f func(*admissionregistrationv1.ValidatingWebhookConfiguration) *metric.Family) func(interface{}) *metric.Family {
return func(obj interface{}) *metric.Family {
mutatingWebhookConfiguration := obj.(*admissionregistration.ValidatingWebhookConfiguration)
mutatingWebhookConfiguration := obj.(*admissionregistrationv1.ValidatingWebhookConfiguration)

metricFamily := f(mutatingWebhookConfiguration)

Expand Down
6 changes: 3 additions & 3 deletions internal/store/validatingwebhookconfiguration_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -19,7 +19,7 @@ package store
import (
"testing"

admissionregistration "k8s.io/api/admissionregistration/v1"
admissionregistrationv1 "k8s.io/api/admissionregistration/v1"
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"

generator "k8s.io/kube-state-metrics/pkg/metric_generator"
Expand All @@ -31,7 +31,7 @@ func TestValidatingWebhookConfigurationStore(t *testing.T) {

cases := []generateMetricsTestCase{
{
Obj: &admissionregistration.ValidatingWebhookConfiguration{
Obj: &admissionregistrationv1.ValidatingWebhookConfiguration{
ObjectMeta: metav1.ObjectMeta{
Name: "validatingwebhookconfiguration1",
Namespace: "ns1",
Expand All @@ -49,7 +49,7 @@ func TestValidatingWebhookConfigurationStore(t *testing.T) {
MetricNames: []string{"kube_validatingwebhookconfiguration_info", "kube_validatingwebhookconfiguration_metadata_resource_version"},
},
{
Obj: &admissionregistration.ValidatingWebhookConfiguration{
Obj: &admissionregistrationv1.ValidatingWebhookConfiguration{
ObjectMeta: metav1.ObjectMeta{
Name: "validatingwebhookconfiguration2",
Namespace: "ns2",
Expand Down
5 changes: 4 additions & 1 deletion tests/manifests/mutatingwebhookconfiguration.yaml
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
apiVersion: admissionregistration.k8s.io/v1beta1
apiVersion: admissionregistration.k8s.io/v1
kind: MutatingWebhookConfiguration
metadata:
name: example-mutatingwebhookconfiguration
Expand All @@ -11,6 +11,9 @@ webhooks:
namespace: apples
path: /apple
caBundle: "YXBwbGVz"
admissionReviewVersions: ["v1", "v1beta1"]
sideEffects: None
timeoutSeconds: 5
namespaceSelector:
matchExpressions:
- key: production
Expand Down

0 comments on commit 59e0e0c

Please sign in to comment.