Skip to content

Commit 4abefe2

Browse files
kaitoii11kaitoii11
committed
add ingress class metrics
1 parent 898345f commit 4abefe2

File tree

10 files changed

+265
-1
lines changed

10 files changed

+265
-1
lines changed

‎docs/README.md

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -65,6 +65,7 @@ See each file for specific documentation about the exposed metrics:
6565

6666
- [ClusterRole Metrics](clusterrole-metrics.md)
6767
- [ClusterRoleBinding Metrics](clusterrolebinding-metrics.md)
68+
- [IngressClass Metrics](ingressclass-metrics.md)
6869
- [Role Metrics](role-metrics.md)
6970
- [RoleBinding Metrics](rolebinding-metrics.md)
7071
- [ServiceAccount Metrics](serviceaccount-metrics.md)

‎docs/ingressclass-metrics.md

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,8 @@
1+
# IngressClass Metrics
2+
3+
| Metric name| Metric type | Labels/tags | Status |
4+
| ---------- | ----------- | ----------- | ----------- |
5+
| kube_ingressclass_annotations | Gauge | `ingressclass`=&lt;ingressclass-name&gt; <br> `annotation_INGRESSCLASS_ANNOTATION`=&lt;INGRESSCLASS_ANNOTATION&gt; | EXPERIMENTAL |
6+
| kube_ingressclass_info | Gauge | `ingressclass`=&lt;ingressclass-name&gt; <br> `controller`=&lt;ingress-controller-name&gt; <br> | STABLE |
7+
| kube_ingressclass_labels | Gauge | `ingressclass`=&lt;ingressclass-name&gt; <br> `label_INGRESSCLASS_LABEL`=&lt;INGRESSCLASS_LABEL&gt; | STABLE |
8+
| kube_ingressclass_created | Gauge | `ingressclass`=&lt;ingressclass-name&gt; | STABLE |

‎examples/autosharding/cluster-role.yaml

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -97,6 +97,7 @@ rules:
9797
- networking.k8s.io
9898
resources:
9999
- networkpolicies
100+
- ingressclasses
100101
- ingresses
101102
verbs:
102103
- list

‎examples/standard/cluster-role.yaml

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -97,6 +97,7 @@ rules:
9797
- networking.k8s.io
9898
resources:
9999
- networkpolicies
100+
- ingressclasses
100101
- ingresses
101102
verbs:
102103
- list

