/
handler.go
61 lines (50 loc) · 1.76 KB
/
handler.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
// Copyright (c) 2021 Red Hat, Inc.
// Copyright Contributors to the Open Cluster Management project
package common
import (
"context"
"k8s.io/client-go/util/workqueue"
"sigs.k8s.io/controller-runtime/pkg/client"
"sigs.k8s.io/controller-runtime/pkg/event"
"sigs.k8s.io/controller-runtime/pkg/handler"
"sigs.k8s.io/controller-runtime/pkg/predicate"
)
var _ handler.EventHandler = &EnqueueRequestsFromMapFunc{}
// EnqueueRequestsFromMapFunc same as original EnqueueRequestsFromMapFunc
// execept this doesn't queue old object for update
type EnqueueRequestsFromMapFunc struct {
// Mapper transforms the argument into a slice of keys to be reconciled
ToRequests handler.MapFunc
}
// Create implements EventHandler
func (e *EnqueueRequestsFromMapFunc) Create(ctx context.Context, evt event.CreateEvent,
q workqueue.RateLimitingInterface,
) {
e.mapAndEnqueue(ctx, q, evt.Object)
}
// Update implements EventHandler
func (e *EnqueueRequestsFromMapFunc) Update(ctx context.Context, evt event.UpdateEvent,
q workqueue.RateLimitingInterface,
) {
e.mapAndEnqueue(ctx, q, evt.ObjectNew)
}
// Delete implements EventHandler
func (e *EnqueueRequestsFromMapFunc) Delete(ctx context.Context, evt event.DeleteEvent,
q workqueue.RateLimitingInterface,
) {
e.mapAndEnqueue(ctx, q, evt.Object)
}
// Generic implements EventHandler
func (e *EnqueueRequestsFromMapFunc) Generic(ctx context.Context, evt event.GenericEvent,
q workqueue.RateLimitingInterface,
) {
e.mapAndEnqueue(ctx, q, evt.Object)
}
func (e *EnqueueRequestsFromMapFunc) mapAndEnqueue(ctx context.Context, q workqueue.RateLimitingInterface,
object client.Object,
) {
for _, req := range e.ToRequests(ctx, object) {
q.Add(req)
}
}
var NeverEnqueue = predicate.NewPredicateFuncs(func(o client.Object) bool { return false })