in clusterloader2/cmd/clusterloader.go [152:200]
func completeConfig(m *framework.MultiClientSet) error {
if clusterLoaderConfig.ClusterConfig.Nodes == 0 {
nodes, err := util.GetSchedulableUntainedNodesNumber(m.GetClient())
if err != nil {
if clusterLoaderConfig.ClusterConfig.Provider.Name() == provider.KCPName {
return fmt.Errorf("getting number of nodes error: %v, please create nodes.core CRD", err)
}
return fmt.Errorf("getting number of nodes error: %v", err)
}
clusterLoaderConfig.ClusterConfig.Nodes = nodes
klog.V(0).Infof("ClusterConfig.Nodes set to %v", nodes)
}
if clusterLoaderConfig.ClusterConfig.MasterName == "" {
masterName, err := util.GetMasterName(m.GetClient())
if err == nil {
clusterLoaderConfig.ClusterConfig.MasterName = masterName
klog.V(0).Infof("ClusterConfig.MasterName set to %v", masterName)
} else {
klog.Errorf("Getting master name error: %v", err)
}
}
if len(clusterLoaderConfig.ClusterConfig.MasterIPs) == 0 {
masterIPs, err := util.GetMasterIPs(m.GetClient(), corev1.NodeExternalIP)
if err == nil {
clusterLoaderConfig.ClusterConfig.MasterIPs = masterIPs
klog.V(0).Infof("ClusterConfig.MasterIP set to %v", masterIPs)
} else {
klog.Errorf("Getting master external ip error: %v", err)
}
}
if len(clusterLoaderConfig.ClusterConfig.MasterInternalIPs) == 0 {
masterIPs, err := util.GetMasterIPs(m.GetClient(), corev1.NodeInternalIP)
if err == nil {
clusterLoaderConfig.ClusterConfig.MasterInternalIPs = masterIPs
klog.V(0).Infof("ClusterConfig.MasterInternalIP set to %v", masterIPs)
} else {
klog.Errorf("Getting master internal ip error: %v", err)
}
}
if !clusterLoaderConfig.ClusterConfig.Provider.Features().SupportAccessAPIServerPprofEndpoint {
clusterLoaderConfig.ClusterConfig.APIServerPprofByClientEnabled = false
}
if clusterLoaderConfig.ClusterConfig.K8SClientsNumber == 0 {
clusterLoaderConfig.ClusterConfig.K8SClientsNumber = getClientsNumber(clusterLoaderConfig.ClusterConfig.Nodes)
}
prometheus.CompleteConfig(&clusterLoaderConfig.PrometheusConfig)
return nil
}