@@ -21,25 +21,23 @@ import (
2121 "context"
2222 "time"
2323
24- "github.com/streamnative/function-mesh/pkg/monitoring"
25- "k8s.io/apimachinery/pkg/types"
26- "sigs.k8s.io/controller-runtime/pkg/handler"
27- k8ssource "sigs.k8s.io/controller-runtime/pkg/source"
28-
2924 "github.com/go-logr/logr"
3025 "github.com/streamnative/function-mesh/api/compute/v1alpha1"
3126 "github.com/streamnative/function-mesh/controllers/spec"
27+ "github.com/streamnative/function-mesh/pkg/monitoring"
3228 "github.com/streamnative/function-mesh/utils"
3329 appsv1 "k8s.io/api/apps/v1"
3430 v1 "k8s.io/api/batch/v1"
3531 corev1 "k8s.io/api/core/v1"
3632 "k8s.io/apimachinery/pkg/api/errors"
3733 "k8s.io/apimachinery/pkg/runtime"
34+ "k8s.io/apimachinery/pkg/types"
3835 vpav1 "k8s.io/autoscaler/vertical-pod-autoscaler/pkg/apis/autoscaling.k8s.io/v1"
3936 "k8s.io/client-go/rest"
4037 ctrl "sigs.k8s.io/controller-runtime"
4138 "sigs.k8s.io/controller-runtime/pkg/builder"
4239 "sigs.k8s.io/controller-runtime/pkg/client"
40+ "sigs.k8s.io/controller-runtime/pkg/handler"
4341 "sigs.k8s.io/controller-runtime/pkg/predicate"
4442 "sigs.k8s.io/controller-runtime/pkg/reconcile"
4543)
@@ -191,10 +189,9 @@ func (r *SourceReconciler) SetupWithManager(mgr ctrl.Manager) error {
191189 if r .GroupVersionFlags != nil && r .GroupVersionFlags .APIAutoscalingGroupVersion != "" {
192190 AddControllerBuilderOwn (manager , r .GroupVersionFlags .APIAutoscalingGroupVersion )
193191 }
194- manager .Watches (& k8ssource. Kind { Type : & v1alpha1.BackendConfig {} }, handler .EnqueueRequestsFromMapFunc (
195- func (object client.Object ) []reconcile.Request {
192+ manager .Watches (& v1alpha1.BackendConfig {}, handler .EnqueueRequestsFromMapFunc (
193+ func (ctx context. Context , object client.Object ) []reconcile.Request {
196194 if object .GetName () == utils .GlobalBackendConfig && object .GetNamespace () == utils .GlobalBackendConfigNamespace {
197- ctx := context .Background ()
198195 sources := & v1alpha1.SourceList {}
199196 err := mgr .GetClient ().List (ctx , sources )
200197 if err != nil {
0 commit comments