update

Author: lichuqiang

pkg/client/config/config.go

@@ -110,6 +110,16 @@ func GetKubernetesClientSetOrDie() *kubernetes.Clientset {
 	return cs
 }
 
+// GetKubernetesClientSetOrDieWithConfig creates a *kubernetes.ClientSet with given config,
+// for talking to a Kubernetes apiserver.
+func GetKubernetesClientSetOrDieWithConfig(config *rest.Config) *kubernetes.Clientset {
+	cs, err := kubernetes.NewForConfig(config)
+	if err != nil {
+		log.Fatalf("%v", err)
+	}
+	return cs
+}
+
 // GetKubernetesInformers creates a informers.SharedInformerFactory for talking to a Kubernetes apiserver.
 // If --kubeconfig is set, will use the kubeconfig file at that location.  Otherwise will assume running
 // in cluster and use the cluster provided kubeconfig.

pkg/manager/manager.go

@@ -136,6 +136,6 @@ func New(config *rest.Config, options Options) (Manager, error) {
 
 	cm.recorderProvider = recorder.NewProvider()
 	cm.recorderProvider.SetScheme(cm.scheme)
-	cm.recorderProvider.SetClientSet(clientconfig.GetKubernetesClientSetOrDie())
+	cm.recorderProvider.SetClientSet(clientconfig.GetKubernetesClientSetOrDieWithConfig(config))
 	return cm, nil
 }