Skip to content

Commit a8c870b

Browse files
dependabot[bot]benashz
dependabot[bot]
and
benashz
authored
Bump the gomod-backward-compatible group across 1 directory with 14 updates (#943)
* Update to support the TypedEventHandler interface Related upstream change: - kubernetes-sigs/controller-runtime#2799 * Support the sha512sum Sprig template function Bumps the gomod-backward-compatible group with 11 updates in the / directory: | Package | From | To | | --- | --- | --- | | [cloud.google.com/go/compute/metadata](https://github.com/googleapis/google-cloud-go) | `0.5.0` | `0.5.2` | | [github.com/Masterminds/sprig/v3](https://github.com/Masterminds/sprig) | `3.2.3` | `3.3.0` | | [github.com/gruntwork-io/terratest](https://github.com/gruntwork-io/terratest) | `0.47.0` | `0.47.2` | | [github.com/hashicorp/hcp-sdk-go](https://github.com/hashicorp/hcp-sdk-go) | `0.110.0` | `0.115.0` | | [github.com/onsi/gomega](https://github.com/onsi/gomega) | `1.34.1` | `1.34.2` | | [github.com/prometheus/client_golang](https://github.com/prometheus/client_golang) | `1.20.3` | `1.20.4` | | [golang.org/x/crypto](https://github.com/golang/crypto) | `0.26.0` | `0.27.0` | | [google.golang.org/api](https://github.com/googleapis/google-api-go-client) | `0.192.0` | `0.199.0` | | [k8s.io/apiextensions-apiserver](https://github.com/kubernetes/apiextensions-apiserver) | `0.30.3` | `0.31.1` | | [sigs.k8s.io/controller-runtime](https://github.com/kubernetes-sigs/controller-runtime) | `0.18.4` | `0.19.0` | | [nhooyr.io/websocket](https://github.com/nhooyr/websocket-old) | `1.8.11` | `1.8.17` | Updates `cloud.google.com/go/compute/metadata` from 0.5.0 to 0.5.2 - [Release notes](https://github.com/googleapis/google-cloud-go/releases) - [Changelog](https://github.com/googleapis/google-cloud-go/blob/main/CHANGES.md) - [Commits](googleapis/google-cloud-go@v0.5.0...auth/v0.5.2) Updates `github.com/Masterminds/sprig/v3` from 3.2.3 to 3.3.0 - [Release notes](https://github.com/Masterminds/sprig/releases) - [Changelog](https://github.com/Masterminds/sprig/blob/master/CHANGELOG.md) - [Commits](Masterminds/sprig@v3.2.3...v3.3.0) Updates `github.com/gruntwork-io/terratest` from 0.47.0 to 0.47.2 - [Release notes](https://github.com/gruntwork-io/terratest/releases) - [Commits](gruntwork-io/terratest@v0.47.0...v0.47.2) Updates `github.com/hashicorp/hcp-sdk-go` from 0.110.0 to 0.115.0 - [Release notes](https://github.com/hashicorp/hcp-sdk-go/releases) - [Changelog](https://github.com/hashicorp/hcp-sdk-go/blob/main/CHANGELOG.md) - [Commits](hashicorp/hcp-sdk-go@v0.110.0...v0.115.0) Updates `github.com/onsi/gomega` from 1.34.1 to 1.34.2 - [Release notes](https://github.com/onsi/gomega/releases) - [Changelog](https://github.com/onsi/gomega/blob/master/CHANGELOG.md) - [Commits](onsi/gomega@v1.34.1...v1.34.2) Updates `github.com/prometheus/client_golang` from 1.20.3 to 1.20.4 - [Release notes](https://github.com/prometheus/client_golang/releases) - [Changelog](https://github.com/prometheus/client_golang/blob/main/CHANGELOG.md) - [Commits](prometheus/client_golang@v1.20.3...v1.20.4) Updates `golang.org/x/crypto` from 0.26.0 to 0.27.0 - [Commits](golang/crypto@v0.26.0...v0.27.0) Updates `google.golang.org/api` from 0.192.0 to 0.199.0 - [Release notes](https://github.com/googleapis/google-api-go-client/releases) - [Changelog](https://github.com/googleapis/google-api-go-client/blob/main/CHANGES.md) - [Commits](googleapis/google-api-go-client@v0.192.0...v0.199.0) Updates `k8s.io/apiextensions-apiserver` from 0.30.3 to 0.31.1 - [Release notes](https://github.com/kubernetes/apiextensions-apiserver/releases) - [Commits](kubernetes/apiextensions-apiserver@v0.30.3...v0.31.1) Updates `k8s.io/apimachinery` from 0.30.3 to 0.31.1 - [Commits](kubernetes/apimachinery@v0.30.3...v0.31.1) Updates `k8s.io/client-go` from 0.30.3 to 0.31.1 - [Changelog](https://github.com/kubernetes/client-go/blob/master/CHANGELOG.md) - [Commits](kubernetes/client-go@v0.30.3...v0.31.1) Updates `k8s.io/utils` from 0.0.0-20230726121419-3b25d923346b to 0.0.0-20240711033017-18e509b52bc8 - [Commits](https://github.com/kubernetes/utils/commits) Updates `sigs.k8s.io/controller-runtime` from 0.18.4 to 0.19.0 - [Release notes](https://github.com/kubernetes-sigs/controller-runtime/releases) - [Changelog](https://github.com/kubernetes-sigs/controller-runtime/blob/main/RELEASE.md) - [Commits](kubernetes-sigs/controller-runtime@v0.18.4...v0.19.0) Updates `nhooyr.io/websocket` from 1.8.11 to 1.8.17 - [Release notes](https://github.com/nhooyr/websocket-old/releases) - [Commits](https://github.com/nhooyr/websocket-old/commits/v1.8.17) --- updated-dependencies: - dependency-name: cloud.google.com/go/compute/metadata dependency-type: direct:production update-type: version-update:semver-patch dependency-group: gomod-backward-compatible - dependency-name: github.com/Masterminds/sprig/v3 dependency-type: direct:production update-type: version-update:semver-minor dependency-group: gomod-backward-compatible - dependency-name: github.com/gruntwork-io/terratest dependency-type: direct:production update-type: version-update:semver-patch dependency-group: gomod-backward-compatible - dependency-name: github.com/hashicorp/hcp-sdk-go dependency-type: direct:production update-type: version-update:semver-minor dependency-group: gomod-backward-compatible - dependency-name: github.com/onsi/gomega dependency-type: direct:production update-type: version-update:semver-patch dependency-group: gomod-backward-compatible - dependency-name: github.com/prometheus/client_golang dependency-type: direct:production update-type: version-update:semver-patch dependency-group: gomod-backward-compatible - dependency-name: golang.org/x/crypto dependency-type: direct:production update-type: version-update:semver-minor dependency-group: gomod-backward-compatible - dependency-name: google.golang.org/api dependency-type: direct:production update-type: version-update:semver-minor dependency-group: gomod-backward-compatible - dependency-name: k8s.io/apiextensions-apiserver dependency-type: direct:production update-type: version-update:semver-minor dependency-group: gomod-backward-compatible - dependency-name: k8s.io/apimachinery dependency-type: direct:production update-type: version-update:semver-minor dependency-group: gomod-backward-compatible - dependency-name: k8s.io/client-go dependency-type: direct:production update-type: version-update:semver-minor dependency-group: gomod-backward-compatible - dependency-name: k8s.io/utils dependency-type: direct:production update-type: version-update:semver-patch dependency-group: gomod-backward-compatible - dependency-name: sigs.k8s.io/controller-runtime dependency-type: direct:production update-type: version-update:semver-minor dependency-group: gomod-backward-compatible - dependency-name: nhooyr.io/websocket dependency-type: direct:production update-type: version-update:semver-patch dependency-group: gomod-backward-compatible ... Signed-off-by: dependabot[bot] <[email protected]> --------- Signed-off-by: dependabot[bot] <[email protected]> Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com> Co-authored-by: Ben Ash <[email protected]>
1 parent 60a4bd2 commit a8c870b

File tree

6 files changed

+206
-201
lines changed

6 files changed

+206
-201
lines changed

‎controllers/eventhandlers.go

+15-15
Original file line numberDiff line numberDiff line change
@@ -53,13 +53,13 @@ type enqueueRefRequestsHandler struct {
5353
}
5454

5555
func (e *enqueueRefRequestsHandler) Create(ctx context.Context,
56-
evt event.CreateEvent, q workqueue.RateLimitingInterface,
56+
evt event.CreateEvent, q workqueue.TypedRateLimitingInterface[reconcile.Request],
5757
) {
5858
e.enqueue(ctx, q, evt.Object)
5959
}
6060

6161
func (e *enqueueRefRequestsHandler) Update(ctx context.Context,
62-
evt event.UpdateEvent, q workqueue.RateLimitingInterface,
62+
evt event.UpdateEvent, q workqueue.TypedRateLimitingInterface[reconcile.Request],
6363
) {
6464
if evt.ObjectOld == nil {
6565
return
@@ -73,19 +73,19 @@ func (e *enqueueRefRequestsHandler) Update(ctx context.Context,
7373
}
7474
}
7575

76-
func (e *enqueueRefRequestsHandler) Delete(ctx context.Context,
77-
evt event.DeleteEvent, _ workqueue.RateLimitingInterface,
76+
func (e *enqueueRefRequestsHandler) Delete(_ context.Context,
77+
evt event.DeleteEvent, _ workqueue.TypedRateLimitingInterface[reconcile.Request],
7878
) {
7979
e.refCache.Prune(e.kind, client.ObjectKeyFromObject(evt.Object))
8080
}
8181

82-
func (e *enqueueRefRequestsHandler) Generic(ctx context.Context,
83-
_ event.GenericEvent, _ workqueue.RateLimitingInterface,
82+
func (e *enqueueRefRequestsHandler) Generic(_ context.Context,
83+
_ event.GenericEvent, _ workqueue.TypedRateLimitingInterface[reconcile.Request],
8484
) {
8585
}
8686

8787
func (e *enqueueRefRequestsHandler) enqueue(ctx context.Context,
88-
q workqueue.RateLimitingInterface, o client.Object,
88+
q workqueue.TypedRateLimitingInterface[reconcile.Request], o client.Object,
8989
) {
9090
logger := log.FromContext(ctx).WithName(
9191
"enqueueRefRequestsHandler").
@@ -138,17 +138,17 @@ type enqueueOnDeletionRequestHandler struct {
138138
}
139139

140140
func (e *enqueueOnDeletionRequestHandler) Create(_ context.Context,
141-
_ event.CreateEvent, _ workqueue.RateLimitingInterface,
141+
_ event.CreateEvent, _ workqueue.TypedRateLimitingInterface[reconcile.Request],
142142
) {
143143
}
144144

145145
func (e *enqueueOnDeletionRequestHandler) Update(_ context.Context,
146-
_ event.UpdateEvent, _ workqueue.RateLimitingInterface,
146+
_ event.UpdateEvent, _ workqueue.TypedRateLimitingInterface[reconcile.Request],
147147
) {
148148
}
149149

150150
func (e *enqueueOnDeletionRequestHandler) Delete(ctx context.Context,
151-
evt event.DeleteEvent, q workqueue.RateLimitingInterface,
151+
evt event.DeleteEvent, q workqueue.TypedRateLimitingInterface[reconcile.Request],
152152
) {
153153
logger := log.FromContext(ctx).WithName("enqueueOnDeletionRequestHandler").
154154
WithValues("ownerGVK", e.gvk)
@@ -179,7 +179,7 @@ func (e *enqueueOnDeletionRequestHandler) Delete(ctx context.Context,
179179
}
180180

181181
func (e *enqueueOnDeletionRequestHandler) Generic(ctx context.Context,
182-
_ event.GenericEvent, _ workqueue.RateLimitingInterface,
182+
_ event.GenericEvent, _ workqueue.TypedRateLimitingInterface[reconcile.Request],
183183
) {
184184
}
185185

@@ -189,16 +189,16 @@ type enqueueDelayingSyncEventHandler struct {
189189
enqueueDurationForJitter time.Duration
190190
}
191191

192-
func (e *enqueueDelayingSyncEventHandler) Create(_ context.Context, _ event.CreateEvent, _ workqueue.RateLimitingInterface) {
192+
func (e *enqueueDelayingSyncEventHandler) Create(_ context.Context, _ event.CreateEvent, _ workqueue.TypedRateLimitingInterface[reconcile.Request]) {
193193
}
194194

195-
func (e *enqueueDelayingSyncEventHandler) Update(_ context.Context, _ event.UpdateEvent, _ workqueue.RateLimitingInterface) {
195+
func (e *enqueueDelayingSyncEventHandler) Update(_ context.Context, _ event.UpdateEvent, _ workqueue.TypedRateLimitingInterface[reconcile.Request]) {
196196
}
197197

198-
func (e *enqueueDelayingSyncEventHandler) Delete(_ context.Context, _ event.DeleteEvent, _ workqueue.RateLimitingInterface) {
198+
func (e *enqueueDelayingSyncEventHandler) Delete(_ context.Context, _ event.DeleteEvent, _ workqueue.TypedRateLimitingInterface[reconcile.Request]) {
199199
}
200200

201-
func (e *enqueueDelayingSyncEventHandler) Generic(ctx context.Context, evt event.GenericEvent, q workqueue.RateLimitingInterface) {
201+
func (e *enqueueDelayingSyncEventHandler) Generic(ctx context.Context, evt event.GenericEvent, q workqueue.TypedRateLimitingInterface[reconcile.Request]) {
202202
logger := log.FromContext(ctx).WithName("enqueueDelayingSyncEventHandler")
203203
if evt.Object == nil {
204204
logger.Error(nil,

‎controllers/eventhandlers_test.go

+29-29
Original file line numberDiff line numberDiff line change
@@ -110,7 +110,7 @@ func Test_enqueueRefRequestsHandler_Create(t *testing.T) {
110110
refCache: cache,
111111
createEvents: createEvents,
112112
q: &DelegatingQueue{
113-
Interface: workqueue.New(),
113+
TypedRateLimitingInterface: workqueue.NewTypedRateLimitingQueue[reconcile.Request](nil),
114114
},
115115
wantAddedAfter: wantAddedAfterValid,
116116
maxRequeueAfter: time.Second * 10,
@@ -122,7 +122,7 @@ func Test_enqueueRefRequestsHandler_Create(t *testing.T) {
122122
refCache: cache,
123123
createEvents: createEvents,
124124
q: &DelegatingQueue{
125-
Interface: workqueue.New(),
125+
TypedRateLimitingInterface: workqueue.NewTypedRateLimitingQueue[reconcile.Request](nil),
126126
},
127127
wantAddedAfter: wantAddedAfterValid,
128128
wantRefCache: cache,
@@ -133,7 +133,7 @@ func Test_enqueueRefRequestsHandler_Create(t *testing.T) {
133133
refCache: cache,
134134
createEvents: createEvents,
135135
q: &DelegatingQueue{
136-
Interface: workqueue.New(),
136+
TypedRateLimitingInterface: workqueue.NewTypedRateLimitingQueue[reconcile.Request](nil),
137137
},
138138
wantAddedAfter: wantAddedAfterValid,
139139
maxRequeueAfter: time.Second * -1,
@@ -146,7 +146,7 @@ func Test_enqueueRefRequestsHandler_Create(t *testing.T) {
146146
createEvents: createEvents,
147147
validator: &validatorFunc{},
148148
q: &DelegatingQueue{
149-
Interface: workqueue.New(),
149+
TypedRateLimitingInterface: workqueue.NewTypedRateLimitingQueue[reconcile.Request](nil),
150150
},
151151
wantValidObjects: []client.Object{
152152
createEvent.Object,
@@ -162,7 +162,7 @@ func Test_enqueueRefRequestsHandler_Create(t *testing.T) {
162162
createEvents: createEvents,
163163
validator: &validatorFunc{},
164164
q: &DelegatingQueue{
165-
Interface: workqueue.New(),
165+
TypedRateLimitingInterface: workqueue.NewTypedRateLimitingQueue[reconcile.Request](nil),
166166
},
167167
wantInvalidObjects: []client.Object{
168168
createEvent.Object,
@@ -178,7 +178,7 @@ func Test_enqueueRefRequestsHandler_Create(t *testing.T) {
178178
},
179179
createEvents: createEvents,
180180
q: &DelegatingQueue{
181-
Interface: workqueue.New(),
181+
TypedRateLimitingInterface: workqueue.NewTypedRateLimitingQueue[reconcile.Request](nil),
182182
},
183183
},
184184
}
@@ -250,7 +250,7 @@ func Test_enqueueRefRequestsHandler_Update(t *testing.T) {
250250
refCache: cache,
251251
updateEvents: updateEventsEnqueue,
252252
q: &DelegatingQueue{
253-
Interface: workqueue.New(),
253+
TypedRateLimitingInterface: workqueue.NewTypedRateLimitingQueue[reconcile.Request](nil),
254254
},
255255
wantAddedAfter: wantAddedAfterValid,
256256
wantRefCache: cache,
@@ -262,7 +262,7 @@ func Test_enqueueRefRequestsHandler_Update(t *testing.T) {
262262
updateEvents: updateEventsEnqueue,
263263
validator: &validatorFunc{},
264264
q: &DelegatingQueue{
265-
Interface: workqueue.New(),
265+
TypedRateLimitingInterface: workqueue.NewTypedRateLimitingQueue[reconcile.Request](nil),
266266
},
267267
wantValidObjects: []client.Object{
268268
objectNew,
@@ -278,7 +278,7 @@ func Test_enqueueRefRequestsHandler_Update(t *testing.T) {
278278
updateEvents: updateEventsEnqueue,
279279
validator: &validatorFunc{},
280280
q: &DelegatingQueue{
281-
Interface: workqueue.New(),
281+
TypedRateLimitingInterface: workqueue.NewTypedRateLimitingQueue[reconcile.Request](nil),
282282
},
283283
wantInvalidObjects: []client.Object{
284284
objectNew,
@@ -294,7 +294,7 @@ func Test_enqueueRefRequestsHandler_Update(t *testing.T) {
294294
},
295295
updateEvents: updateEventsEnqueue,
296296
q: &DelegatingQueue{
297-
Interface: workqueue.New(),
297+
TypedRateLimitingInterface: workqueue.NewTypedRateLimitingQueue[reconcile.Request](nil),
298298
},
299299
},
300300
{
@@ -303,7 +303,7 @@ func Test_enqueueRefRequestsHandler_Update(t *testing.T) {
303303
refCache: cache,
304304
updateEvents: updateEventsNoEnqueue,
305305
q: &DelegatingQueue{
306-
Interface: workqueue.New(),
306+
TypedRateLimitingInterface: workqueue.NewTypedRateLimitingQueue[reconcile.Request](nil),
307307
},
308308
},
309309
}
@@ -353,7 +353,7 @@ func Test_enqueueRefRequestsHandler_Delete(t *testing.T) {
353353
kind: SecretTransformation,
354354
refCache: cache,
355355
q: &DelegatingQueue{
356-
Interface: workqueue.New(),
356+
TypedRateLimitingInterface: workqueue.NewTypedRateLimitingQueue[reconcile.Request](nil),
357357
},
358358
deleteEvents: []event.DeleteEvent{
359359
{
@@ -369,7 +369,7 @@ func Test_enqueueRefRequestsHandler_Delete(t *testing.T) {
369369
kind: SecretTransformation,
370370
refCache: cache,
371371
q: &DelegatingQueue{
372-
Interface: workqueue.New(),
372+
TypedRateLimitingInterface: workqueue.NewTypedRateLimitingQueue[reconcile.Request](nil),
373373
},
374374
deleteEvents: []event.DeleteEvent{
375375
{
@@ -383,7 +383,7 @@ func Test_enqueueRefRequestsHandler_Delete(t *testing.T) {
383383
kind: SecretTransformation,
384384
refCache: cache,
385385
q: &DelegatingQueue{
386-
Interface: workqueue.New(),
386+
TypedRateLimitingInterface: workqueue.NewTypedRateLimitingQueue[reconcile.Request](nil),
387387
},
388388
deleteEvents: []event.DeleteEvent{
389389
{
@@ -469,29 +469,29 @@ func assertEnqueueRefRequestHandler(t *testing.T, ctx context.Context, tt testCa
469469
}
470470
}
471471

472-
var _ workqueue.RateLimitingInterface = &DelegatingQueue{}
472+
var _ workqueue.TypedRateLimitingInterface[reconcile.Request] = &DelegatingQueue{}
473473

474474
type DelegatingQueue struct {
475-
workqueue.Interface
475+
workqueue.TypedRateLimitingInterface[reconcile.Request]
476476
mu sync.Mutex
477477
AddedAfter []any
478478
AddedAfterDuration []time.Duration
479479
}
480480

481481
// AddAfter implements RateLimitingInterface.
482-
func (q *DelegatingQueue) AddAfter(item interface{}, d time.Duration) {
482+
func (q *DelegatingQueue) AddAfter(item reconcile.Request, d time.Duration) {
483483
q.mu.Lock()
484484
defer q.mu.Unlock()
485485
q.AddedAfter = append(q.AddedAfter, item)
486486
q.AddedAfterDuration = append(q.AddedAfterDuration, d)
487487
q.Add(item)
488488
}
489489

490-
func (q *DelegatingQueue) AddRateLimited(item interface{}) {}
490+
func (q *DelegatingQueue) AddRateLimited(item reconcile.Request) {}
491491

492-
func (q *DelegatingQueue) Forget(item interface{}) {}
492+
func (q *DelegatingQueue) Forget(item reconcile.Request) {}
493493

494-
func (q *DelegatingQueue) NumRequeues(item interface{}) int {
494+
func (q *DelegatingQueue) NumRequeues(item reconcile.Request) int {
495495
return 0
496496
}
497497

@@ -553,7 +553,7 @@ func Test_enqueueOnDeletionRequestHandler_Delete(t *testing.T) {
553553
deleteEventSupported,
554554
},
555555
q: &DelegatingQueue{
556-
Interface: workqueue.New(),
556+
TypedRateLimitingInterface: workqueue.NewTypedRateLimitingQueue[reconcile.Request](nil),
557557
},
558558
gvk: gvk,
559559
wantAddedAfter: wantAddedAfterValid,
@@ -567,7 +567,7 @@ func Test_enqueueOnDeletionRequestHandler_Delete(t *testing.T) {
567567
deleteEventSupported,
568568
},
569569
q: &DelegatingQueue{
570-
Interface: workqueue.New(),
570+
TypedRateLimitingInterface: workqueue.NewTypedRateLimitingQueue[reconcile.Request](nil),
571571
},
572572
gvk: gvk,
573573
wantAddedAfter: wantAddedAfterValid,
@@ -581,7 +581,7 @@ func Test_enqueueOnDeletionRequestHandler_Delete(t *testing.T) {
581581
deleteEventSupported,
582582
},
583583
q: &DelegatingQueue{
584-
Interface: workqueue.New(),
584+
TypedRateLimitingInterface: workqueue.NewTypedRateLimitingQueue[reconcile.Request](nil),
585585
},
586586
gvk: gvk,
587587
wantAddedAfter: wantAddedAfterValid,
@@ -594,7 +594,7 @@ func Test_enqueueOnDeletionRequestHandler_Delete(t *testing.T) {
594594
deleteEventSupported,
595595
},
596596
q: &DelegatingQueue{
597-
Interface: workqueue.New(),
597+
TypedRateLimitingInterface: workqueue.NewTypedRateLimitingQueue[reconcile.Request](nil),
598598
},
599599
gvk: gvk,
600600
wantAddedAfter: wantAddedAfterValid,
@@ -607,7 +607,7 @@ func Test_enqueueOnDeletionRequestHandler_Delete(t *testing.T) {
607607
deleteEventUnsupported,
608608
},
609609
q: &DelegatingQueue{
610-
Interface: workqueue.New(),
610+
TypedRateLimitingInterface: workqueue.NewTypedRateLimitingQueue[reconcile.Request](nil),
611611
},
612612
gvk: gvk,
613613
},
@@ -671,7 +671,7 @@ func Test_enqueueOnDeletionRequestHandler_Create(t *testing.T) {
671671
createEvent,
672672
},
673673
q: &DelegatingQueue{
674-
Interface: workqueue.New(),
674+
TypedRateLimitingInterface: workqueue.NewTypedRateLimitingQueue[reconcile.Request](nil),
675675
},
676676
gvk: gvk,
677677
wantAddedAfter: nil,
@@ -683,7 +683,7 @@ func Test_enqueueOnDeletionRequestHandler_Create(t *testing.T) {
683683
createEventUnsupported,
684684
},
685685
q: &DelegatingQueue{
686-
Interface: workqueue.New(),
686+
TypedRateLimitingInterface: workqueue.NewTypedRateLimitingQueue[reconcile.Request](nil),
687687
},
688688
gvk: gvk,
689689
wantAddedAfter: nil,
@@ -767,7 +767,7 @@ func Test_enqueueOnDeletionRequestHandler_Update(t *testing.T) {
767767
updateEvent,
768768
},
769769
q: &DelegatingQueue{
770-
Interface: workqueue.New(),
770+
TypedRateLimitingInterface: workqueue.NewTypedRateLimitingQueue[reconcile.Request](nil),
771771
},
772772
gvk: gvk,
773773
wantAddedAfter: nil,
@@ -779,7 +779,7 @@ func Test_enqueueOnDeletionRequestHandler_Update(t *testing.T) {
779779
updateEventUnsupported,
780780
},
781781
q: &DelegatingQueue{
782-
Interface: workqueue.New(),
782+
TypedRateLimitingInterface: workqueue.NewTypedRateLimitingQueue[reconcile.Request](nil),
783783
},
784784
gvk: gvk,
785785
wantAddedAfter: nil,

‎controllers/vaultdynamicsecret_controller_test.go

+2-2
Original file line numberDiff line numberDiff line change
@@ -840,7 +840,7 @@ func Test_computeRelativeHorizonWithJitter(t *testing.T) {
840840
},
841841
minHorizon: 1 * time.Second,
842842
wantMinHorizon: time.Duration(.8 * float64(time.Second)),
843-
wantMaxHorizon: time.Duration(1 * time.Second),
843+
wantMaxHorizon: 1 * time.Second,
844844
wantInWindow: true,
845845
},
846846
}
@@ -1157,7 +1157,7 @@ func TestVaultDynamicSecretReconciler_vaultClientCallback(t *testing.T) {
11571157
cs := source.Channel(r.SourceCh, handler)
11581158

11591159
q := &DelegatingQueue{
1160-
Interface: workqueue.New(),
1160+
TypedRateLimitingInterface: workqueue.NewTypedRateLimitingQueue[reconcile.Request](nil),
11611161
}
11621162

11631163
go func() {

0 commit comments

Comments
 (0)