@@ -3,14 +3,12 @@ package crd
3
3
4
4
import (
5
5
"context"
6
- "fmt"
7
6
8
7
apiextensions "k8s.io/apiextensions-apiserver/pkg/apis/apiextensions/v1"
9
8
apierrors "k8s.io/apimachinery/pkg/api/errors"
10
9
"k8s.io/apimachinery/pkg/types"
11
10
ctrl "sigs.k8s.io/controller-runtime"
12
11
"sigs.k8s.io/controller-runtime/pkg/client"
13
- "sigs.k8s.io/controller-runtime/pkg/client/config"
14
12
15
13
api "sigs.k8s.io/hierarchical-namespaces/api/v1alpha2"
16
14
)
@@ -19,13 +17,13 @@ import (
19
17
type fakeDeleteCRDClient struct {}
20
18
21
19
// fakeDeleteCRDClient doesn't return any err on Get() because none of the reconciler test performs CRD deletion
22
- func (f fakeDeleteCRDClient ) Get (context.Context , types. NamespacedName , client.Object ) error {
20
+ func (f fakeDeleteCRDClient ) Get (context.Context , client. ObjectKey , client.Object , ... client. GetOption ) error {
23
21
return nil
24
22
}
25
23
26
24
// crdClientType could be either a real client or fakeDeleteCRDClient
27
25
type crdClientType interface {
28
- Get (context.Context , types. NamespacedName , client.Object ) error
26
+ Get (context.Context , client. ObjectKey , client.Object , ... client. GetOption ) error
29
27
}
30
28
31
29
// crdClient is an uncached client for checking CRD deletion (or a fake for testing)
@@ -38,16 +36,7 @@ func Setup(mgr ctrl.Manager, fake bool) error {
38
36
return nil
39
37
}
40
38
41
- //TODO(aludwin): can we just use mgr.GetClient()? If not, document why not
42
- var err error
43
- crdClient , err = client .New (config .GetConfigOrDie (), client.Options {
44
- Scheme : mgr .GetScheme (),
45
- // I'm not sure if this mapper is needed - @ginnyji Dec2020
46
- Mapper : mgr .GetRESTMapper (),
47
- })
48
- if err != nil {
49
- return fmt .Errorf ("cannot create crdClient: %s" , err .Error ())
50
- }
39
+ crdClient = mgr .GetClient ()
51
40
52
41
return nil
53
42
}
0 commit comments