func enqueueV1beta2PullBindingsForServiceAccount()

in internal/controller/acrpullbinding_v1beta2_controller.go [208:222]


func enqueueV1beta2PullBindingsForServiceAccount(mgr ctrl.Manager) func(ctx context.Context, object crclient.Object) []reconcile.Request {
	return func(ctx context.Context, object crclient.Object) []reconcile.Request {
		var pullBindings msiacrpullv1beta2.AcrPullBindingList
		if err := mgr.GetClient().List(ctx, &pullBindings, crclient.InNamespace(object.GetNamespace()), crclient.MatchingFields{serviceAccountField: object.GetName()}); err != nil {
			return nil
		}
		var requests []reconcile.Request
		for _, pullBinding := range pullBindings.Items {
			requests = append(requests, reconcile.Request{
				NamespacedName: crclient.ObjectKeyFromObject(&pullBinding),
			})
		}
		return requests
	}
}