@@ -2,28 +2,29 @@ package k8s
22
33import (
44 "context"
5- "fmt"
5+ "errors"
6+
67 "github.com/go-logr/logr"
78 corev1 "k8s.io/api/core/v1"
8- "k8s.io/apimachinery/pkg/api/errors"
9+ k8serrors "k8s.io/apimachinery/pkg/api/errors"
910 "sigs.k8s.io/controller-runtime/pkg/client"
1011)
1112
1213type SecretClient struct {
13- client client.Client
14- log * logr.Logger
14+ k8sClient client.Client
15+ log * logr.Logger
1516}
1617
17- func NewSecretClient (client client.Client , log * logr.Logger ) (* SecretClient , error ) {
18- if client == nil {
19- return nil , fmt . Errorf ( "client cannot be nil" )
18+ func NewSecretClient (k8sClient client.Client , log * logr.Logger ) (* SecretClient , error ) {
19+ if k8sClient == nil {
20+ return nil , errors . New ( "k8sClient cannot be nil" )
2021 }
2122 if log == nil {
22- return nil , fmt . Errorf ("logger cannot be nil" )
23+ return nil , errors . New ("logger cannot be nil" )
2324 }
2425 return & SecretClient {
25- client : client ,
26- log : log ,
26+ k8sClient : k8sClient ,
27+ log : log ,
2728 }, nil
2829}
2930
@@ -34,20 +35,20 @@ func (s *SecretClient) EnsureFinalizer(ctx context.Context, secretName, secretNa
3435 Name : secretName ,
3536 Namespace : secretNamespace ,
3637 }
37- if err := s .client .Get (ctx , secretKey , & secret ); err != nil {
38+ if err := s .k8sClient .Get (ctx , secretKey , & secret ); err != nil {
3839 return err
3940 }
4041
4142 // if finalizer already exists, we are happy
42- for _ , existingFinalizer := range secret .ObjectMeta . Finalizers {
43+ for _ , existingFinalizer := range secret .Finalizers {
4344 if finalizer == existingFinalizer {
4445 return nil
4546 }
4647 }
4748
4849 s .log .WithValues ("finalizer" , finalizer ).Info ("creating finalizer" )
4950 secret .Finalizers = append (secret .Finalizers , finalizer )
50- return s .client .Update (ctx , & secret )
51+ return s .k8sClient .Update (ctx , & secret )
5152}
5253
5354// RemoveFinalizer removes the first instance of the finalizer from the given secret
@@ -57,16 +58,16 @@ func (s *SecretClient) RemoveFinalizer(ctx context.Context, secretName, secretNa
5758 Name : secretName ,
5859 Namespace : secretNamespace ,
5960 }
60- if err := s .client .Get (ctx , secretKey , & secret ); err != nil {
61- if errors .IsNotFound (err ) {
61+ if err := s .k8sClient .Get (ctx , secretKey , & secret ); err != nil {
62+ if k8serrors .IsNotFound (err ) {
6263 return nil
6364 }
6465 return err
6566 }
6667
6768 s .log .WithValues ("finalizer" , finalizer ).Info ("deleting finalizer" )
6869 secret .Finalizers = removeString (secret .Finalizers , finalizer )
69- return s .client .Update (ctx , & secret )
70+ return s .k8sClient .Update (ctx , & secret )
7071}
7172
7273// removeString returns a copy of list with the first (only) occurrence
0 commit comments