diff --git a/pkg/descheduler/descheduler.go b/pkg/descheduler/descheduler.go index da7c4564f..f5cd1e9fb 100644 --- a/pkg/descheduler/descheduler.go +++ b/pkg/descheduler/descheduler.go @@ -105,7 +105,7 @@ func NewDescheduler(karmadaClient karmadaclientset.Interface, kubeClient kuberne eventBroadcaster := record.NewBroadcaster() eventBroadcaster.StartStructuredLogging(0) - eventBroadcaster.StartRecordingToSink(&v1core.EventSinkImpl{Interface: kubeClient.CoreV1().Events("")}) + eventBroadcaster.StartRecordingToSink(&v1core.EventSinkImpl{Interface: kubeClient.CoreV1().Events(metav1.NamespaceAll)}) desched.eventRecorder = eventBroadcaster.NewRecorder(gclient.NewSchema(), corev1.EventSource{Component: "karmada-descheduler"}) return desched diff --git a/pkg/karmadactl/addons/init/enable_option.go b/pkg/karmadactl/addons/init/enable_option.go index 9a2556aae..7bc1bdf10 100644 --- a/pkg/karmadactl/addons/init/enable_option.go +++ b/pkg/karmadactl/addons/init/enable_option.go @@ -93,7 +93,7 @@ func (o *CommandAddonsEnableOption) Validate(args []string) error { if err != nil { return fmt.Errorf("failed to get nodes from cluster %s with member-kubeconfig and member-context. error: %v, Please check the Role or ClusterRole of the serviceAccount in your member-kubeconfig", o.Cluster, err) } - _, err = memberKubeClient.CoreV1().Pods("").List(context.TODO(), metav1.ListOptions{}) + _, err = memberKubeClient.CoreV1().Pods(metav1.NamespaceAll).List(context.TODO(), metav1.ListOptions{}) if err != nil { return fmt.Errorf("failed to get pods from cluster %s with member-kubeconfig and member-context. error: %v, Please check the Role or ClusterRole of the serviceAccount in your member-kubeconfig", o.Cluster, err) } diff --git a/pkg/karmadactl/cmdinit/kubernetes/services.go b/pkg/karmadactl/cmdinit/kubernetes/services.go index 8905f4d78..73c09af71 100644 --- a/pkg/karmadactl/cmdinit/kubernetes/services.go +++ b/pkg/karmadactl/cmdinit/kubernetes/services.go @@ -169,7 +169,7 @@ func (i *CommandInitOption) karmadaAggregatedAPIServerService() *corev1.Service } func (i CommandInitOption) isNodePortExist() bool { - svc, err := i.KubeClientSet.CoreV1().Services("").List(context.TODO(), metav1.ListOptions{}) + svc, err := i.KubeClientSet.CoreV1().Services(metav1.NamespaceAll).List(context.TODO(), metav1.ListOptions{}) if err != nil { klog.Exit(err) } diff --git a/pkg/karmadactl/get/get.go b/pkg/karmadactl/get/get.go index 30a694b60..8dce064fd 100644 --- a/pkg/karmadactl/get/get.go +++ b/pkg/karmadactl/get/get.go @@ -915,7 +915,7 @@ func (g *CommandGetOptions) getRBInKarmada() error { if !g.AllNamespaces { rbList, err = g.karmadaClient.WorkV1alpha2().ResourceBindings(*options.DefaultConfigFlags.Namespace).List(context.TODO(), metav1.ListOptions{}) } else { - rbList, err = g.karmadaClient.WorkV1alpha2().ResourceBindings("").List(context.TODO(), metav1.ListOptions{}) + rbList, err = g.karmadaClient.WorkV1alpha2().ResourceBindings(metav1.NamespaceAll).List(context.TODO(), metav1.ListOptions{}) } if err != nil { return err diff --git a/pkg/scheduler/event_handler.go b/pkg/scheduler/event_handler.go index 84992d67c..500318088 100644 --- a/pkg/scheduler/event_handler.go +++ b/pkg/scheduler/event_handler.go @@ -4,6 +4,7 @@ import ( corev1 "k8s.io/api/core/v1" "k8s.io/apimachinery/pkg/api/equality" "k8s.io/apimachinery/pkg/api/meta" + metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" "k8s.io/apimachinery/pkg/labels" v1core "k8s.io/client-go/kubernetes/typed/core/v1" "k8s.io/client-go/tools/cache" @@ -65,7 +66,7 @@ func (s *Scheduler) addAllEventHandlers() { eventBroadcaster := record.NewBroadcaster() eventBroadcaster.StartStructuredLogging(0) - eventBroadcaster.StartRecordingToSink(&v1core.EventSinkImpl{Interface: s.KubeClient.CoreV1().Events("")}) + eventBroadcaster.StartRecordingToSink(&v1core.EventSinkImpl{Interface: s.KubeClient.CoreV1().Events(metav1.NamespaceAll)}) s.eventRecorder = eventBroadcaster.NewRecorder(gclient.NewSchema(), corev1.EventSource{Component: s.schedulerName}) }