Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for FetchFromCluster (1.06 sec)

  1. cmd/kubeadm/app/componentconfigs/configset_test.go

    			kind: KubeletConfiguration
    		`),
    	}
    	client := clientsetfake.NewSimpleClientset(objects...)
    	clusterCfg := testClusterCfg()
    
    	if err := FetchFromCluster(clusterCfg, client); err != nil {
    		t.Fatalf("FetchFromCluster failed: %v", err)
    	}
    
    	if len(clusterCfg.ComponentConfigs) != len(objects) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 01 14:17:07 UTC 2022
    - 2.8K bytes
    - Viewed (0)
  2. cmd/kubeadm/app/componentconfigs/configset.go

    			componentCfg.Default(clusterCfg, localAPIEndpoint, nodeRegOpts)
    			clusterCfg.ComponentConfigs[group] = componentCfg
    		}
    	}
    }
    
    // FetchFromCluster attempts to fetch all known component configs from their config maps and store them in the supplied ClusterConfiguration
    func FetchFromCluster(clusterCfg *kubeadmapi.ClusterConfiguration, client clientset.Interface) error {
    	ensureInitializedComponentConfigs(clusterCfg)
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 04 15:36:00 UTC 2024
    - 10.8K bytes
    - Viewed (0)
  3. cmd/kubeadm/app/util/config/cluster.go

    		return nil, errors.Wrap(err, "failed to decode cluster configuration data")
    	}
    
    	if !skipComponentConfigs {
    		// get the component configs from the corresponding config maps
    		if err := componentconfigs.FetchFromCluster(&initcfg.ClusterConfiguration, client); err != nil {
    			return nil, errors.Wrap(err, "failed to get component configs")
    		}
    	}
    
    	// if this isn't a new controlplane instance (e.g. in case of kubeadm upgrades)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 01 11:04:08 UTC 2024
    - 11K bytes
    - Viewed (0)
Back to top