From e174dcb3d6557b9d0af222c50d7f2f4a6e7a3583 Mon Sep 17 00:00:00 2001 From: zryfish Date: Wed, 8 Apr 2020 00:40:28 +0800 Subject: [PATCH] add cluster controller (#1993) --- cmd/controller-manager/app/controllers.go | 9 +++++++++ 1 file changed, 9 insertions(+) diff --git a/cmd/controller-manager/app/controllers.go b/cmd/controller-manager/app/controllers.go index 5c471ee69..df7867e7f 100644 --- a/cmd/controller-manager/app/controllers.go +++ b/cmd/controller-manager/app/controllers.go @@ -20,6 +20,7 @@ package app import ( "k8s.io/klog" "kubesphere.io/kubesphere/pkg/controller/application" + "kubesphere.io/kubesphere/pkg/controller/cluster" "kubesphere.io/kubesphere/pkg/controller/destinationrule" "kubesphere.io/kubesphere/pkg/controller/job" "kubesphere.io/kubesphere/pkg/controller/s2ibinary" @@ -93,6 +94,13 @@ func AddControllers( client.KubeSphere(), kubesphereInformer.Iam().V1alpha2().Users()) + clusterController := cluster.NewClusterController( + client.Kubernetes(), + kubesphereInformer.Cluster().V1alpha1().Clusters(), + kubesphereInformer.Cluster().V1alpha1().Agents(), + client.KubeSphere().ClusterV1alpha1().Agents(), + client.KubeSphere().ClusterV1alpha1().Clusters()) + controllers := map[string]manager.Runnable{ "virtualservice-controller": vsController, "destinationrule-controller": drController, @@ -102,6 +110,7 @@ func AddControllers( "s2irun-controller": s2iRunController, "volumeexpansion-controller": volumeExpansionController, "user-controller": userController, + "cluster-controller": clusterController, } for name, ctrl := range controllers {