@@ -100,9 +100,7 @@ import (
100
100
var (
101
101
defaultCluster * object.ClusterComputeResource
102
102
svcClient clientset.Interface
103
- svcClient1 clientset.Interface
104
103
svcNamespace string
105
- svcNamespace1 string
106
104
vsanHealthClient * VsanClient
107
105
clusterComputeResource []* object.ClusterComputeResource
108
106
defaultDatastore * object.Datastore
@@ -1113,31 +1111,6 @@ func getSvcClientAndNamespace() (clientset.Interface, string) {
1113
1111
return svcClient , svcNamespace
1114
1112
}
1115
1113
1116
- // create kubernetes client for multi-supervisors clusters and returns it along with namespaces
1117
- func getMultiSvcClientAndNamespace () ([]clientset.Interface , []string , []error ) {
1118
- var err error
1119
- if svcClient == nil {
1120
- if k8senv := GetAndExpectStringEnvVar ("KUBECONFIG" ); k8senv != "" {
1121
- svcClient , err = createKubernetesClientFromConfig (k8senv )
1122
- if err != nil {
1123
- return []clientset.Interface {}, []string {}, []error {err , nil }
1124
- }
1125
- }
1126
- svcNamespace = GetAndExpectStringEnvVar (envSupervisorClusterNamespace )
1127
- }
1128
- if svcClient1 == nil {
1129
- if k8senv := GetAndExpectStringEnvVar ("KUBECONFIG1" ); k8senv != "" {
1130
- svcClient1 , err = createKubernetesClientFromConfig (k8senv )
1131
- if err != nil {
1132
- return []clientset.Interface {}, []string {}, []error {nil , err }
1133
- }
1134
- }
1135
- svcNamespace1 = GetAndExpectStringEnvVar (envSupervisorClusterNamespace1 )
1136
- }
1137
- // returns list of clientset, namespace and error if any for both svc
1138
- return []clientset.Interface {svcClient , svcClient1 }, []string {svcNamespace , svcNamespace1 }, []error {}
1139
- }
1140
-
1141
1114
// updateCSIDeploymentTemplateFullSyncInterval helps to update the
1142
1115
// FULL_SYNC_INTERVAL_MINUTES in deployment template. For this to take effect,
1143
1116
// we need to terminate the running csi controller pod.
0 commit comments