@@ -8,17 +8,15 @@ import (
8
8
"fmt"
9
9
"time"
10
10
11
- "k8s.io/api/certificates/v1beta1"
12
- certificatesv1b1api "k8s.io/api/certificates/v1beta1"
11
+ certificatesv1api "k8s.io/api/certificates/v1"
13
12
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
14
13
"k8s.io/apimachinery/pkg/util/json"
15
14
"k8s.io/client-go/kubernetes"
16
15
"k8s.io/klog/v2"
17
16
18
17
"k8s.io/apimachinery/pkg/api/errors"
19
18
20
- _ "k8s.io/apimachinery/pkg/runtime/serializer/yaml"
21
- certificatesv1beta1 "k8s.io/client-go/kubernetes/typed/certificates/v1beta1"
19
+ certificatesv1 "k8s.io/client-go/kubernetes/typed/certificates/v1"
22
20
23
21
"github.com/openshift/insights-operator/pkg/record"
24
22
)
@@ -40,10 +38,10 @@ func GatherCertificateSigningRequests(g *Gatherer) ([]record.Record, []error) {
40
38
if err != nil {
41
39
return nil , []error {err }
42
40
}
43
- return gatherCertificateSigningRequests (g .ctx , gatherKubeClient .CertificatesV1beta1 ())
41
+ return gatherCertificateSigningRequests (g .ctx , gatherKubeClient .CertificatesV1 ())
44
42
}
45
43
46
- func gatherCertificateSigningRequests (ctx context.Context , certClient certificatesv1beta1. CertificatesV1beta1Interface ) ([]record.Record , []error ) {
44
+ func gatherCertificateSigningRequests (ctx context.Context , certClient certificatesv1. CertificateSigningRequestsGetter ) ([]record.Record , []error ) {
47
45
requests , err := certClient .CertificateSigningRequests ().List (ctx , metav1.ListOptions {
48
46
Limit : csrGatherLimit ,
49
47
})
@@ -82,11 +80,11 @@ func (a CSRAnonymizer) GetExtension() string {
82
80
}
83
81
84
82
type CSRs struct {
85
- Requests []v1beta1 .CertificateSigningRequest
83
+ Requests []certificatesv1api .CertificateSigningRequest
86
84
Anonymized []CSRAnonymizer
87
85
}
88
86
89
- func FromCSRs (requests * v1beta1 .CertificateSigningRequestList ) * CSRs {
87
+ func FromCSRs (requests * certificatesv1api .CertificateSigningRequestList ) * CSRs {
90
88
return & CSRs {Requests : requests .Items }
91
89
}
92
90
@@ -153,7 +151,7 @@ func IncludeCSR(c *CSRAnonymizedFeatures, opts ...FilterOptFunc) bool {
153
151
return true
154
152
}
155
153
156
- func anonymizeCSRRequest (r * certificatesv1b1api .CertificateSigningRequest , c * CSRAnonymizedFeatures ) {
154
+ func anonymizeCSRRequest (r * certificatesv1api .CertificateSigningRequest , c * CSRAnonymizedFeatures ) {
157
155
if r == nil || c == nil {
158
156
return
159
157
}
@@ -231,7 +229,7 @@ func anonymizePkxName(s pkix.Name) (a pkix.Name) {
231
229
}
232
230
233
231
// returns true if certificate is valid
234
- func anonymizeCSRCert (r * certificatesv1b1api .CertificateSigningRequest , c * CSRAnonymizedFeatures ) {
232
+ func anonymizeCSRCert (r * certificatesv1api .CertificateSigningRequest , c * CSRAnonymizedFeatures ) {
235
233
if r == nil || c == nil {
236
234
return
237
235
}
@@ -258,17 +256,17 @@ func anonymizeCSRCert(r *certificatesv1b1api.CertificateSigningRequest, c *CSRAn
258
256
c .Status .Cert .NotAfter = cert .NotAfter .Format (time .RFC3339 )
259
257
}
260
258
261
- func addMeta (r * certificatesv1b1api .CertificateSigningRequest , c * CSRAnonymizedFeatures ) {
259
+ func addMeta (r * certificatesv1api .CertificateSigningRequest , c * CSRAnonymizedFeatures ) {
262
260
if r == nil || c == nil {
263
261
return
264
262
}
265
263
c .TypeMeta = r .TypeMeta
266
264
c .ObjectMeta = r .ObjectMeta
267
265
}
268
266
269
- func anonymizeCSR (r * certificatesv1b1api .CertificateSigningRequest ) * CSRAnonymizedFeatures {
267
+ func anonymizeCSR (r * certificatesv1api .CertificateSigningRequest ) * CSRAnonymizedFeatures {
270
268
c := & CSRAnonymizedFeatures {}
271
- fns := []func (r * certificatesv1b1api .CertificateSigningRequest , c * CSRAnonymizedFeatures ){
269
+ fns := []func (r * certificatesv1api .CertificateSigningRequest , c * CSRAnonymizedFeatures ){
272
270
addMeta ,
273
271
anonymizeCSRRequest ,
274
272
anonymizeCSRCert ,
@@ -299,13 +297,13 @@ type StateFeatures struct {
299
297
UID string
300
298
Username string
301
299
Groups []string
302
- Usages []v1beta1 .KeyUsage
300
+ Usages []certificatesv1api .KeyUsage
303
301
304
302
Request * CsrFeatures
305
303
}
306
304
307
305
type StatusFeatures struct {
308
- Conditions []v1beta1 .CertificateSigningRequestCondition
306
+ Conditions []certificatesv1api .CertificateSigningRequestCondition
309
307
Cert * CertFeatures
310
308
}
311
309
0 commit comments