‎internal/store/builder.go

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -295,6 +295,7 @@ var availableStores = map[string]func(f *Builder) []cache.Store{
295295
"endpoints": func(b *Builder) []cache.Store { return b.buildEndpointsStores() },
296296
"horizontalpodautoscalers": func(b *Builder) []cache.Store { return b.buildHPAStores() },
297297
"ingresses": func(b *Builder) []cache.Store { return b.buildIngressStores() },
298+
"ingressclasses": func(b *Builder) []cache.Store { return b.buildIngressClassStores() },
298299
"jobs": func(b *Builder) []cache.Store { return b.buildJobStores() },
299300
"leases": func(b *Builder) []cache.Store { return b.buildLeasesStores() },
300301
"limitranges": func(b *Builder) []cache.Store { return b.buildLimitRangeStores() },
@@ -470,6 +471,10 @@ func (b *Builder) buildRoleBindingStores() []cache.Store {
470471
return b.buildStoresFunc(roleBindingMetricFamilies(b.allowAnnotationsList["rolebindings"], b.allowLabelsList["rolebindings"]), &rbacv1.RoleBinding{}, createRoleBindingListWatch, b.useAPIServerCache)
471472
}
472473

474+
func (b *Builder) buildIngressClassStores() []cache.Store {
475+
return b.buildStoresFunc(ingressClassMetricFamilies(b.allowAnnotationsList["ingressclass"], b.allowLabelsList["ingressclass"]), &networkingv1.IngressClass{}, createIngressClassListWatch, b.useAPIServerCache)
476+
}
477+
473478
func (b *Builder) buildStores(
474479
metricFamilies []generator.FamilyGenerator,
475480
expectedType interface{},

‎internal/store/ingressclass.go

Lines changed: 134 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,134 @@
1+
/*
2+
Copyright 2022 The Kubernetes Authors All rights reserved.
3+
Licensed under the Apache License, Version 2.0 (the "License");
4+
you may not use this file except in compliance with the License.
5+
You may obtain a copy of the License at
6+
http://www.apache.org/licenses/LICENSE-2.0
7+
Unless required by applicable law or agreed to in writing, software
8+
distributed under the License is distributed on an "AS IS" BASIS,
9+
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
10+
See the License for the specific language governing permissions and
11+
limitations under the License.
12+
*/
13+
14+
package store
15+
16+
import (
17+
"context"
18+
19+
"k8s.io/kube-state-metrics/v2/pkg/metric"
20+
generator "k8s.io/kube-state-metrics/v2/pkg/metric_generator"
21+
22+
networkingv1 "k8s.io/api/networking/v1"
23+
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
24+
"k8s.io/apimachinery/pkg/runtime"
25+
"k8s.io/apimachinery/pkg/watch"
26+
clientset "k8s.io/client-go/kubernetes"
27+
"k8s.io/client-go/tools/cache"
28+
)
29+
30+
var (
31+
descIngressClassAnnotationsName = "kube_ingressclass_annotations"
32+
descIngressClassAnnotationsHelp = "Kubernetes annotations converted to Prometheus labels."
33+
descIngressClassLabelsName = "kube_ingressclass_labels"
34+
descIngressClassLabelsHelp = "Kubernetes labels converted to Prometheus labels."
35+
descIngressClassLabelsDefaultLabels = []string{"ingressclass"}
36+
)
37+
38+
func ingressClassMetricFamilies(allowAnnotationsList, allowLabelsList []string) []generator.FamilyGenerator {
39+
return []generator.FamilyGenerator{
40+
*generator.NewFamilyGenerator(
41+
"kube_ingressclass_info",
42+
"Information about ingressclass.",
43+
metric.Gauge,
44+
"",
45+
wrapIngressClassFunc(func(s *networkingv1.IngressClass) *metric.Family {
46+
47+
m := metric.Metric{
48+
LabelKeys: []string{"controller"},
49+
LabelValues: []string{s.Spec.Controller},
50+
Value: 1,
51+
}
52+
return &metric.Family{Metrics: []*metric.Metric{&m}}
53+
}),
54+
),
55+
*generator.NewFamilyGenerator(
56+
"kube_ingressclass_created",
57+
"Unix creation timestamp",
58+
metric.Gauge,
59+
"",
60+
wrapIngressClassFunc(func(s *networkingv1.IngressClass) *metric.Family {
61+
ms := []*metric.Metric{}
62+
if !s.CreationTimestamp.IsZero() {
63+
ms = append(ms, &metric.Metric{
64+
Value: float64(s.CreationTimestamp.Unix()),
65+
})
66+
}
67+
return &metric.Family{
68+
Metrics: ms,
69+
}
70+
}),
71+
),
72+
*generator.NewFamilyGenerator(
73+
descIngressClassAnnotationsName,
74+
descIngressClassAnnotationsHelp,
75+
metric.Gauge,
76+
"",
77+
wrapIngressClassFunc(func(s *networkingv1.IngressClass) *metric.Family {
78+
annotationKeys, annotationValues := createPrometheusLabelKeysValues("annotation", s.Annotations, allowAnnotationsList)
79+
return &metric.Family{
80+
Metrics: []*metric.Metric{
81+
{
82+
LabelKeys: annotationKeys,
83+
LabelValues: annotationValues,
84+
Value: 1,
85+
},
86+
},
87+
}
88+
}),
89+
),
90+
*generator.NewFamilyGenerator(
91+
descIngressClassLabelsName,
92+
descIngressClassLabelsHelp,
93+
metric.Gauge,
94+
"",
95+
wrapIngressClassFunc(func(s *networkingv1.IngressClass) *metric.Family {
96+
labelKeys, labelValues := createPrometheusLabelKeysValues("label", s.Labels, allowLabelsList)
97+
return &metric.Family{
98+
Metrics: []*metric.Metric{
99+
{
100+
LabelKeys: labelKeys,
101+
LabelValues: labelValues,
102+
Value: 1,
103+
},
104+
},
105+
}
106+
}),
107+
),
108+
}
109+
}
110+
111+
func wrapIngressClassFunc(f func(*networkingv1.IngressClass) *metric.Family) func(interface{}) *metric.Family {
112+
return func(obj interface{}) *metric.Family {
113+
ingressClass := obj.(*networkingv1.IngressClass)
114+
115+
metricFamily := f(ingressClass)
116+
117+
for _, m := range metricFamily.Metrics {
118+
m.LabelKeys, m.LabelValues = mergeKeyValues(descIngressClassLabelsDefaultLabels, []string{ingressClass.Name}, m.LabelKeys, m.LabelValues)
119+
}
120+
121+
return metricFamily
122+
}
123+
}
124+
125+
func createIngressClassListWatch(kubeClient clientset.Interface, ns string, fieldSelector string) cache.ListerWatcher {
126+
return &cache.ListWatch{
127+
ListFunc: func(opts metav1.ListOptions) (runtime.Object, error) {
128+
return kubeClient.NetworkingV1().IngressClasses().List(context.TODO(), opts)
129+
},
130+
WatchFunc: func(opts metav1.ListOptions) (watch.Interface, error) {
131+
return kubeClient.NetworkingV1().IngressClasses().Watch(context.TODO(), opts)
132+
},
133+
}
134+
}

‎internal/store/ingressclass_test.go

Lines changed: 105 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,105 @@
1+
/*
2+
Copyright 2022 The Kubernetes Authors All rights reserved.
3+
Licensed under the Apache License, Version 2.0 (the "License");
4+
you may not use this file except in compliance with the License.
5+
You may obtain a copy of the License at
6+
http://www.apache.org/licenses/LICENSE-2.0
7+
Unless required by applicable law or agreed to in writing, software
8+
distributed under the License is distributed on an "AS IS" BASIS,
9+
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
10+
See the License for the specific language governing permissions and
11+
limitations under the License.
12+
*/
13+
14+
package store
15+
16+
import (
17+
"testing"
18+
19+
networkingv1 "k8s.io/api/networking/v1"
20+
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
21+
22+
generator "k8s.io/kube-state-metrics/v2/pkg/metric_generator"
23+
)
24+
25+
func TestIngressClassStore(t *testing.T) {
26+
startTime := 1501569018
27+
metav1StartTime := metav1.Unix(int64(startTime), 0)
28+
29+
cases := []generateMetricsTestCase{
30+
{
31+
Obj: &networkingv1.IngressClass{
32+
ObjectMeta: metav1.ObjectMeta{
33+
Name: "test_ingressclass-info",
34+
},
35+
Spec: networkingv1.IngressClassSpec{
36+
Controller: "controller",
37+
},
38+
},
39+
Want: `
40+
# HELP kube_ingressclass_info Information about ingressclass.
41+
# TYPE kube_ingressclass_info gauge
42+
kube_ingressclass_info{ingressclass="test_ingressclass-info",controller="controller"} 1
43+
`,
44+
MetricNames: []string{
45+
"kube_ingressclass_info",
46+
},
47+
},
48+
{
49+
Obj: &networkingv1.IngressClass{
50+
ObjectMeta: metav1.ObjectMeta{
51+
Name: "test_kube_ingressclass-created",
52+
CreationTimestamp: metav1StartTime,
53+
},
54+
Spec: networkingv1.IngressClassSpec{
55+
Controller: "controller",
56+
},
57+
},
58+
Want: `
59+
# HELP kube_ingressclass_created Unix creation timestamp
60+
# TYPE kube_ingressclass_created gauge
61+
kube_ingressclass_created{ingressclass="test_kube_ingressclass-created"} 1.501569018e+09
62+
`,
63+
MetricNames: []string{
64+
"kube_ingressclass_created",
65+
},
66+
},
67+
{
68+
AllowAnnotationsList: []string{
69+
"ingressclass.kubernetes.io/is-default-class",
70+
},
71+
Obj: &networkingv1.IngressClass{
72+
ObjectMeta: metav1.ObjectMeta{
73+
Name: "test_ingressclass-labels",
74+
Annotations: map[string]string{
75+
"ingressclass.kubernetes.io/is-default-class": "true",
76+
},
77+
Labels: map[string]string{
78+
"foo": "bar",
79+
},
80+
},
81+
Spec: networkingv1.IngressClassSpec{
82+
Controller: "controller",
83+
},
84+
},
85+
Want: `
86+
# HELP kube_ingressclass_annotations Kubernetes annotations converted to Prometheus labels.
87+
# HELP kube_ingressclass_labels Kubernetes labels converted to Prometheus labels.
88+
# TYPE kube_ingressclass_annotations gauge
89+
# TYPE kube_ingressclass_labels gauge
90+
kube_ingressclass_annotations{ingressclass="test_ingressclass-labels",annotation_ingressclass_kubernetes_io_is_default_class="true"} 1
91+
kube_ingressclass_labels{ingressclass="test_ingressclass-labels"} 1
92+
`,
93+
MetricNames: []string{
94+
"kube_ingressclass_annotations", "kube_ingressclass_labels",
95+
},
96+
},
97+
}
98+
for i, c := range cases {
99+
c.Func = generator.ComposeMetricGenFuncs(ingressClassMetricFamilies(c.AllowAnnotationsList, nil))
100+
c.Headers = generator.ExtractMetricFamilyHeaders(ingressClassMetricFamilies(c.AllowAnnotationsList, nil))
101+
if err := c.run(); err != nil {
102+
t.Errorf("unexpected collecting result in %vth run:\n%s", i, err)
103+
}
104+
}
105+
}

‎jsonnet/kube-state-metrics/kube-state-metrics.libsonnet

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -134,6 +134,7 @@
134134
apiGroups: ['networking.k8s.io'],
135135
resources: [
136136
'networkpolicies',
137+
'ingressclasses',
137138
'ingresses',
138139
],
139140
verbs: ['list', 'watch'],

‎tests/manifests/ingress.yaml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
apiVersion: networking.k8s.io/v1
1+
apiVersion: networking.k8s.io/v1
22
kind: Ingress
33
metadata:
44
name: example-ingress

‎tests/manifests/ingressclass.yaml

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,8 @@
1+
apiVersion: networking.k8s.io/v1
2+
kind: IngressClass
3+
metadata:
4+
name: example-ingressclass
5+
annotations:
6+
ingressclass.kubernetes.io/is-default-class: "true"
7+
spec:
8+
controller: example-ingress/controller

0 commit comments

Comments
 (0)