Skip to content

Commit 36ef9e1

Browse files
committed
Remove inject.Client
Signed-off-by: Vince Prignano <vincepri@redhat.com>
1 parent 1c3b223 commit 36ef9e1

File tree

6 files changed

+2
-68
lines changed

6 files changed

+2
-68
lines changed

pkg/cluster/cluster_test.go

-8
Original file line numberDiff line numberDiff line change
@@ -143,13 +143,6 @@ var _ = Describe("cluster.Cluster", func() {
143143
By("Returning an error if dependency injection fails")
144144

145145
expected := fmt.Errorf("expected error")
146-
err = c.SetFields(&injectable{
147-
client: func(client client.Client) error {
148-
return expected
149-
},
150-
})
151-
Expect(err).To(Equal(expected))
152-
153146
err = c.SetFields(&injectable{
154147
scheme: func(scheme *runtime.Scheme) error {
155148
return expected
@@ -219,7 +212,6 @@ var _ = Describe("cluster.Cluster", func() {
219212
})
220213
})
221214

222-
var _ inject.Client = &injectable{}
223215
var _ inject.Scheme = &injectable{}
224216
var _ inject.Logger = &injectable{}
225217

pkg/cluster/internal.go

-3
Original file line numberDiff line numberDiff line change
@@ -65,9 +65,6 @@ type cluster struct {
6565
}
6666

6767
func (c *cluster) SetFields(i interface{}) error {
68-
if _, err := inject.ClientInto(c.client, i); err != nil {
69-
return err
70-
}
7168
if _, err := inject.SchemeInto(c.scheme, i); err != nil {
7269
return err
7370
}

pkg/controller/controller_test.go

+1-3
Original file line numberDiff line numberDiff line change
@@ -35,7 +35,6 @@ import (
3535
internalcontroller "sigs.k8s.io/controller-runtime/pkg/internal/controller"
3636
"sigs.k8s.io/controller-runtime/pkg/manager"
3737
"sigs.k8s.io/controller-runtime/pkg/reconcile"
38-
"sigs.k8s.io/controller-runtime/pkg/runtime/inject"
3938
"sigs.k8s.io/controller-runtime/pkg/source"
4039
)
4140

@@ -226,14 +225,13 @@ var _ = Describe("controller.Controller", func() {
226225
})
227226

228227
var _ reconcile.Reconciler = &failRec{}
229-
var _ inject.Client = &failRec{}
230228

231229
type failRec struct{}
232230

233231
func (*failRec) Reconcile(context.Context, reconcile.Request) (reconcile.Result, error) {
234232
return reconcile.Result{}, nil
235233
}
236234

237-
func (*failRec) InjectClient(client.Client) error {
235+
func (*failRec) InjectFunc(client.Client) error {
238236
return fmt.Errorf("expected error")
239237
}

pkg/manager/manager_test.go

+1-10
Original file line numberDiff line numberDiff line change
@@ -1553,13 +1553,6 @@ var _ = Describe("manger.Manager", func() {
15531553
By("Returning an error if dependency injection fails")
15541554

15551555
expected := fmt.Errorf("expected error")
1556-
err = m.SetFields(&injectable{
1557-
client: func(client client.Client) error {
1558-
return expected
1559-
},
1560-
})
1561-
Expect(err).To(Equal(expected))
1562-
15631556
err = m.SetFields(&injectable{
15641557
scheme: func(scheme *runtime.Scheme) error {
15651558
return expected
@@ -1685,7 +1678,6 @@ var _ = Describe("manger.Manager", func() {
16851678
})
16861679

16871680
var _ reconcile.Reconciler = &failRec{}
1688-
var _ inject.Client = &failRec{}
16891681

16901682
type failRec struct{}
16911683

@@ -1697,12 +1689,11 @@ func (*failRec) Start(context.Context) error {
16971689
return nil
16981690
}
16991691

1700-
func (*failRec) InjectClient(client.Client) error {
1692+
func (*failRec) InjectFunc(client.Client) error {
17011693
return fmt.Errorf("expected error")
17021694
}
17031695

17041696
var _ inject.Injector = &injectable{}
1705-
var _ inject.Client = &injectable{}
17061697
var _ inject.Scheme = &injectable{}
17071698
var _ inject.Logger = &injectable{}
17081699

pkg/runtime/inject/inject.go

-21
Original file line numberDiff line numberDiff line change
@@ -23,29 +23,8 @@ import (
2323
"github.com/go-logr/logr"
2424
"k8s.io/apimachinery/pkg/api/meta"
2525
"k8s.io/apimachinery/pkg/runtime"
26-
27-
"sigs.k8s.io/controller-runtime/pkg/client"
2826
)
2927

30-
// Client is used by the ControllerManager to inject client into Sources, EventHandlers, Predicates, and
31-
// Reconciles.
32-
//
33-
// Deprecated: Dependency injection methods are deprecated and going to be removed in a future version.
34-
type Client interface {
35-
InjectClient(client.Client) error
36-
}
37-
38-
// ClientInto will set client on i and return the result if it implements Client. Returns
39-
// false if i does not implement Client.
40-
//
41-
// Deprecated: Dependency injection methods are deprecated and going to be removed in a future version.
42-
func ClientInto(client client.Client, i interface{}) (bool, error) {
43-
if s, ok := i.(Client); ok {
44-
return true, s.InjectClient(client)
45-
}
46-
return false, nil
47-
}
48-
4928
// Scheme is used by the ControllerManager to inject Scheme into Sources, EventHandlers, Predicates, and
5029
// Reconciles.
5130
//

pkg/runtime/inject/inject_test.go

-23
Original file line numberDiff line numberDiff line change
@@ -26,7 +26,6 @@ import (
2626
"k8s.io/client-go/rest"
2727
"sigs.k8s.io/controller-runtime/pkg/cache"
2828
"sigs.k8s.io/controller-runtime/pkg/client"
29-
"sigs.k8s.io/controller-runtime/pkg/client/fake"
3029
)
3130

3231
var instance *testSource
@@ -40,28 +39,6 @@ var _ = Describe("runtime inject", func() {
4039
uninjectable = &failSource{}
4140
})
4241

43-
It("should set client", func() {
44-
client, err := client.NewDelegatingClient(client.NewDelegatingClientInput{Client: fake.NewClientBuilder().Build()})
45-
Expect(err).NotTo(HaveOccurred())
46-
47-
By("Validating injecting client")
48-
res, err := ClientInto(client, instance)
49-
Expect(err).NotTo(HaveOccurred())
50-
Expect(res).To(Equal(true))
51-
Expect(client).To(Equal(instance.GetClient()))
52-
53-
By("Returning false if the type does not implement inject.Client")
54-
res, err = ClientInto(client, uninjectable)
55-
Expect(err).NotTo(HaveOccurred())
56-
Expect(res).To(Equal(false))
57-
Expect(uninjectable.GetClient()).To(BeNil())
58-
59-
By("Returning an error if client injection fails")
60-
res, err = ClientInto(nil, instance)
61-
Expect(err).To(Equal(errInjectFail))
62-
Expect(res).To(Equal(true))
63-
})
64-
6542
It("should set scheme", func() {
6643

6744
scheme := runtime.NewScheme()

0 commit comments

Comments
 (0)