mirror of https://github.com/k3s-io/k3s
util/config` packages; filenames and methods should be updated to use new names
parent
a29b093a56
commit
8729cade98
|
@ -194,7 +194,7 @@ func getDefaultInitConfigBytes(kind string) ([]byte, error) {
|
||||||
}
|
}
|
||||||
|
|
||||||
func getDefaultNodeConfigBytes() ([]byte, error) {
|
func getDefaultNodeConfigBytes() ([]byte, error) {
|
||||||
internalcfg, err := configutil.NodeConfigFileAndDefaultsToInternalConfig("", &kubeadmapiv1beta1.JoinConfiguration{
|
internalcfg, err := configutil.JoinConfigFileAndDefaultsToInternalConfig("", &kubeadmapiv1beta1.JoinConfiguration{
|
||||||
Token: sillyToken.Token.String(),
|
Token: sillyToken.Token.String(),
|
||||||
DiscoveryTokenAPIServers: []string{"kube-apiserver:6443"},
|
DiscoveryTokenAPIServers: []string{"kube-apiserver:6443"},
|
||||||
DiscoveryTokenUnsafeSkipCAVerification: true, // TODO: DiscoveryTokenUnsafeSkipCAVerification: true needs to be set for validation to pass, but shouldn't be recommended as the default
|
DiscoveryTokenUnsafeSkipCAVerification: true, // TODO: DiscoveryTokenUnsafeSkipCAVerification: true needs to be set for validation to pass, but shouldn't be recommended as the default
|
||||||
|
|
|
@ -274,7 +274,7 @@ func NewJoin(cfgPath string, args []string, defaultcfg *kubeadmapiv1beta1.JoinCo
|
||||||
glog.V(1).Infoln("[join] found advertiseAddress empty; using default interface's IP address as advertiseAddress")
|
glog.V(1).Infoln("[join] found advertiseAddress empty; using default interface's IP address as advertiseAddress")
|
||||||
}
|
}
|
||||||
|
|
||||||
internalcfg, err := configutil.NodeConfigFileAndDefaultsToInternalConfig(cfgPath, defaultcfg)
|
internalcfg, err := configutil.JoinConfigFileAndDefaultsToInternalConfig(cfgPath, defaultcfg)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
|
|
|
@ -128,7 +128,7 @@ func NewCmdPreFlightNode(cfgPath *string, ignorePreflightErrors *[]string) *cobr
|
||||||
cfg := &kubeadmapiv1beta1.JoinConfiguration{}
|
cfg := &kubeadmapiv1beta1.JoinConfiguration{}
|
||||||
kubeadmscheme.Scheme.Default(cfg)
|
kubeadmscheme.Scheme.Default(cfg)
|
||||||
|
|
||||||
internalcfg, err := configutil.NodeConfigFileAndDefaultsToInternalConfig(*cfgPath, cfg)
|
internalcfg, err := configutil.JoinConfigFileAndDefaultsToInternalConfig(*cfgPath, cfg)
|
||||||
kubeadmutil.CheckErr(err)
|
kubeadmutil.CheckErr(err)
|
||||||
err = configutil.VerifyAPIServerBindAddress(internalcfg.APIEndpoint.AdvertiseAddress)
|
err = configutil.VerifyAPIServerBindAddress(internalcfg.APIEndpoint.AdvertiseAddress)
|
||||||
kubeadmutil.CheckErr(err)
|
kubeadmutil.CheckErr(err)
|
||||||
|
|
|
@ -11,8 +11,8 @@ go_library(
|
||||||
srcs = [
|
srcs = [
|
||||||
"cluster.go",
|
"cluster.go",
|
||||||
"common.go",
|
"common.go",
|
||||||
"masterconfig.go",
|
"initconfiguration.go",
|
||||||
"nodeconfig.go",
|
"joinconfiguration.go",
|
||||||
],
|
],
|
||||||
importpath = "k8s.io/kubernetes/cmd/kubeadm/app/util/config",
|
importpath = "k8s.io/kubernetes/cmd/kubeadm/app/util/config",
|
||||||
deps = [
|
deps = [
|
||||||
|
@ -43,8 +43,8 @@ go_test(
|
||||||
srcs = [
|
srcs = [
|
||||||
"cluster_test.go",
|
"cluster_test.go",
|
||||||
"common_test.go",
|
"common_test.go",
|
||||||
"masterconfig_test.go",
|
"initconfiguration_test.go",
|
||||||
"nodeconfig_test.go",
|
"joinconfiguration_test.go",
|
||||||
],
|
],
|
||||||
data = glob(["testdata/**"]),
|
data = glob(["testdata/**"]),
|
||||||
embed = [":go_default_library"],
|
embed = [":go_default_library"],
|
||||||
|
|
|
@ -51,7 +51,7 @@ func AnyConfigFileAndDefaultsToInternal(cfgPath string) (runtime.Object, error)
|
||||||
return ConfigFileAndDefaultsToInternalConfig(cfgPath, &kubeadmapiv1beta1.InitConfiguration{})
|
return ConfigFileAndDefaultsToInternalConfig(cfgPath, &kubeadmapiv1beta1.InitConfiguration{})
|
||||||
}
|
}
|
||||||
if kubeadmutil.GroupVersionKindsHasJoinConfiguration(gvks...) {
|
if kubeadmutil.GroupVersionKindsHasJoinConfiguration(gvks...) {
|
||||||
return NodeConfigFileAndDefaultsToInternalConfig(cfgPath, &kubeadmapiv1beta1.JoinConfiguration{})
|
return JoinConfigFileAndDefaultsToInternalConfig(cfgPath, &kubeadmapiv1beta1.JoinConfiguration{})
|
||||||
}
|
}
|
||||||
return nil, fmt.Errorf("didn't recognize types with GroupVersionKind: %v", gvks)
|
return nil, fmt.Errorf("didn't recognize types with GroupVersionKind: %v", gvks)
|
||||||
}
|
}
|
||||||
|
|
|
@ -45,8 +45,8 @@ func SetJoinDynamicDefaults(cfg *kubeadmapi.JoinConfiguration) error {
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
// NodeConfigFileAndDefaultsToInternalConfig
|
// JoinConfigFileAndDefaultsToInternalConfig
|
||||||
func NodeConfigFileAndDefaultsToInternalConfig(cfgPath string, defaultversionedcfg *kubeadmapiv1beta1.JoinConfiguration) (*kubeadmapi.JoinConfiguration, error) {
|
func JoinConfigFileAndDefaultsToInternalConfig(cfgPath string, defaultversionedcfg *kubeadmapiv1beta1.JoinConfiguration) (*kubeadmapi.JoinConfiguration, error) {
|
||||||
internalcfg := &kubeadmapi.JoinConfiguration{}
|
internalcfg := &kubeadmapi.JoinConfiguration{}
|
||||||
|
|
||||||
if cfgPath != "" {
|
if cfgPath != "" {
|
|
@ -37,13 +37,13 @@ const (
|
||||||
node_invalidYAML = "testdata/validation/invalid_nodecfg.yaml"
|
node_invalidYAML = "testdata/validation/invalid_nodecfg.yaml"
|
||||||
)
|
)
|
||||||
|
|
||||||
func TestNodeConfigFileAndDefaultsToInternalConfig(t *testing.T) {
|
func TestJoinConfigFileAndDefaultsToInternalConfig(t *testing.T) {
|
||||||
var tests = []struct {
|
var tests = []struct {
|
||||||
name, in, out string
|
name, in, out string
|
||||||
groupVersion schema.GroupVersion
|
groupVersion schema.GroupVersion
|
||||||
expectedErr bool
|
expectedErr bool
|
||||||
}{
|
}{
|
||||||
// These tests are reading one file, loading it using NodeConfigFileAndDefaultsToInternalConfig that all of kubeadm is using for unmarshal of our API types,
|
// These tests are reading one file, loading it using JoinConfigFileAndDefaultsToInternalConfig that all of kubeadm is using for unmarshal of our API types,
|
||||||
// and then marshals the internal object to the expected groupVersion
|
// and then marshals the internal object to the expected groupVersion
|
||||||
{ // v1alpha3 -> internal
|
{ // v1alpha3 -> internal
|
||||||
name: "v1alpha3ToInternal",
|
name: "v1alpha3ToInternal",
|
||||||
|
@ -69,7 +69,7 @@ func TestNodeConfigFileAndDefaultsToInternalConfig(t *testing.T) {
|
||||||
out: node_v1beta1YAML,
|
out: node_v1beta1YAML,
|
||||||
groupVersion: kubeadmapiv1beta1.SchemeGroupVersion,
|
groupVersion: kubeadmapiv1beta1.SchemeGroupVersion,
|
||||||
},
|
},
|
||||||
// These tests are reading one file that has only a subset of the fields populated, loading it using NodeConfigFileAndDefaultsToInternalConfig,
|
// These tests are reading one file that has only a subset of the fields populated, loading it using JoinConfigFileAndDefaultsToInternalConfig,
|
||||||
// and then marshals the internal object to the expected groupVersion
|
// and then marshals the internal object to the expected groupVersion
|
||||||
{ // v1beta1 -> default -> validate -> internal -> v1beta1
|
{ // v1beta1 -> default -> validate -> internal -> v1beta1
|
||||||
name: "incompleteYAMLToDefaultedv1beta1",
|
name: "incompleteYAMLToDefaultedv1beta1",
|
||||||
|
@ -87,7 +87,7 @@ func TestNodeConfigFileAndDefaultsToInternalConfig(t *testing.T) {
|
||||||
for _, rt := range tests {
|
for _, rt := range tests {
|
||||||
t.Run(rt.name, func(t2 *testing.T) {
|
t.Run(rt.name, func(t2 *testing.T) {
|
||||||
|
|
||||||
internalcfg, err := NodeConfigFileAndDefaultsToInternalConfig(rt.in, &kubeadmapiv1beta1.JoinConfiguration{})
|
internalcfg, err := JoinConfigFileAndDefaultsToInternalConfig(rt.in, &kubeadmapiv1beta1.JoinConfiguration{})
|
||||||
if err != nil {
|
if err != nil {
|
||||||
if rt.expectedErr {
|
if rt.expectedErr {
|
||||||
return
|
return
|
Loading…
Reference in New Issue