Skip to content

Commit 4025b9a

Browse files
committed
Fix more reportcard issues and compile errors
1 parent 2de602c commit 4025b9a

File tree

4 files changed

+15
-15
lines changed

4 files changed

+15
-15
lines changed

pkg/controller/eventhandler/enqueue.go

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -36,15 +36,15 @@ func (e *EnqueueHandler) Create(q workqueue.RateLimitingInterface, evt event.Cre
3636
enqueueLog.Error(nil, "CreateEvent received with no metadata", "CreateEvent", evt)
3737
return
3838
}
39-
q.AddRateLimited(reconcile.ReconcileRequest{types.NamespacedName{
39+
q.AddRateLimited(reconcile.ReconcileRequest{NamespacedName:types.NamespacedName{
4040
Name: evt.Meta.GetName(),
4141
Namespace: evt.Meta.GetNamespace(),
4242
}})
4343
}
4444

4545
func (e *EnqueueHandler) Update(q workqueue.RateLimitingInterface, evt event.UpdateEvent) {
4646
if evt.MetaOld != nil {
47-
q.AddRateLimited(reconcile.ReconcileRequest{types.NamespacedName{
47+
q.AddRateLimited(reconcile.ReconcileRequest{NamespacedName:types.NamespacedName{
4848
Name: evt.MetaOld.GetName(),
4949
Namespace: evt.MetaOld.GetNamespace(),
5050
}})
@@ -53,7 +53,7 @@ func (e *EnqueueHandler) Update(q workqueue.RateLimitingInterface, evt event.Upd
5353
}
5454

5555
if evt.MetaNew != nil {
56-
q.AddRateLimited(reconcile.ReconcileRequest{types.NamespacedName{
56+
q.AddRateLimited(reconcile.ReconcileRequest{NamespacedName:types.NamespacedName{
5757
Name: evt.MetaNew.GetName(),
5858
Namespace: evt.MetaNew.GetNamespace(),
5959
}})
@@ -67,7 +67,7 @@ func (e *EnqueueHandler) Delete(q workqueue.RateLimitingInterface, evt event.Del
6767
enqueueLog.Error(nil, "DeleteEvent received with no metadata", "DeleteEvent", evt)
6868
return
6969
}
70-
q.AddRateLimited(reconcile.ReconcileRequest{types.NamespacedName{
70+
q.AddRateLimited(reconcile.ReconcileRequest{NamespacedName:types.NamespacedName{
7171
Name: evt.Meta.GetName(),
7272
Namespace: evt.Meta.GetNamespace(),
7373
}})
@@ -78,7 +78,7 @@ func (e *EnqueueHandler) Generic(q workqueue.RateLimitingInterface, evt event.Ge
7878
enqueueLog.Error(nil, "GenericEvent received with no metadata", "GenericEvent", evt)
7979
return
8080
}
81-
q.AddRateLimited(reconcile.ReconcileRequest{types.NamespacedName{
81+
q.AddRateLimited(reconcile.ReconcileRequest{NamespacedName:types.NamespacedName{
8282
Name: evt.Meta.GetName(),
8383
Namespace: evt.Meta.GetNamespace(),
8484
}})

pkg/controller/eventhandler/example_test.go

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -28,13 +28,13 @@ import (
2828
"k8s.io/client-go/util/workqueue"
2929
)
3030

31-
var controller controller.Controller
31+
var c controller.Controller
3232

3333
// This example watches Pods and enqueues ReconcileRequests with the Name and Namespace of the Pod from
3434
// the Event (i.e. change caused by a Create, Update, Delete).
3535
func ExampleEnqueueHandler() {
3636
// controller is a controller.controller
37-
controller.Watch(
37+
c.Watch(
3838
&source.KindSource{Type: &corev1.Pod{}},
3939
&eventhandler.EnqueueHandler{},
4040
)
@@ -44,7 +44,7 @@ func ExampleEnqueueHandler() {
4444
// owning (direct) Deployment responsible for the creation of the ReplicaSet.
4545
func ExampleEnqueueOwnerHandler() {
4646
// controller is a controller.controller
47-
controller.Watch(
47+
c.Watch(
4848
&source.KindSource{Type: &appsv1.ReplicaSet{}},
4949
&eventhandler.EnqueueOwnerHandler{
5050
OwnerType: &appsv1.Deployment{},
@@ -57,7 +57,7 @@ func ExampleEnqueueOwnerHandler() {
5757
// objects (of Type: MyKind) using a mapping function defined by the user.
5858
func ExampleEnqueueMappedHandler() {
5959
// controller is a controller.controller
60-
controller.Watch(
60+
c.Watch(
6161
&source.KindSource{Type: &appsv1.Deployment{}},
6262
&eventhandler.EnqueueMappedHandler{
6363
ToRequests: eventhandler.ToRequestsFunc(func(a eventhandler.MapObject) []reconcile.ReconcileRequest {
@@ -76,9 +76,9 @@ func ExampleEnqueueMappedHandler() {
7676
}
7777

7878
// This example implements eventhandler.EnqueueHandler.
79-
func ExampleEventHandlerFunc() {
79+
func ExampleEventHandlerFuncs() {
8080
// controller is a controller.controller
81-
controller.Watch(
81+
c.Watch(
8282
&source.KindSource{Type: &corev1.Pod{}},
8383
eventhandler.EventHandlerFuncs{
8484
CreateFunc: func(q workqueue.RateLimitingInterface, e event.CreateEvent) {

pkg/controller/predicate/example_test.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,7 @@ import (
2424
var p predicate.Predicate
2525

2626
// This example creates a new Predicate to drop Update Events where the Generation has not changed.
27-
func ExamplePredicateFunc() {
27+
func ExamplePredicateFuncs() {
2828
p = predicate.PredicateFuncs{
2929
UpdateFunc: func(e event.UpdateEvent) bool {
3030
return e.MetaOld.GetGeneration() != e.MetaNew.GetGeneration()

pkg/controller/source/example_test.go

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -24,12 +24,12 @@ import (
2424
"k8s.io/api/core/v1"
2525
)
2626

27-
var controller controller.Controller
27+
var ctrl controller.Controller
2828

2929
// This example Watches for Pod Events (e.g. Create / Update / Delete) and enqueues a ReconcileRequest
3030
// with the Name and Namespace of the Pod.
3131
func ExampleKindSource() {
32-
controller.Watch(
32+
ctrl.Watch(
3333
&source.KindSource{Type: &v1.Pod{}},
3434
&eventhandler.EnqueueHandler{},
3535
)
@@ -40,7 +40,7 @@ func ExampleKindSource() {
4040
func ExampleChannelSource() {
4141
events := make(chan event.GenericEvent)
4242

43-
controller.Watch(
43+
ctrl.Watch(
4444
source.ChannelSource(events),
4545
&eventhandler.EnqueueHandler{},
4646
)

0 commit comments

Comments
 (0)