@@ -13,12 +13,11 @@ import (
1313 "sigs.k8s.io/controller-runtime/pkg/controller"
1414 "sigs.k8s.io/controller-runtime/pkg/event"
1515 "sigs.k8s.io/controller-runtime/pkg/manager"
16- "sigs.k8s.io/controller-runtime/pkg/predicate"
1716 "sigs.k8s.io/controller-runtime/pkg/reconcile"
18-
19- "github.com/api7/api7-ingress-controller/internal/controller/indexer"
2017)
2118
19+ // +kubebuilder:rbac:groups="",resources=secrets,verbs=get;list;watch
20+
2221type SecretReconciler struct {
2322 client.Client
2423
@@ -38,8 +37,7 @@ func (r *SecretReconciler) SetupWithManager(mgr manager.Manager) error {
3837 return r .Log
3938 },
4039 }).
41- For (& corev1.Secret {}). //builder.WithPredicates(r.predicateFuncs()),
42-
40+ For (& corev1.Secret {}).
4341 Complete (r )
4442}
4543
@@ -55,22 +53,3 @@ func (r *SecretReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctr
5553 }
5654 return ctrl.Result {}, nil
5755}
58-
59- func (r * SecretReconciler ) predicateFuncs () predicate.Funcs {
60- predicateFuncs := predicate .NewPredicateFuncs (func (object client.Object ) bool {
61- if _ , ok := object .(* corev1.Secret ); ! ok {
62- return false
63- }
64- key := indexer .GenIndexKey (object .GetNamespace (), object .GetName ())
65- refs , err := r .Indexer .ByIndex ("referent" , key )
66- if err != nil {
67- r .Log .Error (err , "failed to check whether secret referred" , "namespace" , object .GetNamespace (), "name" , object .GetName ())
68- return false
69- }
70- return len (refs ) > 0
71- })
72- predicateFuncs .DeleteFunc = func (_ event.DeleteEvent ) bool {
73- return true
74- }
75- return predicateFuncs
76- }
0 commit comments